Apache mina 与Spring整合设计

fdhfgh

其实很简单，看了网上很多例子，但是发现还是Apache自己写的比较好，于是就抄下来了。
先说配置文件,注意这里不能使用延迟加载和“byName”的方式找bean

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"
default-lazy-init="false">
<!--
This makes it possible to specify java.net.SocketAddress values (e.g.
:80 below) as Strings. They will be converted into
java.net.InetSocketAddress objects by Spring.
-->
<bean class="org.springframework.beans.factory.config.CustomEditorConfigurer">
<property name="customEditors">
<map>
<entry key="java.net.SocketAddress">
<bean class="org.apache.mina.integration.spring.InetSocketAddressEditor" />
</entry>
</map>
</property>
</bean>
<!-- The IoHandler implementation -->
<bean id="myHandler" class="com.mina.MyProtocolHandler">
</bean>
<bean id="filterChainBuilder"
class="org.apache.mina.integration.spring.DefaultIoFilterChainBuilderFactoryBean">
<property name="filters">
<list>
<bean class="org.apache.mina.filter.LoggingFilter" />
</list>
</property>
</bean>
<!--
By default MINA uses an ExecutorThreadModel. This demonstrates how to
use your own with some non default settings. The threadModel will be
set on the SocketAcceptorConfig defined below. To configure a
ExecutorFilter directly you will have to use the ThreadModel.MANUAL
ThreadModel instead.
-->
<bean id="threadModel"
class="org.apache.mina.integration.spring.ExecutorThreadModelFactoryBean">
<property name="serviceName" value="MyMinaService" />
<property name="executor">
<bean
class="org.apache.mina.integration.spring.ThreadPoolExecutorFactoryBean">
<property name="corePoolSize" value="2" />
<property name="maxPoolSize" value="30" />
<property name="keepAliveSeconds" value="30" />
</bean>
</property>
</bean>
<bean id="ioAcceptor"
class="org.apache.mina.integration.spring.IoAcceptorFactoryBean">
<property name="target">
<bean class="org.apache.mina.transport.socket.nio.SocketAcceptor" />
</property>
<property name="bindings">
<list>
<bean class="org.apache.mina.integration.spring.Binding">
<property name="address" value=":8081" />
<property name="handler" ref="myHandler" />
<property name="serviceConfig">
<bean class="org.apache.mina.transport.socket.nio.SocketAcceptorConfig">
<property name="filterChainBuilder" ref="filterChainBuilder" />
<property name="reuseAddress" value="true" />
<property name="threadModel" ref="threadModel" />
</bean>
</property>
</bean>
</list>
</property>
</bean>

</beans>


再然后我们只需要实现MyProtocolHandler就可以了,只在接收数据加了处理，数据传输用的是byte[]，MinaEndpoint里面来执行自己的代码就行了

public class MyProtocolHandler extends IoHandlerAdapter {
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
if (message instanceof ByteBuffer) {
ByteBuffer rb = (ByteBuffer) message;
byte[] moMessage = new byte[rb.remaining()];
rb.get(moMessage);
Endpoint endpoint = new MinaEndpoint(session);
endpoint.receive(moMessage);
}
super.messageReceived(session, message);
}
}

最后就是EndPoint了，其实就两个方法，一个接收,一个发送

public class MinaEndpoint implements Endpoint {
private IoSession session;
public MinaEndpoint(IoSession session) {
this.session = session;
}
public void send(byte[] data) {
if (session.isConnected() && ArrayUtils.isEmpty(data)) {
ByteBuffer byteBuffer = ByteBuffer.allocate(data.length);
byteBuffer.put(data);
byteBuffer.flip();
session.write(byteBuffer);
}
}
public void receive(byte[] data) {
//Service的实现操作
}

其实这玩意主要还是配置文件，这个还是抄自IoAcceptorFactoryBean的API的说明，呵呵