Create server with spring.
Introduction
Create missian server with spring
Details
Step 1:Create an spring context configuration file
<?xml version="1.0" encoding="UTF-8"?> <beansxmlns="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-3.0.xsd"> </beans>
Step 2:Create a custom editors to convert a 'host:port' string to SocketAddress
<beanclass="org.springframework.beans.factory.config.CustomEditorConfigurer"> <propertyname="customEditors"> <map> <entrykey="java.net.SocketAddress"> <beanclass="org.apache.mina.integration.beans.InetSocketAddressEditor"/> </entry> </map> </property> </bean>
Step 3:Build filters especially the Codec filter
<beanid="executorFilter"class="org.apache.mina.filter.executor.ExecutorFilter"/> <beanid="codecFilter"class="org.apache.mina.filter.codec.ProtocolCodecFilter"> <constructor-arg> <beanclass="com.missian.server.codec.MissianCodecFactory"/> </constructor-arg> </bean> <beanid="loggingFilter"class="org.apache.mina.filter.logging.LoggingFilter"> <propertyname="messageReceivedLogLevel"value="DEBUG"/> <propertyname="messageSentLogLevel"value="DEBUG"/> <propertyname="sessionCreatedLogLevel"value="DEBUG"/> <propertyname="sessionClosedLogLevel"value="DEBUG"/> <propertyname="sessionIdleLogLevel"value="DEBUG"/> <propertyname="sessionOpenLogLevel"value="DEBUG"/> </bean>
Step 4:Create the filter chain
<beanid="filterChainBuilder" class="org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder"> <propertyname="filters"> <map> <entrykey="codecFilter"value-ref="codecFilter"/> <entrykey="executor"value-ref="executorFilter"/> <entrykey="loggingFilter"value-ref="loggingFilter"/> </map> </property> </bean>
Step 5:Create the message handler
<beanid="minaHandler"class="com.missian.server.handler.MissianHandler"> <constructor-arg> <beanclass="com.missian.common.beanlocate.SpringLocator"/> </constructor-arg> </bean>
Please node that we create an SpringLocator instance and inject it to the MissianHandler, so that the handler can lookup beans in the spring context.
SpringLocator is provided by missian and its source code as below:
publicclassSpringLocatorimplementsBeanLocator,ApplicationContextAware{ privateApplicationContext applicationContext; @Override publicObject lookup(String beanName){ return applicationContext.getBean(beanName); } @Override publicvoid setApplicationContext(ApplicationContext applicationContext) throwsBeansException{ this.applicationContext = applicationContext; } }
Step 6: Mina NioSocketAcceptor
<beanid="minaAcceptor"class="org.apache.mina.transport.socket.nio.NioSocketAcceptor" init-method="bind"destroy-method="unbind"> <propertyname="defaultLocalAddress"value=":1235"/><!----> <propertyname="handler"ref="minaHandler"/> <propertyname="reuseAddress"value="true"/> <propertyname="filterChainBuilder"ref="filterChainBuilder"/> </bean>
Step 7:Create business beans
Create an interface, for example:
publicinterfaceHello{ publicString hello(String name,int age); }
Implements the business interface
publicclassHelloImplimplementsHello{ @Override publicString hello(String name,int age){ return"hi, "+name+", "+age; } }
And now configure this business implementation in spring:
<beanid="hello"class="com.missian.example.bean.HelloImpl"></bean>
Step 8:Startup the server
publicstaticvoid main(String[] args){ newClassPathXmlApplicationContext("com/missian/example/server/withspring/applicationContext-*.xml"); }