1、下载相应的开发包http://mina.apache.org/,MINA2.0版本包含了spring开发包,还需下载其他相关包,我的工程用到的包如下图:
2、配置spring的applicationContext.xml,配置mina服务;
- <?xml version="1.0" encoding="UTF-8"?>
-
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:aop="http://www.springframework.org/schema/aop"
- xmlns:tx="http://www.springframework.org/schema/tx"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
- http://www.springframework.org/schema/aop
- http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
- http://www.springframework.org/schema/tx
- http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
-
-
- <bean id="serverHandler" class="com.supconit.its.server.handler.ServerHandler" />
-
-
- <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="com.supconit.its.server.handler.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=":1235" />
- <property name="handler" ref="serverHandler" />
- <property name="filterChainBuilder" ref="filterChainBuilder" />
- <property name="reuseAddress" value="true" />
- </bean>
3、ServerHandler实现类
- package com.supconit.its.server.handler;
-
- import java.net.InetSocketAddress;
- import java.util.Collections;
- import java.util.Date;
- import java.util.HashSet;
- import java.util.Set;
-
- import org.apache.log4j.Logger;
- import org.apache.mina.core.service.IoHandlerAdapter;
- import org.apache.mina.core.session.IdleStatus;
- import org.apache.mina.core.session.IoSession;
-
-
- public class ServerHandler extends IoHandlerAdapter {
-
- private final int IDLE = 300;
-
-
- private final Logger log = Logger.getLogger(ServerHandler.class.getName());
-
- public static Set<IoSession> sessions = Collections .synchronizedSet(new HashSet<IoSession>());
-
-
-
-
- public ServerHandler(){
-
- }
-
- @Override
- public void exceptionCaught(IoSession session, Throwable cause)
- throws Exception {
- session.close();
-
- log.debug("session occured exception, so close it." + cause.getMessage());
- }
-
- @Override
- public void sessionCreated(IoSession session) {
-
- log.debug("remote client ["+session.getRemoteAddress().toString()+"] connected.");
- session.write("Welcome");
- sessions.add(session);
- }
-
- @Override
- public void messageReceived(IoSession session, Object message)
- throws Exception {
- String str = message.toString();
- log.debug("Message written..." + str);
- log.debug("客户端"+((InetSocketAddress) session.getRemoteAddress()).getAddress().getHostAddress()+"连接成功!");
-
-
-
-
-
-
-
-
- session.setAttribute("type", message);
- String remoteAddress = ((InetSocketAddress) session.getRemoteAddress()).getAddress().getHostAddress();
- session.setAttribute("ip", remoteAddress);
-
- }
-
- @Override
- public void sessionClosed(IoSession session) throws Exception {
- log.debug("sessionClosed.");
- sessions.remove(session);
- }
-
- @Override
- public void sessionIdle(IoSession session, IdleStatus status)
- throws Exception {
- log.debug("session idle, so disconnecting......");
- session.close();
- log.debug("disconnected.");
- }
-
-
- @Override
- public void messageSent(IoSession session, Object message) throws Exception {
- log.debug("messageSent.");
-
-
- }
-
- @Override
- public void sessionOpened(IoSession session) throws Exception {
- log.debug("sessionOpened.");
-
- session.getConfig().setIdleTime(IdleStatus.BOTH_IDLE, IDLE);
- }
-
- }
4、过滤器ServerCodeFactory
- package com.supconit.its.server.handler;
-
- import java.nio.charset.Charset;
-
- import org.apache.mina.core.session.IoSession;
- import org.apache.mina.filter.codec.ProtocolCodecFactory;
- import org.apache.mina.filter.codec.ProtocolDecoder;
- import org.apache.mina.filter.codec.ProtocolEncoder;
- import org.apache.mina.filter.codec.textline.LineDelimiter;
- import org.apache.mina.filter.codec.textline.TextLineDecoder;
- import org.apache.mina.filter.codec.textline.TextLineEncoder;
-
- public class ServerCodeFactory implements ProtocolCodecFactory {
-
- private final TextLineEncoder encoder;
- private final TextLineDecoder decoder;
-
- final static char endchar = 0x0d;
- public ServerCodeFactory() {
- this(Charset.forName("gb2312"));
- }
- public ServerCodeFactory(Charset charset) {
- encoder = new TextLineEncoder(charset, LineDelimiter.UNIX);
- decoder = new TextLineDecoder(charset, LineDelimiter.AUTO);
- }
-
- @Override
- public ProtocolDecoder getDecoder(IoSession session) throws Exception {
-
- return decoder;
- }
- @Override
- public ProtocolEncoder getEncoder(IoSession session) throws Exception {
-
- return encoder;
- }
- public int getEncoderMaxLineLength() {
- return encoder.getMaxLineLength();
- }
- public void setEncoderMaxLineLength(int maxLineLength) {
- encoder.setMaxLineLength(maxLineLength);
- }
- public int getDecoderMaxLineLength() {
- return decoder.getMaxLineLength();
- }
- public void setDecoderMaxLineLength(int maxLineLength) {
- decoder.setMaxLineLength(maxLineLength);
- }
-
- }
5、启动spring+mina socket server;
- package com.supconit.its.server.test;
-
- import org.springframework.context.support.ClassPathXmlApplicationContext;
-
- public class Test {
-
-
-
-
- public static void main(String[] args) {
- ClassPathXmlApplicationContext ct = new ClassPathXmlApplicationContext("applicationContext.xml");
-
- }
-
- }
6、客户端测试ClintTest
- package com.supconit.its.server.test;
-
- import java.net.InetSocketAddress;
- import java.nio.charset.Charset;
-
- import org.apache.mina.core.future.ConnectFuture;
- import org.apache.mina.filter.codec.ProtocolCodecFilter;
- import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
- import org.apache.mina.filter.logging.LoggingFilter;
- import org.apache.mina.transport.socket.nio.NioSocketConnector;
-
- import com.supconit.its.server.handler.ServerHandler;
-
-
-
- public class ClintTest {
-
-
-
-
- public static void main(String[] args) {
- NioSocketConnector connector = new NioSocketConnector();
- connector.getFilterChain().addLast( "logger", new LoggingFilter() );
-
- connector.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( )));
- connector.setConnectTimeout(1);
- connector.setHandler(new ServerHandler());
- ConnectFuture cf = connector.connect(
- new InetSocketAddress("127.0.0.1", 1235));
- cf.awaitUninterruptibly();
- cf.getSession().write("hello,测试!");
-
- cf.getSession().close();
- cf.getSession().getCloseFuture().awaitUninterruptibly();
- connector.dispose();
-
- }
-
- }
分享到:
相关推荐
参见博客: http://blog.csdn.net/joe_storm/article/details/11041763
这是一个基于spring mina 的服务端整合框架
mina2+spring结合实例
SSI+Mina2(Struts2+Spring4+Mybatis3+Mina2)集成,都是最新的包, 发布就可运行,配置文件都写了详细的注释。
集成框架SpringBoot+myBatis+Mina,内附CRC校验工具类和进制转换工具类 SpringBoot集成Socket通讯之Mina框架
该项目是本人真实项目中使用到的mina + spring+struts2 + mybatis框架,里面有详细的注释说明,以及一个完整的接收消息、入库、返回例子。对需要真实项目开发的人员来说,可以直接使用。 另外,如果需要更加详细的...
mina 与spring的结合开发 ,mina 学习,spring 学习,
mina2核心框架5000个并发
找了很长时间网上没有一个详细整合的例子,现在已整合成功 放上来让大家参照,少走弯路,稍后会放出博客说明 使用idea 打开后可以直接使用的例子,很珍贵
mina函数.xls
apahce的MINA例子,包含了与spring的整合
一个mina跟Spring、Hibernate整合的说明文档,挺好的,有需要的可以看看
Apache Mina Server 是一个网络通信应用框架,也就是说,它主要是对基于TCP/IP、UDP/IP 协议栈的通信框架(当然,也可以提供JAVA 对象的序列化服务、虚拟机管道通信服务等),...Mina 主要有1.x 和2.x 两个分支…………
2.系统读取mina-spring.xml。如果想把该工程导成jar则需要处理下配置文件的路径 3.结合自己系统时(导成jar集成进自己系统)需要继承与serverHandler,实现里面doService方法 4.本系统支持HTTP以及TCP链接,这个是...
基于java的开发源码-mina高性能Java网络框架.zip 基于java的开发源码-mina高性能Java网络框架.zip 基于java的开发源码-mina高性能Java网络框架.zip 基于java的开发源码-mina高性能Java网络框架.zip 基于java的开发...
本工程用于研究Apache Mina技术 本工程编码方式:UTF-8 本工程开发工具:MyEclipse 本工程运行步骤: 1、运行StartMinaServer类 2、运行StartMinaClient类
简单的基于spring的mina 框架,可以用来做tcp网络连接。
org.apache.mina.core.buffer.IoBuffer mina core 包
mina框架介绍、主要接口介绍:IoService、IoAcceptor、IoConnector、IoSession、IoSessionConfig、IoHandler、IoBuffer、IoFuture等;信息分段处理demo、多路分离编解码demo、与Spring/JMX集成示例
Mina 主要有 1.x 和 2.x 两个分支,这里我们讲解最新版本 2.0,如果你使用的是 Mina 1.x,那么可能会有一些功能并不适用。学习本文档,需要你已掌握 JAVA IO、JAVA NIO、JAVA Socket、JAVA 线程及并发库(java.util....