MINA服务端+flash(AS)客户端+嵌入式socket服务端互联互通

1、 应用环境：

Web服务器：TOMCAT 7

服务端开源框架：spring2.5+hibernate3+struts2

SOCKET服务端：MINA

客户端：flash+html

第三方服务端:嵌入式、socket

数据库：mysql5.5



2、 Flash客户端连接MINA服务端

Ø MINA服务端配置和spring配置文件集成，随tomcat启动而启动。
<!-- Apache mina 配置-->
<bean id="serverHandler" class="com.upos.protocol.mina.ServerHandler" />
<bean id="SecurityHandler" class="com.upos.protocol.mina.SecurityHandler"></bean>
<!-- executorFilter多线程处理 -->
<bean id="executorFilter" class="org.apache.mina.filter.executor.ExecutorFilter" />
<bean id="mdcInjectionFilter" class="org.apache.mina.filter.logging.MdcInjectionFilter">
<constructor-arg value="remoteAddress" />
</bean>
<bean id="codecFilter" class="org.apache.mina.filter.codec.ProtocolCodecFilter">
<constructor-arg>
<!-- <bean class="org.apache.mina.filter.codec.textline.TextLineCodecFactory" />-->
<!-- 处理对象流时候用ObjectSerializationCodecFactory -->
<!-- <bean class="org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory" /> -->
<bean class="com.upos.protocol.mina.ServerCodeFactory" />
</constructor-arg>
</bean>
<bean id="loggingFilter" class="org.apache.mina.filter.logging.LoggingFilter" />
<bean id="filterChainBuilder" class="org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder">
<property name="filters">
<map>
<entry key="executor" value-ref="executorFilter" />
<entry key="mdcInjectionFilter" value-ref="mdcInjectionFilter" />
<entry key="codecFilter" value-ref="codecFilter" />
<entry key="loggingFilter" value-ref="loggingFilter" />
</map>
</property>
</bean>
<bean class="org.springframework.beans.factory.config.CustomEditorConfigurer">
<property name="customEditors">
<map>
<entry key="java.net.SocketAddress">
<bean class="org.apache.mina.integration.beans.InetSocketAddressEditor" />
</entry>
</map>
</property>
</bean>
<bean id="ioAcceptor" class="org.apache.mina.transport.socket.nio.NioSocketAcceptor" init-method="bind" destroy-method="unbind">
<property name="defaultLocalAddress" value=":9001" />
<property name="handler" ref="serverHandler" />
<property name="filterChainBuilder" ref="filterChainBuilder" />
<property name="reuseAddress" value="true" />
</bean>
<bean id="ioAcceptor2" class="org.apache.mina.transport.socket.nio.NioSocketAcceptor" init-method="bind" destroy-method="unbind">
<property name="defaultLocalAddress" value=":9999" />
<property name="handler" ref="SecurityHandler" />
<property name="filterChainBuilder" ref="filterChainBuilder" />
<property name="reuseAddress" value="true" />
</bean>

ServerHandler 处理器用于服务端接收数据，应答数据。

SecurityHandler 处理器用于为flash客户端提供安全策略文件。

以上配置文件中，将ioAcceptor2的监听端口设置为9999端口。flash客户端在和服务端进行socket连接时，会先去默认的843端口请求安全策略文件。如果在843端口未获得安全授权，将会向9999端口请求安全策略文件。如果安全授权确认，flash客户端将请求ioAcceptor建立socket连接。

Ø SecurityHandler 代码如下：
public class SecurityHandler extends IoHandlerAdapter {

@Override

public void sessionOpened(IoSession session) throws Exception {

// TODO Auto-generated method stub

String xml = "<cross-domain-policy>";

xml = xml + "<allow-access-from domain="*" to-ports="*" />";

xml = xml + "</cross-domain-policy>";

session.write(xml + "\0");

}

}

Ø Flash客户端的socket连接实现类：
public class SocketBase extends Socket
{
private var myremote:MyRemoteObject;
//private var surityStr:String = "xmlsocket://"+host+":843"; ;

public function SocketBase()
{

this.objectEncoding = ObjectEncoding.AMF3;

this.addEventListener(Event.CONNECT,onConnect);
this.addEventListener(Event.CLOSE,onClose);
this.addEventListener(IOErrorEvent.IO_ERROR,onIOError);
this.addEventListener(SecurityErrorEvent.SECURITY_ERROR,onSecurityError);
this.addEventListener(ProgressEvent.SOCKET_DATA,onData);
}

override public function connect(host:String , port:int):void
{
Security.allowDomain("*");
Security.loadPolicyFile("xmlsocket://" + host +
":" + 9999);
trace('Security.loadPolicyFile('+"xmlsocket://" + host +":" + port+')');
super.connect(host,port);
}

override public function close():void
{
if(this.connected)
{
super.close();
}
}

private function onData(e:ProgressEvent):void
{
Singleton.getInstance().dispatchEvent(new SocketEvent(SocketEvent.RECEIEVED));
}
private function onConnect(e:Event):void
{
trace('连接socket服务器成功！');
loadremoteip();
}
public function loadremoteip():void{
myremote = new MyRemoteObject('minaforflexService');
var op:Operation = myremote.getOp('getRemoteIp',onSuccess);
op.send();
}
private function onSuccess(event:ResultEvent):void{
login(event.result.toString());
}
private function onClose(e:Event):void
{
trace('断开了和socket服务器的连接！');
close();
}
private function onIOError(e:IOErrorEvent):void
{
trace('连接服务器失败，请稍候操作');
}
private function onSecurityError(e:SecurityErrorEvent):void
{
trace('发生沙箱安全错误！'+e.text);
}
public function login(value:String):void{
if(!this.connected)
{
return;
}
sendMessage("LOGIN:"+value);
}
public function broadcast(senddata:String):void
{
if(!this.connected)
{
return;
}
sendMessage("BROADCAST:"+senddata);
}
public function quit():void
{
if(!this.connected)
{
return;
}
sendMessage("QUIT");
}
public function sendMessage(senddata:String):void
{
if(!this.connected)
{
return;
}
var message:ByteArray=new ByteArray();
var sendmessage:String = senddata;
message.writeMultiByte(sendmessage+"\n",'GBK');
this.writeBytes(message,0,message.length);
this.flush();//发送数据
}
}
在服务端连接成功后，会通过RemoteObject访问spring提供的后台服务，获得客户端IP地址，并通过login方法发送至mina服务端。
Mina服务记录该这次连接的session及IP地址。用于将来向flash客户端广播消息。
Ø 服务端获得客户端IP地址的代码：
@RemotingInclude
public String getRemoteIp(){
String str = FlexContext.getHttpRequest().getRemoteHost();
int i = ai.getAndIncrement();
return str+"_"+i;
}