Apache Mina簡單執行個體

[b]一.简介[/b]

MINA是一个网络应用框架，也可被称之为NIO框架库、客户端/服务器框架库、网络套接字 (socket)库，可以帮助用户开发高性能和高可扩展性的网络应用程序，支持(TCP/IP、UDP/IP协议)等。

[b]二.工作流程[/b]

MINA处于中间层，它不关心数据是如何在底层网络进行传输，只负责接受底层数据，将数据通过过滤器过滤并装换成JAVA对象，供应用程序使用，然后在应用程序对数据做过业务处理之后，将响应值过滤且转换成底层能识别的二进制数据，提供给底层传输。总之，MINA是底层数据和应用程序交互的接口。

[color=red]第一步，创建服务对象(服务端、客户端) ----IoService接口实现

第二步，数据过滤(编解码器) ----IoFilter接口实现

第三步，业务处理 ----IoHandler接口实现[/color]

IoFilter是MINA的精髓，可以进行日志记录，信息过滤，编解码等操作，把数据接收发送从业务层独立出来。

IoService对NIO进行了封装，提供简介接口，来创建服务对象。

IoHandler是我们最关心的部分，负责对接收/发送数据做了业务逻辑处理

[b]三.服务端实例[/b]

private static Logger logger = Logger.getLogger(Demo1Server.class);
	private static final int PORT = 3005;

	public static void main(String[] args) {
		IoAcceptor acceptor = new NioSocketAcceptor();
		acceptor.addListener(new ServerListener());
		acceptor.getFilterChain().addLast(
				"codec",
				new ProtocolCodecFilter(new MyTextLineCodecFactory()));
		// 设置读取数据的缓冲区大小
		acceptor.getSessionConfig().setReadBufferSize(2048);
		// 读写通道10秒内无操作进入空闲状态
		acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
		// 绑定逻辑处理起器
		acceptor.setHandler(new Demo1ServerHandler());
		// 绑定端口
		try {
			acceptor.bind(new InetSocketAddress(PORT));
			logger.info("服务器启动成功。。。。端口为：" + PORT);
		} catch (IOException e) {
			logger.error("服务器启动异常。。。。", e);
			e.printStackTrace();
		}
	}
           

[b]四.客户端实例[/b]

private Logger logger = Logger.getLogger(Demo2Client.class);
	private static final String HOST = "127.0.0.1";
	private static final int PORT = 3005;

	public static void main(String[] args) {
		// 创建一个非阻塞的客户端程序
		IoConnector connector = new NioSocketConnector();
		// 设置连接超时时间 单位毫秒
		connector.setConnectTimeout(30000);
		// 添加过滤器
		connector.getFilterChain().addLast(
				"codec",
				new ProtocolCodecFilter(new MyTextLineCodecFactory()));
		// 添加业务逻辑处理类
		connector.setHandler(new Demo2ClientHandler());
		// 创建连接
		IoSession session = null;
		try {
			ConnectFuture connect = connector.connect(new InetSocketAddress(
					HOST, PORT));
			// 等待连接创建完成
			connect.awaitUninterruptibly();
			// 获取session
			session = connect.getSession();
			session.write("我爱你，mina！！！！");
		} catch (Exception e) {
			System.out.println("客户端连接异常");
		}
		session.getCloseFuture().awaitUninterruptibly();
		connector.dispose();
	}
           

[b]五.编解码器实例[/b]

[color=darkblue]5.1 编码器[/color]

private Logger logger = Logger.getLogger(MyTextLineCodecEncoder.class);
	//字符编码类型
	private Charset charset = Charset.forName("UTF-8");
	@Override
	public void dispose(IoSession arg0) throws Exception {

	}

	@Override
	public void encode(IoSession arg0, Object obj, ProtocolEncoderOutput out)
			throws Exception {
		logger.info("开始编码...........");
		IoBuffer io = IoBuffer.allocate(100).setAutoExpand(true);
		CharsetEncoder ce = charset.newEncoder();
		io.putString(obj.toString(), ce);
		io.put((byte)'\r');
		io.put((byte)'\n');
		io.flip();
		out.write(io);
	}
           

[color=darkblue]5.2 解码器[/color]

private Logger logger = Logger.getLogger(MyTextLineCodecDecoder.class);
	//字符编码类型
	private Charset charset = Charset.forName("UTF-8");
	//设置数据存放的IoBuffer大小
	private IoBuffer ioBuffer = IoBuffer.allocate(1024).setAutoExpand(true);
	@Override
	public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out)
			throws Exception {
		logger.info("开始解码...........");
		while(in.hasRemaining()){
			byte by = in.get();
			//将数据存放到IoBuffer中
			ioBuffer.put(by);
			//数据解码结束标记
			if(by == '\n'){
				ioBuffer.flip();
				byte[] b = new byte[ioBuffer.limit()];
				ioBuffer.get(b);
				String msg = new String(b,charset);
				//重置ioBuffer
				ioBuffer = IoBuffer.allocate(100).setAutoExpand(true);
				out.write(msg);
			}
		}
	}