当前位置:首页 > 开发 > 编程语言 > 网络编程 > 正文

Mina TCP服务端客户端 示例

发表于: 2013-06-24   作者:cuisuqiang   来源:转载   浏览次数:
摘要: 服务端代码: package com.xd.nms.example; import java.io.IOException; import java.net.InetSocketAddress; import org.apache.mina.core.buffer.IoBuffer; import org.apache.mina.core.service.IoHandlerAdapter

服务端代码:

package com.xd.nms.example;
import java.io.IOException;
import java.net.InetSocketAddress;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
import com.xd.nms.util.ByteAndStr16;
/**
 * @说明 Mina TCP 服务端
 * @author 崔素强
 * @version 1.0
 * @since
 */
public class MinaTcpServer extends IoHandlerAdapter {
	public static final int PORT = 18567;
	public MinaTcpServer() throws IOException {
		NioSocketAcceptor acceptor = new NioSocketAcceptor();
		acceptor.setHandler(this);
		acceptor.bind(new InetSocketAddress(PORT));
		System.out.println("TCP服务启动,端口:" + PORT);
	}
	public static void main(String[] args) throws IOException {
		new MinaTcpServer();
	}
	@Override
	public void messageReceived(IoSession session, Object message)
			throws Exception {
		IoBuffer bbuf = (IoBuffer) message;
		byte[] byten = new byte[bbuf.limit()];
		bbuf.get(byten, bbuf.position(), bbuf.limit());
		System.out.println("收到消息:" + ByteAndStr16.Bytes2HexString(byten));
		byte[] bts = new byte[10];
		for(int i=0;i<10;i++){
			bts[i] = (byte)i;
		}
		IoBuffer buffer = IoBuffer.allocate(10);
		buffer.put(bts);
		buffer.flip();
		session.write(buffer);
//		// 拿到所有的客户端Session
//		Collection<IoSession> sessions = session.getService().getManagedSessions().values();
//		// 向所有客户端发送数据
//		for (IoSession sess : sessions) {
//			sess.write(buffer);
//		}
	}
	@Override
	public void sessionClosed(IoSession session) throws Exception {
		System.out.println("会话关闭");
	}
	@Override
	public void exceptionCaught(IoSession session, Throwable cause)
			throws Exception {
		System.out.println("会话异常");
		super.exceptionCaught(session, cause);
	}
	@Override
	public void messageSent(IoSession iosession, Object obj) throws Exception {
		System.out.println("服务端消息发送");
		super.messageSent(iosession, obj);
	}
	@Override
	public void sessionCreated(IoSession iosession) throws Exception {
		System.out.println("会话创建");
		super.sessionCreated(iosession);
	}
	@Override
	public void sessionIdle(IoSession iosession, IdleStatus idlestatus)
			throws Exception {
		System.out.println("会话休眠");
		super.sessionIdle(iosession, idlestatus);
	}
	@Override
	public void sessionOpened(IoSession iosession) throws Exception {
		System.out.println("会话打开");
		super.sessionOpened(iosession);
	}
}

 

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

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

 

客户端程序:

package com.xd.nms.example;
import java.net.InetSocketAddress;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
import com.xd.nms.util.ByteAndStr16;
/**
 * @说明 Mina TCP客户端
 * @author 崔素强
 * @version 1.0
 * @since
 */
public class MinaTcpClient extends IoHandlerAdapter {
	private IoConnector connector;
	private static IoSession session;
	public MinaTcpClient() {
		connector = new NioSocketConnector();
		connector.setHandler(this);
		ConnectFuture connFuture = connector.connect(new InetSocketAddress("localhost", MinaTcpServer.PORT));
		connFuture.awaitUninterruptibly();
		session = connFuture.getSession();
		System.out.println("TCP 客户端启动");
	}
	public static void main(String[] args) throws Exception {
		MinaTcpClient client = new MinaTcpClient();
		for(int j=0;j<2;j++){ // 发送两遍
			byte[] bts = new byte[20];
			for (int i = 0; i < 20; i++) {
				bts[i] = (byte) i;
			}
			IoBuffer buffer = IoBuffer.allocate(20);
			// 自动扩容
			buffer.setAutoExpand(true);
			// 自动收缩
			buffer.setAutoShrink(true);
			buffer.put(bts);
			buffer.flip();
			session.write(buffer);
			Thread.sleep(2000);
		}
		// 关闭会话,待所有线程处理结束后
		client.connector.dispose(true);
	}
	@Override
	public void messageReceived(IoSession iosession, Object message)
			throws Exception {
		IoBuffer bbuf = (IoBuffer) message;
		byte[] byten = new byte[bbuf.limit()];
		bbuf.get(byten, bbuf.position(), bbuf.limit());
		System.out.println("客户端收到消息" + ByteAndStr16.Bytes2HexString(byten));
	}
	@Override
	public void exceptionCaught(IoSession session, Throwable cause)
			throws Exception {
		System.out.println("客户端异常");
		super.exceptionCaught(session, cause);
	}
	@Override
	public void messageSent(IoSession iosession, Object obj) throws Exception {
		System.out.println("客户端消息发送");
		super.messageSent(iosession, obj);
	}
	@Override
	public void sessionClosed(IoSession iosession) throws Exception {
		System.out.println("客户端会话关闭");
		super.sessionClosed(iosession);
	}
	@Override
	public void sessionCreated(IoSession iosession) throws Exception {
		System.out.println("客户端会话创建");
		super.sessionCreated(iosession);
	}
	@Override
	public void sessionIdle(IoSession iosession, IdleStatus idlestatus)
			throws Exception {
		System.out.println("客户端会话休眠");
		super.sessionIdle(iosession, idlestatus);
	}
	@Override
	public void sessionOpened(IoSession iosession) throws Exception {
		System.out.println("客户端会话打开");
		super.sessionOpened(iosession);
	}
}

 

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

 

打印结果:

TCP服务启动,端口:18567
会话创建
会话打开
收到消息:00 01 02 03 04 05 06 07 08 09 0A 0B 0C 0D 0E 0F 10 11 12 13 
服务端消息发送
收到消息:00 01 02 03 04 05 06 07 08 09 0A 0B 0C 0D 0E 0F 10 11 12 13 
服务端消息发送
会话关闭

 

 

客户端会话创建
客户端会话打开
TCP 客户端启动
客户端消息发送
客户端收到消息00 01 02 03 04 05 06 07 08 09 
客户端消息发送
客户端收到消息00 01 02 03 04 05 06 07 08 09 
客户端会话关闭

 

 请您到ITEYE网站看原创,谢谢!

http://cuisuqiang.iteye.com/ ! 

自建博客地址:http://www.javacui.com/ ,内容与ITEYE同步!

Mina TCP服务端客户端 示例

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
IoService(Inf) | |==AbstractIoService --IoAcceptor -----IoConnector | | | | | |-----------|==
Apache MINA(Multipurpose Infrastructure for Network Applications) 是 Apache 组织一个较新的项
和上篇的 客户端和服务端之间的通信(UDP)程序类似:http://www.cnblogs.com/Shang0109/archive/201
客户端代码: package com.zzl.tcp; import java.net.*; import java.io.*; public class TcpClient
最近项目中需要用到WebService向其他开发人员提供接口,之前对WebService只是简单了解,没有具体实
目录 说明 TCP/UDP通信主要结构 管理多个Socket的解决方案 框架中TCP部分的使用 框架中UDP部分的使
在这篇文章中主要讲解如下内容: 1.mina 简介 1.1 mina 分布图 1.2 mina 组件图 2.例子 2.1 服户端
使用MINA2开发服务端程序 关键字 :MINA,MINA2,网络应用,协议实现,框架,apache 适合级别:中级
通用数据访问层及Ajax服务端框架的综合示例,展示与下载 阅读目录 开始 第一部分,界面截图 调用数
网址大全 | EF CodeFirst | 电视 | MyNPOI | 开源 | 我的皮肤 | ASP.NET MVC4 | 前端提升 | LINQ |
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号