`

mina2.x与spring的集成开发

    博客分类:
  • MINA
 
阅读更多

1、下载相应的开发包http://mina.apache.org/,MINA2.0版本包含了spring开发包,还需下载其他相关包,我的工程用到的包如下图:

 

 

2、配置spring的applicationContext.xml,配置mina服务;

 

  1. <?xml version="1.0" encoding="UTF-8"?>  
  2.   
  3. <beans xmlns="http://www.springframework.org/schema/beans"   
  4.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   
  5.        xmlns:aop="http://www.springframework.org/schema/aop"   
  6.        xmlns:tx="http://www.springframework.org/schema/tx"   
  7.        xsi:schemaLocation="http://www.springframework.org/schema/beans   
  8.        http://www.springframework.org/schema/beans/spring-beans-2.5.xsd   
  9.        http://www.springframework.org/schema/aop   
  10.        http://www.springframework.org/schema/aop/spring-aop-2.5.xsd   
  11.        http://www.springframework.org/schema/tx   
  12.        http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">  
  13.   
  14.     <!-- mina server -->  
  15.     <bean id="serverHandler" class="com.supconit.its.server.handler.ServerHandler" />  
  16.       
  17.     <!-- executorFilter多线程处理 -->  
  18.     <bean id="executorFilter" class="org.apache.mina.filter.executor.ExecutorFilter" />  
  19.       
  20.     <bean id="mdcInjectionFilter" class="org.apache.mina.filter.logging.MdcInjectionFilter">  
  21.         <constructor-arg value="remoteAddress" />  
  22.     </bean>  
  23.       
  24.     <bean id="codecFilter" class="org.apache.mina.filter.codec.ProtocolCodecFilter">  
  25.         <constructor-arg>  
  26.         <!-- <bean class="org.apache.mina.filter.codec.textline.TextLineCodecFactory" />-->  
  27.         <!-- 处理对象流时候用ObjectSerializationCodecFactory -->  
  28.         <!-- <bean class="org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory" /> -->  
  29.             <bean class="com.supconit.its.server.handler.ServerCodeFactory" />  
  30.         </constructor-arg>  
  31.     </bean>  
  32.       
  33.     <bean id="loggingFilter" class="org.apache.mina.filter.logging.LoggingFilter" />  
  34.       
  35.     <bean id="filterChainBuilder" class="org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder">  
  36.         <property name="filters">  
  37.             <map>  
  38.                 <entry key="executor" value-ref="executorFilter" />  
  39.                 <entry key="mdcInjectionFilter" value-ref="mdcInjectionFilter" />  
  40.                 <entry key="codecFilter" value-ref="codecFilter" />  
  41.                 <entry key="loggingFilter" value-ref="loggingFilter" />  
  42.             </map>  
  43.         </property>  
  44.     </bean>  
  45.       
  46.     <bean class="org.springframework.beans.factory.config.CustomEditorConfigurer">  
  47.         <property name="customEditors">  
  48.             <map>  
  49.                 <entry key="java.net.SocketAddress">  
  50.                     <bean class="org.apache.mina.integration.beans.InetSocketAddressEditor" />  
  51.                 </entry>  
  52.             </map>  
  53.         </property>  
  54.     </bean>  
  55.   
  56.     <bean id="ioAcceptor" class="org.apache.mina.transport.socket.nio.NioSocketAcceptor" init-method="bind" destroy-method="unbind">  
  57.         <property name="defaultLocalAddress" value=":1235" />  
  58.         <property name="handler" ref="serverHandler" />  
  59.         <property name="filterChainBuilder" ref="filterChainBuilder" />  
  60.         <property name="reuseAddress" value="true" />  
  61.     </bean>  

3、ServerHandler实现类

  1. package com.supconit.its.server.handler;  
  2.   
  3. import java.net.InetSocketAddress;  
  4. import java.util.Collections;  
  5. import java.util.Date;  
  6. import java.util.HashSet;  
  7. import java.util.Set;  
  8.   
  9. import org.apache.log4j.Logger;  
  10. import org.apache.mina.core.service.IoHandlerAdapter;  
  11. import org.apache.mina.core.session.IdleStatus;  
  12. import org.apache.mina.core.session.IoSession;  
  13.   
  14.   
  15. public class ServerHandler extends IoHandlerAdapter {  
  16.   
  17.     private final int IDLE = 300;  
  18.       
  19.      //private final Logger log = LoggerFactory .getLogger(HandlerTwo.class);  
  20.      private final Logger log = Logger.getLogger(ServerHandler.class.getName());  
  21.   
  22.      public static Set<IoSession> sessions = Collections .synchronizedSet(new HashSet<IoSession>());  
  23.        
  24.     /** 
  25.      *  
  26.      */  
  27.     public ServerHandler(){  
  28.           
  29.     }  
  30.   
  31.     @Override  
  32.     public void exceptionCaught(IoSession session, Throwable cause)  
  33.             throws Exception {  
  34.         session.close();  
  35.         //log.debug("session occured exception, so close it.");  
  36.         log.debug("session occured exception, so close it." + cause.getMessage());  
  37.     }  
  38.       
  39.     @Override  
  40.     public void sessionCreated(IoSession session) {  
  41.         //   
  42.         log.debug("remote client ["+session.getRemoteAddress().toString()+"] connected.");  
  43.         session.write("Welcome");  
  44.         sessions.add(session);  
  45.     }  
  46.       
  47.     @Override  
  48.     public void messageReceived(IoSession session, Object message)  
  49.             throws Exception {  
  50.         String str = message.toString();  
  51.         log.debug("Message written..." + str);  
  52.         log.debug("客户端"+((InetSocketAddress) session.getRemoteAddress()).getAddress().getHostAddress()+"连接成功!");  
  53.         /*if (str.trim().equalsIgnoreCase("quit")) { 
  54.             session.close();//  
  55.             return; 
  56.         }*/  
  57.         //Date date = new Date();  
  58.         //session.write(date.toString());//   
  59.         //session.setAttribute(remoteAddress, message);  
  60.           
  61.         session.setAttribute("type", message);  
  62.         String remoteAddress = ((InetSocketAddress) session.getRemoteAddress()).getAddress().getHostAddress();  
  63.         session.setAttribute("ip", remoteAddress);  
  64.           
  65.     }  
  66.   
  67.     @Override  
  68.     public void sessionClosed(IoSession session) throws Exception {  
  69.          log.debug("sessionClosed.");  
  70.         sessions.remove(session);  
  71.     }  
  72.   
  73.     @Override  
  74.     public void sessionIdle(IoSession session, IdleStatus status)  
  75.             throws Exception {  
  76.         log.debug("session idle, so disconnecting......");  
  77.         session.close();  
  78.         log.debug("disconnected.");  
  79.     }  
  80.       
  81.     //   
  82.     @Override  
  83.     public void messageSent(IoSession session, Object message) throws Exception {  
  84.          log.debug("messageSent.");  
  85.         // disconnect an idle client  
  86.         //session.close();  
  87.     }  
  88.       
  89.     @Override  
  90.     public void sessionOpened(IoSession session) throws Exception {  
  91.         log.debug("sessionOpened.");  
  92.         //  
  93.         session.getConfig().setIdleTime(IdleStatus.BOTH_IDLE, IDLE);  
  94.     }  
  95.   
  96. }  

4、过滤器ServerCodeFactory

  1. package com.supconit.its.server.handler;  
  2.   
  3. import java.nio.charset.Charset;  
  4.   
  5. import org.apache.mina.core.session.IoSession;  
  6. import org.apache.mina.filter.codec.ProtocolCodecFactory;  
  7. import org.apache.mina.filter.codec.ProtocolDecoder;  
  8. import org.apache.mina.filter.codec.ProtocolEncoder;  
  9. import org.apache.mina.filter.codec.textline.LineDelimiter;  
  10. import org.apache.mina.filter.codec.textline.TextLineDecoder;  
  11. import org.apache.mina.filter.codec.textline.TextLineEncoder;  
  12.   
  13. public  class ServerCodeFactory implements ProtocolCodecFactory {  
  14.   
  15.         private final TextLineEncoder encoder;  
  16.         private final TextLineDecoder decoder;  
  17.         /*final static char endchar = 0x1a;*/  
  18.         final static char endchar = 0x0d;  
  19.         public ServerCodeFactory() {  
  20.             this(Charset.forName("gb2312"));  
  21.         }  
  22.         public ServerCodeFactory(Charset charset) {  
  23.              encoder = new TextLineEncoder(charset, LineDelimiter.UNIX);     
  24.              decoder = new TextLineDecoder(charset, LineDelimiter.AUTO);     
  25.              }  
  26.   
  27.         @Override  
  28.         public ProtocolDecoder getDecoder(IoSession session) throws Exception {  
  29.             // TODO Auto-generated method stub  
  30.             return decoder;  
  31.         }  
  32.         @Override  
  33.         public ProtocolEncoder getEncoder(IoSession session) throws Exception {  
  34.             // TODO Auto-generated method stub  
  35.             return encoder;  
  36.         }  
  37.         public int getEncoderMaxLineLength() {  
  38.             return encoder.getMaxLineLength();  
  39.         }  
  40.         public void setEncoderMaxLineLength(int maxLineLength) {  
  41.             encoder.setMaxLineLength(maxLineLength);  
  42.         }  
  43.         public int getDecoderMaxLineLength() {  
  44.             return decoder.getMaxLineLength();  
  45.         }  
  46.         public void setDecoderMaxLineLength(int maxLineLength) {  
  47.             decoder.setMaxLineLength(maxLineLength);  
  48.         }  
  49.   
  50. }  

5、启动spring+mina socket server;

  1. package com.supconit.its.server.test;  
  2.   
  3. import org.springframework.context.support.ClassPathXmlApplicationContext;  
  4.   
  5. public class Test {  
  6.   
  7.     /** 
  8.      * @param args 
  9.      */  
  10.     public static void main(String[] args) {  
  11.         ClassPathXmlApplicationContext ct =    new ClassPathXmlApplicationContext("applicationContext.xml");     
  12.   
  13.     }  
  14.   
  15. }  

6、客户端测试ClintTest

  1. package com.supconit.its.server.test;  
  2.   
  3. import java.net.InetSocketAddress;  
  4. import java.nio.charset.Charset;  
  5.   
  6. import org.apache.mina.core.future.ConnectFuture;  
  7. import org.apache.mina.filter.codec.ProtocolCodecFilter;  
  8. import org.apache.mina.filter.codec.textline.TextLineCodecFactory;  
  9. import org.apache.mina.filter.logging.LoggingFilter;  
  10. import org.apache.mina.transport.socket.nio.NioSocketConnector;  
  11.   
  12. import com.supconit.its.server.handler.ServerHandler;  
  13.   
  14.   
  15.   
  16. public class ClintTest {  
  17.   
  18.     /** 
  19.      * @param args 
  20.      */  
  21.     public static void main(String[] args) {  
  22.         NioSocketConnector connector = new NioSocketConnector();   
  23.         connector.getFilterChain().addLast( "logger"new LoggingFilter() );   
  24.         //connector.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "GBK" )))); //  
  25.         connector.getFilterChain().addLast( "codec"new ProtocolCodecFilter( new TextLineCodecFactory( )));   
  26.         connector.setConnectTimeout(1);   
  27.         connector.setHandler(new ServerHandler());//  
  28.         ConnectFuture cf = connector.connect(   
  29.         new InetSocketAddress("127.0.0.1"1235));//  
  30.         cf.awaitUninterruptibly();//  
  31.         cf.getSession().write("hello,测试!");//  
  32.         //cf.getSession().write("quit");//  
  33.         cf.getSession().close();  
  34.         cf.getSession().getCloseFuture().awaitUninterruptibly();//  
  35.         connector.dispose();   
  36.   
  37.     }  
  38.   
  39. }  

分享到:
评论

相关推荐

    mina2.x开发示例

    **Mina2.x开发示例** Apache Mina是一个开源项目,提供了一个高度可扩展的网络通信框架,适用于各种协议,如TCP、UDP和HTTP。它主要用于简化开发高性能、高并发的网络应用程序,如服务器和客户端。在Mina2.x版本中...

    apache mina-spring 服务端程序

    通过这个项目,开发者可以学习到如何将Mina的异步I/O能力与Spring的容器管理及依赖注入机制结合,构建出健壮且易于维护的网络服务端程序。这包括理解Mina的事件模型、Spring的bean管理和网络编程的最佳实践。同时,...

    Mina-Spring-Hibernate.rar_mina_mina hibernate_spring mina

    在Java开发领域,Mina、Spring和Hibernate是三个非常重要的技术组件。Mina作为一个高效的网络通信框架,Spring作为全栈式框架,而Hibernate则是主流的对象关系映射(ORM)框架。将这三个框架进行整合,可以构建出...

    mina2+spring结合实例

    《Mina2与Spring整合应用实战》 在Java开发领域,Apache Mina和Spring框架的结合使用能够构建高效、可扩展的网络应用。Mina2作为一个轻量级的网络通信框架,提供了高度抽象的API,使得开发者可以方便地处理网络I/O...

    spring boot 整合mina 串口

    在Java开发中,有时我们需要与硬件设备进行串口通信,例如读取传感器数据或控制工业设备。Spring Boot作为一款轻量级的框架,使得快速构建应用变得简单。而Mina则是一款强大的网络通信库,它提供了对TCP/IP和UDP协议...

    SSI+Mina2(Struts2+Spring4+Mybatis3+Mina2)集成发布就可运行

    标题中的"SSI+Mina2(Struts2+Spring4+Mybatis3+Mina2)集成发布就可运行"指的是一个基于Java的Web应用程序开发框架的整合,它结合了多种技术来构建高效、灵活和可扩展的网络应用。这个集成方案主要包括以下组件: 1....

    Mina例子包含与spring整合

    在这个"Mina例子包含与Spring整合"的项目中,我们将探讨如何将MINA与流行的Java企业级框架Spring进行集成。 1. **Apache MINA**:MINA是基于Java NIO(非阻塞I/O)的网络应用框架,用于构建高性能、跨平台的服务器...

    基于Java8,SpringBoot,WebFlux,Netty,Vert.x,Reactor等开发, 一个全响应式的物联网平台

    JetLinks 基于Java8,Spring Boot 2.x ,WebFlux,Netty,Vert.x,Reactor等开发, 是一个全响应式的企业级物联网平台。支持统一物模型管理,多种设备,多种厂家,统一管理。统一设备连接管理,多协议适配(TCP,MQTT,UDP,CoAP,...

    MinaDemo.zip SpringBoot集成Socket通讯

    @Value("${mina.port:8080}") private int port; @Bean public ServerBootstrap serverBootstrap() { ServerBootstrap bootstrap = new ServerBootstrap(); EventLoopGroup bossGroup = new ...

    mina2核心框架

    文件可能涵盖了MINA2的高级主题,如性能调优、异常处理策略、自定义过滤器的实现以及与其他开源库的集成等。 总的来说,MINA2作为一个强大的网络通信框架,不仅提供了高效稳定的并发处理能力,还具备了高度灵活性和...

    mina 与spring的结合开发,包头指令

    标题中的"mina 与spring的结合开发,包头指令"可能是指在使用MINA构建网络服务时,如何利用Spring框架来管理和配置MINA的应用上下文,以及如何通过Spring的配置来定义和处理网络通信中的包头信息。 在MINA中,数据...

    spring+mina实现http接口服务端通信客户端

    3. **集成Mina**:引入Mina的相关依赖,然后在Spring配置中定义Mina的ServerBootstrap,包括Acceptor、ProtocolHandler以及相关的配置。Mina的IoHandler接口需要实现,用于处理接收到的网络事件。 4. **编写...

    基于spring的Mina框架

    Spring与Mina的整合** 在Spring中整合Mina,首先需要在Spring配置文件中声明Mina的相关bean,如Acceptor、ProtocolCodecFactory(编码解码工厂)和FilterChainBuilder(过滤器链构建器)。通过Spring的依赖注入,...

    Mina+Struts2+Spring4+Mybatis3组合

    该项目是本人真实项目中使用到的mina + spring+struts2 + mybatis框架,里面有详细的注释说明,以及一个完整的接收消息、入库、返回例子。对需要真实项目开发的人员来说,可以直接使用。 另外,如果需要更加详细的...

    mina 集成spring 传输文件和文本

    2. **Spring集成**:Spring框架提供了IoC(Inversion of Control)和AOP(Aspect Oriented Programming),可以方便地管理和配置Mina服务,以及处理服务间的依赖关系。 3. **文件传输**:在Mina中,文件传输通常...

    springboot 深度整合mina开箱即用

    在本文中,我们将深入探讨如何将Spring Boot与Mina进行深度整合,以便为新手开发者提供一个开箱即用的解决方案。Spring Boot以其简洁的配置和快速的开发体验,已经成为Java领域中的主流微服务框架,而Mina则是一个...

    springboot整合mina

    SpringBoot整合Mina是一个常见的Java开发任务,它涉及到SpringBoot框架与Apache Mina网络通信库的集成。Mina是一个轻量级、高性能的网络应用框架,主要用于构建服务器端的网络应用,如TCP/IP和UDP协议的服务。而...

    apache-mina-2.0.4.rar_apache mina_mina

    - **mina-integration-spring**模块:如果你的项目使用Spring框架,这个模块可以帮助你更好地集成Mina。 通过分析源码,你可以了解到Mina如何实现非阻塞I/O、如何调度任务、如何组织过滤器链,以及如何处理各种网络...

    mina函数.xls

    mina函数.xls

    Apache.Mina.Server.2.0.中文参考手册_李海峰

    #### 四、Mina 2.0 与 Mina 1.x 的区别 虽然Mina 1.x系列已经非常成熟和稳定,但2.0版本在设计上做出了较大的改进,以适应更高的性能要求和更复杂的业务场景。Mina 2.0引入了更多现代化的特性,例如: - 更加灵活的...

Global site tag (gtag.js) - Google Analytics