用red5和flex实现的一个小的聊天程序

程序的基本功能

1.用户连接、断开连接

2.显示用户登录列表

3.信息群聊

4.私聊

red5程序：ChatRoom.java

package com.red5;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Logger;

import org.red5.server.adapter.ApplicationAdapter;
import org.red5.server.api.IConnection;
import org.red5.server.api.IScope;
import org.red5.server.api.Red5;
import org.red5.server.api.service.IServiceCapableConnection;
import org.red5.server.api.so.ISharedObject;

/**
 * @category 一个简单的聊天程序
 * @author Administrator
 *
 */
public class ChatRoom extends ApplicationAdapter {
	private static Logger log = Logger.getLogger(ChatRoom.class.getName());
	private Map<String, IConnection> clientDic = new HashMap<String, IConnection>();
	
	/**
	 * @category 客户端连接时调用
	 */
	@Override
	public synchronized boolean connect(IConnection conn, IScope scope,
			Object[] params) {
		if(params.length == 0) {
			rejectClient("Must pass the login name.");
		}
		
		String loginname = params[0].toString();
		conn.setAttribute("UserName", loginname);
		
		//如果用户不存在于当前的连接中，则将其加入
		//如果不存在共享对象，则创建
		if(clientDic.keySet().contains(loginname)) {
			rejectClient("The same user has logged in already");
		} else {
			clientDic.put(loginname, conn);
			ISharedObject so = getSharedObject(scope, "UserSO");
			if(so == null) {
				createSharedObject(scope, "UserSO", true);
				so = getSharedObject(scope, "UserSO");
			}
			so.setAttribute("userlist", clientDic.keySet().toArray());
		}
		
		return super.connect(conn, scope, params);
	}

	/**
	 * @category 客户端失去连接时调用
	 */
	@Override
	public synchronized void disconnect(IConnection conn, IScope scope) {
		String loginname = conn.getAttribute("UserName").toString();
		if(loginname != null) {
			if(clientDic.keySet().contains(loginname)) {
				clientDic.remove(loginname);
				ISharedObject so = getSharedObject(scope, "UserSO");
				if(so != null) {
					so.setAttribute("userlist", clientDic.keySet().toArray());
				}
			}
		}
		super.disconnect(conn, scope);
	}
	
	/**
	 * @category 发送全局消息，所有上线的人都能够看到
	 * @param params
	 */
	public void sendMessage(List<String> params) {
		IConnection conn = Red5.getConnectionLocal();
		IScope scope = conn.getScope();
		ISharedObject so = getSharedObject(scope, "UserSO");
		log.info("Server: call sendMessage and params " + params.get(0));
		so.sendMessage("receiveMsg", params);
	}
	
	/**
	 * @category 发送私聊信息，只有被选中的人能够看到信息
	 * @param params
	 */
	public void sendPrvMessage(List<String> params) {
		if(params.size() == 3) {
			String sender = params.get(0);
			String content = params.get(1);
			String receiver = params.get(2);
			
			if(clientDic.keySet().contains(receiver)) {
				IConnection conn = clientDic.get(receiver);
				if(conn instanceof IServiceCapableConnection) {
					IServiceCapableConnection sc = (IServiceCapableConnection) conn;
					
					log.info("Server: call sendPrvMessage and sender->" + sender 
							+ " content->" + content + " receiver->" + receiver);
					
					sc.invoke("receivePrvMsg", new Object[]{sender,content});
				}
			}
		}
	}

	public Boolean appStart() {
		return true;
	}
	
	public void appStop() {
		
	}
}

相关配置文件：

1.red5-web.properties

webapp.contextPath=/chatRoom
webapp.virtualHosts=localhost, 127.0.0.1

2.red5-web.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
	
	<bean id="placeholderConfig" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
	    <property name="location" value="/WEB-INF/red5-web.properties" />
	</bean>
	
	<bean id="web.context" class="org.red5.server.Context" 
		autowire="byType" />
	
	<bean id="web.scope" class="org.red5.server.WebScope"
		 init-method="register">
		<property name="server" ref="red5.server" />
		<property name="parent" ref="global.scope" />
		<property name="context" ref="web.context" />
		<property name="handler" ref="web.handler" />
		<property name="contextPath" value="${webapp.contextPath}" />
		<property name="virtualHosts" value="${webapp.virtualHosts}" />
	</bean>

	<bean id="web.handler" 
	    class="com.red5.ChatRoom" 
		singleton="true" />

    <!-- this will support calling methods through "myhandler.<methodName>" -->
	<!-- <bean id="myhandler.service" 
	    class="the.path.to.my.ServiceHandler" 
		singleton="true" /> -->

</beans>

3.web.xml

<?xml version="1.0" encoding="ISO-8859-1"?>
<web-app 
   xmlns="http://java.sun.com/xml/ns/j2ee" 
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd" 
   version="2.4"> 

	<display-name>firstapp</display-name>

	<context-param>
	    <param-name>globalScope</param-name>
	    <param-value>default</param-value>
	</context-param>

	<context-param>
	    <param-name>contextConfigLocation</param-name>
	    <param-value>/WEB-INF/red5-*.xml</param-value>
	</context-param>

	<context-param>
		<param-name>locatorFactorySelector</param-name>
		<param-value>red5.xml</param-value>
	</context-param>

	<context-param>
		<param-name>parentContextKey</param-name>
		<param-value>default.context</param-value>
	</context-param>
	
	<context-param>
	    <param-name>log4jConfigLocation</param-name>
	    <param-value>/WEB-INF/log4j.properties</param-value>
	</context-param>
	
	<context-param>
		<param-name>webAppRootKey</param-name>
		<param-value>/chatRoom</param-value>
	</context-param>
	
    <security-constraint>
        <web-resource-collection>
            <web-resource-name>Forbidden</web-resource-name>
            <url-pattern>/streams/*</url-pattern>
        </web-resource-collection>
        <auth-constraint/>
    </security-constraint>

</web-app>

flex程序:chatRoom.mxml

<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute">
	<mx:Script>
		<![CDATA[
			import mx.charts.chartClasses.StackedSeries;
			import mx.formatters.SwitchSymbolFormatter;
			import mx.controls.Alert;
			
			private var conn:NetConnection;
			private var so:SharedObject;
			private var rtmpURL:String = "rtmp://localhost/chatRoom";
			
			private function connHandler(evnet:Event):void {
				var loginname:String = loginName.text;
				if(loginname == "") {
					Alert.show("login name is null");
					return;
				} else {
					if(conn == null) {
						initNetConnection(loginname);
					}
				}
			}
			
			/**
			 * 初始化连接
			 */ 
			private function initNetConnection(loginname:String):void {
				conn = new NetConnection();
				conn.addEventListener(NetStatusEvent.NET_STATUS, netStatus);
				conn.connect(rtmpURL, loginname);	
			}
			
			private function netStatus(event:NetStatusEvent):void {
				if("NetConnection.Connect.Success" == event.info.code) {
					sendBtn.enabled = true;
					so = SharedObject.getRemote("UserSO", conn.uri, true);
					so.addEventListener(SyncEvent.SYNC, onSync);
					so.client = this;	//设置群聊时接收到消息的窗体
					conn.client = this;	//设置私聊时接收到消息的窗体
					so.connect(conn);
				}
			}
			
			private function onSync(event:SyncEvent):void {
				for(var i:Object in event.changeList) {
					var changeObj:Object = event.changeList[i];
					switch(changeObj.code) {
						case "success":
							break;
						case "change":
							userList.dataProvider = so.data.userlist;
							break;
					}
				}				
			}
			
			/**
			 * 失去连接
			 */ 
			private function disconnhandler(event:Event):void {
				if(conn != null && conn.connected) {
					conn.close();
					var nularr:Array = new Array();
					userList.dataProvider = nularr;
				}
			}
			
			/**
			 * 发送消息
			 */ 
			private function sendHandler(event:Event):void {
				if(conn != null && conn.connected) {
					if(IsPrivate.selected) {
						if(userList.selectedIndex == -1) {
							Alert.show("must choose a user first");
						} else {
							var pusername:String = userList.selectedItem.toString();
							if(pusername == loginName.text) {
								Alert.show("can't say privately to self");
							} else {
								//调用服务器端的私聊函数
								conn.call("sendPrvMessage", null, loginName.text, loginName.text + " says privately: " 
										+ chatWord.text, pusername);
								chatWord.text = "";
							}
						}
					} else {
						if(chatWord.text != "") {
							//调用服务器端的群聊函数
							conn.call("sendMessage", null, loginName.text + " says: " + chatWord.text);
							chatWord.text = "";
						}
					}
				}
			}
			
			/**
			 * 接收私聊信息并显示
			 */ 
			public function receivePrvMsg(sender:String, msg:String):void {
				chatArea.text += msg + "\n";
			}
			
			/**
			 * 接收群聊信息并显示
			 */ 
			public function receiveMsg(msg:String):void {
				chatArea.text += msg + "\n";
			}			
		]]>
	</mx:Script>

	<mx:Panel width="585" height="480" layout="absolute" title="ChatRoom" horizontalCenter="0" verticalCenter="0">
		<mx:Label x="46" y="26" text="Login Name:"/>
		<mx:TextInput x="125" y="24" id="loginName"/>
		<mx:Button x="314" y="24" label="Connect" id="connBtn" click="connHandler(event)"/>
		<mx:Button x="406" y="24" label="DisConnect" id="disconnBtn" click="disconnhandler(event)"/>
		<mx:TextArea x="241" y="73" width="255" height="248" id="chatArea"/>
		<mx:Label text="Chat:" horizontalCenter="-140" verticalCenter="175"/>
		<mx:TextInput x="169" y="384" width="249" id="chatWord"/>
		<mx:Button x="426" y="384" label="send" id="sendBtn" width="68" enabled="false" click="sendHandler(event)"/>
		<mx:CheckBox x="68" y="340" label="Private Chat" id="IsPrivate"/>
		<mx:TileList x="46" y="73" width="164" height="248" id="userList" columnCount="1" direction="vertical"></mx:TileList>
	</mx:Panel>
	
</mx:Application>

效果图：