Apache MINA和Spring MVC集成.docx

Apache MINA和Spring MVC集成1. 创建项目创建一个Spring MVC的WEB应用项目，导入Spring MVC相关的jar包。另外还需要导入支持Spring面向切面编程的几个包，如下：aopalliance.jaraspectjweaver-1.6.12.jarognl-3.0.6.jar两个日志相关的包，如下：slf4j-api-1.6.6.jarslf4j-jdk14-1.6.6.jar另外导入MINA的包，如下：mina-core-2.0.7.jarmina-integration-beans-2.0.7.jar2. 配置1) 配置web.xml其实就是Spring MVC的相关配置。 Spring MVC的配置SpringMVCorg.springframework.web.servlet.DispatcherServletcontextConfigLocationclasspath:applicationContext.xml,classpath:spring-servlet.xml1SpringMVC*.htm index.jsp 2) 配置spring-servlet.xml也是很普通宾配置项。3) 配置applicationContext.xml这里只保留了MINA需要的几个bean的配置。上面标蓝色底的那段，是配置的自已开发的MINA处理客户端请求的服务器端程序。下面标蓝色底的配置指明，本服务器端程序起动后的服务器端的端口是1235。3. 程序实现1) 服务器端程序MinaProtocolHandler.javapackage com.memo.frame.mina;import org.apache.mina.core.service.IoHandlerAdapter;import org.apache.mina.core.session.IdleStatus;import org.apache.mina.core.session.IoSession;import org.slf4j.Logger;import org.slf4j.LoggerFactory;public class MinaProtocolHandler extends IoHandlerAdapter private final Logger logger = LoggerFactory.getLogger(getClass();/private final Set sessions = Collections.synchronizedSet(new HashSet();public void messageReceived(IoSession session, Object message) String msg = (String) message;System.out.println(Server Received: + msg);session.write(Server Send: + msg);/sessions.add(session);public void sessionIdle(IoSession session, IdleStatus status) /disconnect an idle clientsession.close();/ public void sessionClosed(IoSession session) throws Exception / sessions.remove(session);/ public void exceptionCaught(IoSession session, Throwable cause) logger.warn(Unexpected exception., cause);session.close();2) 客户端程序下面是二个测试用的客户端程序：1、 MinaClientHandler.java这个Client端设置的handler程序，是用于接收服务端回复过来的信息用的。package com.memo.frame.mina;import org.apache.mina.core.filterchain.IoFilter;import org.apache.mina.core.service.IoHandlerAdapter;import org.apache.mina.core.session.IoSession;import org.apache.mina.filter.codec.ProtocolCodecFilter;import org.apache.mina.filter.codec.textline.TextLineCodecFactory;import org.apache.mina.filter.logging.LoggingFilter;public class MinaClientHandler extends IoHandlerAdapter private static final IoFilter LOGGING_FILTER = new LoggingFilter();private static final IoFilter CODEC_FILTER = new ProtocolCodecFilter(new TextLineCodecFactory();Overridepublic void sessionCreated(IoSession session) throws Exception session.getFilterChain().addLast(codec, CODEC_FILTER);session.getFilterChain().addLast(logger, LOGGING_FILTER);Overridepublic void messageReceived(IoSession session, Object message)throws Exception String msg = (String) message;System.out.println(Client Received: + msg);2、MinaClientSupport.java这个客户端的主应用程序，负责发送客户端的请求到服务器端。package com.memo.frame.mina;import .InetSocketAddress;import .SocketAddress;import org.apache.mina.core.future.ConnectFuture;import org.apache.mina.core.service.IoHandler;import org.apache.mina.core.session.IoSession;import org.apache.mina.filter.logging.MdcInjectionFilter;import org.apache.mina.transport.socket.nio.NioSocketConnector;public class MinaClientSupport private IoHandler handler = null;private IoSession session;private String host;private int port;public boolean send(Object message) if (session != null & session.isConnected() throw new IllegalStateException(Already connected. Disconnect first.);SocketAddress address = new InetSocketAddress(host, port);NioSocketConnector connector = new NioSocketConnector();try connector.getFilterChain().addLast(mdc, new MdcInjectionFilter();connector.setHandler(handler);ConnectFuture future1 = connector.connect(address);future1.awaitUninterruptibly();if (!future1.isConnected() return false;session = future1.getSession();session.write(message);return true; catch (Exception e) return false;public void close() if (session != null) if (session.isConnected() / Wait until the chat ends.session.getCloseFuture().awaitUninterruptibly();session.close();public String getHost() return host;public void setHost(String host) this.host = host;public int getPort() return port;public void setPort(int port) this.port = port;public void setHandler(IoHandler handler) this.handler = handler;public static void main(String args) System.out.println(-);MinaClientSupport client = new MinaClientSupport();