码迷，mamicode.com
首页 > 其他好文 > 详细

Mina TCP服务端客户端 示例

时间：2018-03-19 13:25:45      阅读：196      评论：0      收藏：0      [点我收藏+]

标签：org   tac   ssi   png   position   cps   示例   mes   close   

服务端代码：

Java代码  技术分享图片
  1. package com.xd.nms.example;  
  2. import java.io.IOException;  
  3. import java.net.InetSocketAddress;  
  4. import org.apache.mina.core.buffer.IoBuffer;  
  5. import org.apache.mina.core.service.IoHandlerAdapter;  
  6. import org.apache.mina.core.session.IdleStatus;  
  7. import org.apache.mina.core.session.IoSession;  
  8. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;  
  9. import com.xd.nms.util.ByteAndStr16;  
  10. /** 
  11.  * @说明 Mina TCP 服务端 
  12.  * @author 崔素强 
  13.  * @version 1.0 
  14.  * @since 
  15.  */  
  16. public class MinaTcpServer extends IoHandlerAdapter {  
  17.     public static final int PORT = 18567;  
  18.     public MinaTcpServer() throws IOException {  
  19.         NioSocketAcceptor acceptor = new NioSocketAcceptor();  
  20.         acceptor.setHandler(this);  
  21.         acceptor.bind(new InetSocketAddress(PORT));  
  22.         System.out.println("TCP服务启动，端口：" + PORT);  
  23.     }  
  24.     public static void main(String[] args) throws IOException {  
  25.         new MinaTcpServer();  
  26.     }  
  27.     @Override  
  28.     public void messageReceived(IoSession session, Object message)  
  29.             throws Exception {  
  30.         IoBuffer bbuf = (IoBuffer) message;  
  31.         byte[] byten = new byte[bbuf.limit()];  
  32.         bbuf.get(byten, bbuf.position(), bbuf.limit());  
  33.         System.out.println("收到消息：" + ByteAndStr16.Bytes2HexString(byten));  
  34.         byte[] bts = new byte[10];  
  35.         for(int i=0;i<10;i++){  
  36.             bts[i] = (byte)i;  
  37.         }  
  38.         IoBuffer buffer = IoBuffer.allocate(10);  
  39.         buffer.put(bts);  
  40.         buffer.flip();  
  41.         session.write(buffer);  
  42. //      // 拿到所有的客户端Session  
  43. //      Collection<IoSession> sessions = session.getService().getManagedSessions().values();  
  44. //      // 向所有客户端发送数据  
  45. //      for (IoSession sess : sessions) {  
  46. //          sess.write(buffer);  
  47. //      }  
  48.     }  
  49.     @Override  
  50.     public void sessionClosed(IoSession session) throws Exception {  
  51.         System.out.println("会话关闭");  
  52.     }  
  53.     @Override  
  54.     public void exceptionCaught(IoSession session, Throwable cause)  
  55.             throws Exception {  
  56.         System.out.println("会话异常");  
  57.         super.exceptionCaught(session, cause);  
  58.     }  
  59.     @Override  
  60.     public void messageSent(IoSession iosession, Object obj) throws Exception {  
  61.         System.out.println("服务端消息发送");  
  62.         super.messageSent(iosession, obj);  
  63.     }  
  64.     @Override  
  65.     public void sessionCreated(IoSession iosession) throws Exception {  
  66.         System.out.println("会话创建");  
  67.         super.sessionCreated(iosession);  
  68.     }  
  69.     @Override  
  70.     public void sessionIdle(IoSession iosession, IdleStatus idlestatus)  
  71.             throws Exception {  
  72.         System.out.println("会话休眠");  
  73.         super.sessionIdle(iosession, idlestatus);  
  74.     }  
  75.     @Override  
  76.     public void sessionOpened(IoSession iosession) throws Exception {  
  77.         System.out.println("会话打开");  
  78.         super.sessionOpened(iosession);  
  79.     }  
  80. }  

 

 服务端建立端口监听后，收到消息后进入messageReceived()方法，示例处理是打印该消息，然后组装了一个0-9的数据返回回去

注意，即使使用的是Mina，仍需做分包、粘包，等处理，例如有时一条数据不是一次发过来的

 

客户端程序：

Java代码  技术分享图片
  1. package com.xd.nms.example;  
  2. import java.net.InetSocketAddress;  
  3. import org.apache.mina.core.buffer.IoBuffer;  
  4. import org.apache.mina.core.future.ConnectFuture;  
  5. import org.apache.mina.core.service.IoConnector;  
  6. import org.apache.mina.core.service.IoHandlerAdapter;  
  7. import org.apache.mina.core.session.IdleStatus;  
  8. import org.apache.mina.core.session.IoSession;  
  9. import org.apache.mina.transport.socket.nio.NioSocketConnector;  
  10. import com.xd.nms.util.ByteAndStr16;  
  11. /** 
  12.  * @说明 Mina TCP客户端 
  13.  * @author 崔素强 
  14.  * @version 1.0 
  15.  * @since 
  16.  */  
  17. public class MinaTcpClient extends IoHandlerAdapter {  
  18.     private IoConnector connector;  
  19.     private static IoSession session;  
  20.     public MinaTcpClient() {  
  21.         connector = new NioSocketConnector();  
  22.         connector.setHandler(this);  
  23.         ConnectFuture connFuture = connector.connect(new InetSocketAddress("localhost", MinaTcpServer.PORT));  
  24.         connFuture.awaitUninterruptibly();  
  25.         session = connFuture.getSession();  
  26.         System.out.println("TCP 客户端启动");  
  27.     }  
  28.     public static void main(String[] args) throws Exception {  
  29.         MinaTcpClient client = new MinaTcpClient();  
  30.         for(int j=0;j<2;j++){ // 发送两遍  
  31.             byte[] bts = new byte[20];  
  32.             for (int i = 0; i < 20; i++) {  
  33.                 bts[i] = (byte) i;  
  34.             }  
  35.             IoBuffer buffer = IoBuffer.allocate(20);  
  36.             // 自动扩容  
  37.             buffer.setAutoExpand(true);  
  38.             // 自动收缩  
  39.             buffer.setAutoShrink(true);  
  40.             buffer.put(bts);  
  41.             buffer.flip();  
  42.             session.write(buffer);  
  43.             Thread.sleep(2000);  
  44.         }  
  45.         // 关闭会话，待所有线程处理结束后  
  46.         client.connector.dispose(true);  
  47.     }  
  48.     @Override  
  49.     public void messageReceived(IoSession iosession, Object message)  
  50.             throws Exception {  
  51.         IoBuffer bbuf = (IoBuffer) message;  
  52.         byte[] byten = new byte[bbuf.limit()];  
  53.         bbuf.get(byten, bbuf.position(), bbuf.limit());  
  54.         System.out.println("客户端收到消息" + ByteAndStr16.Bytes2HexString(byten));  
  55.     }  
  56.     @Override  
  57.     public void exceptionCaught(IoSession session, Throwable cause)  
  58.             throws Exception {  
  59.         System.out.println("客户端异常");  
  60.         super.exceptionCaught(session, cause);  
  61.     }  
  62.     @Override  
  63.     public void messageSent(IoSession iosession, Object obj) throws Exception {  
  64.         System.out.println("客户端消息发送");  
  65.         super.messageSent(iosession, obj);  
  66.     }  
  67.     @Override  
  68.     public void sessionClosed(IoSession iosession) throws Exception {  
  69.         System.out.println("客户端会话关闭");  
  70.         super.sessionClosed(iosession);  
  71.     }  
  72.     @Override  
  73.     public void sessionCreated(IoSession iosession) throws Exception {  
  74.         System.out.println("客户端会话创建");  
  75.         super.sessionCreated(iosession);  
  76.     }  
  77.     @Override  
  78.     public void sessionIdle(IoSession iosession, IdleStatus idlestatus)  
  79.             throws Exception {  
  80.         System.out.println("客户端会话休眠");  
  81.         super.sessionIdle(iosession, idlestatus);  
  82.     }  
  83.     @Override  
  84.     public void sessionOpened(IoSession iosession) throws Exception {  
  85.         System.out.println("客户端会话打开");  
  86.         super.sessionOpened(iosession);  
  87.     }  
  88. }  

 

 向服务端发送两次0-19的数据，收到消息后同样进入messageReceived()方法，处理同样是打印显示！

 

打印结果：

Java代码  技术分享图片
  1. TCP服务启动，端口：18567  
  2. 会话创建  
  3. 会话打开  
  4. 收到消息：00 01 02 03 04 05 06 07 08 09 0A 0B 0C 0D 0E 0F 10 11 12 13   
  5. 服务端消息发送  
  6. 收到消息：00 01 02 03 04 05 06 07 08 09 0A 0B 0C 0D 0E 0F 10 11 12 13   
  7. 服务端消息发送  
  8. 会话关闭  

 

 

Java代码  技术分享图片
  1. 客户端会话创建  
  2. 客户端会话打开  
  3. TCP 客户端启动  
  4. 客户端消息发送  
  5. 客户端收到消息00 01 02 03 04 05 06 07 08 09   
  6. 客户端消息发送  
  7. 客户端收到消息00 01 02 03 04 05 06 07 08 09   
  8. 客户端会话关闭  

Mina TCP服务端客户端 示例

标签：org   tac   ssi   png   position   cps   示例   mes   close   

原文地址：https://www.cnblogs.com/wudage/p/8601007.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！