java整合Apache-mima进行socket通信

项目中遇到一个需求，需要安卓多客户端连接java后台进行相互通信，保持长连接，所以想到用socket来做，在网上看了一堆资料后，发现了mina框架，下面把自己整合的代码记录一下。

jar包自己在网上找，这里就不贴了

1、首先创建一个线程类，创建服务端的socket并且绑定指定的端口

public class SocketTest implements Runnable{//日志类的实现private static Logger logger = Logger.getLogger(SocketTest.class+"");//端口号，要求客户端与服务器端一致private static int PORT = 9088;@Overridepublic void run() {IoAcceptor acceptor = null;try{//创建一个非阻塞的server端的Socketacceptor = new NioSocketAcceptor();//设置过滤器（使用mina提供的文本换行符编解码器）(在bind前进行)acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(),LineDelimiter.WINDOWS.getValue())));//自定义的编解码器//acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new CharsetCodecFactory()));//设置读取数据的换从区大小acceptor.getSessionConfig().setReadBufferSize(2048);//读写通道10秒内无操作进入空闲状态acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);//为接收器设置管理服务acceptor.setHandler(new SocketHandlerTest());//绑定端口acceptor.bind(new InetSocketAddress(PORT));logger.info("服务器启动成功...    端口号未："+PORT);}catch(Exception e){logger.info("服务器启动异常..."+e.getMessage().toString());e.printStackTrace();}}}

2、然后创建监听器，在项目启动的同时启动socket服务，等待客户端连接

public class InitListener implements ApplicationListener<ContextRefreshedEvent>{//日志类的实现private static Logger logger = Logger.getLogger(InitListener.class+"");@Overridepublic void onApplicationEvent(ContextRefreshedEvent arg0) {logger.info("执行监听器...");new Thread(new SocketTest()).start(); }}

3、最后编写处理类继承IoHandlerAdapter对socket进行管理

public class SocketHandlerTest extends IoHandlerAdapter{public static Logger logger = Logger.getLogger(SocketHandlerTest.class + "");// 从端口接受消息，会响应此方法来对消息进行处理@Overridepublic void messageReceived(IoSession session, Object message) throws Exception {String msg = message.toString();    System.out.println(msg);String m = (String) session.getAttribute("clientIP");logger.info(m);/*   //展现解析json得到的值StringBuffer buf = new StringBuffer();       try {//解析传递的jsonObjectMapper mapper = new ObjectMapper();JsonNode rootNode = mapper.readTree(msg);} catch (Exception e) {// TODO: handle exception}*/if ("exit".equals(msg)) {// 如果客户端发来exit，则关闭该连接session.close(true);}// 向客户端发送消息Date date = new Date();session.write(date);logger.info("服务器接受消息成功..." + msg);super.messageReceived(session, message);}// 向客服端发送消息后会调用此方法@Overridepublic void messageSent(IoSession session, Object message) throws Exception {logger.info("服务器发送消息成功...");super.messageSent(session, message);}// 关闭与客户端的连接时会调用此方法@Overridepublic void sessionClosed(IoSession session) throws Exception {logger.info("服务器与客户端断开连接...");super.sessionClosed(session);}// 服务器与客户端创建连接@Overridepublic void sessionCreated(IoSession session) throws Exception {logger.info("服务器与客户端创建连接...");IoSessionTest.session=session;String clientIP =  ((InetSocketAddress)session.getRemoteAddress()).getAddress().getHostAddress();session.setAttribute("clientIP", clientIP);logger.info(clientIP);super.sessionCreated(session);}// 服务器与客户端连接打开@Overridepublic void sessionOpened(IoSession session) throws Exception {logger.info("服务器与客户端连接打开...");super.sessionOpened(session);}@Overridepublic void sessionIdle(IoSession session, IdleStatus status) throws Exception {logger.info("服务器进入空闲状态...");super.sessionIdle(session, status);}@Overridepublic void exceptionCaught(IoSession session, Throwable cause) throws Exception {logger.info("服务器发送异常...");super.exceptionCaught(session, cause);}}

这样服务端也可以主动发消息给客户端，对MINA包下的IoSession进行操作，可以实现多客户端连接且保持长连接的需求

java整合Apache-mima进行socket通信相关推荐

Springboot整合Netty，实现Socket通信
文章目录 *Springboot整合Netty,实现Socket通信* 1.模拟单客户端 2.模拟单服务端总结 Springboot整合Netty,实现Socket通信 1.模拟单客户端引入Net ...
java面试题44关于 Socket 通信编程，以下描述正确的是：（）
java面试题44关于 Socket 通信编程,以下描述正确的是:( ) A 客户端通过new ServerSocket()创建TCP连接对象 B 客户端通过TCP连接对象调用accept()方法创建 ...
java与C语言之间socket通信（java客户端 C服务端）
直接贴代码服务端C代码 server.c #include <stdio.h> #include <sys/types.h> #include <sys/socket. ...
java与c/c++进行socket通信的一些问题
c/c++和java通信的问题比较多,特别是c特有的数据结构(如struct). 特地根据网友的一个问题举个例子,希望对初学者有所帮助. 这类问题通常是为了利用原有Server或者Server不能做修 ...
java事件 socket_java中有关socket通信的学习笔记
最近做的项目中使用到了一些基于java的socket长连接的一些功能,用来穿透有关行业的网闸.用到了也就学习了一下,下面是对学习内容的一个笔记,记录一下也希望有兴趣的同学可以参考一下,加深对javas ...
java客户端服务器代码_Java Socket通信客户端服务器端基本代码
[服务器端] import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import ...
java与c/c++进行socket通信的一些问题(2)
import java.net.*; import java.io.*; /** * 与C语言通信(java做Client,c/c++做Server,传送一个结构) * @author kingfis ...
java与c 通信_Java与C之间的socket通信
最近正在开发一个基于指纹的音乐检索应用,算法部分已经完成,所以尝试做一个Android App.Android与服务器通信通常采用HTTP通信方式和Socket通信方式.由于对web服务器编程了解较少 ...
java socket建立长连接_Java Web项目中使用Socket通信多线程、长连接的方法
很多时候在javaweb项目中我们需要用到Socket通信来实现功能,在web中使用Socket我们需要建立一个监听程序,在程序启动时,启动socket监听.我们的应用场景是在java项目中,需要外接 ...
Java Socket实战之六使用NIO包实现Socket通信
2019独角兽企业重金招聘Python工程师标准>>> 本文地址:http://blog.csdn.net/kongxx/article/details/7288896 Java S ...

java整合Apache-mima进行socket通信

java整合Apache-mima进行socket通信相关推荐

最新文章

热门文章