apache MINA 高效通信框架

 mina-2.0.0-M5

slf4j-1.5.6

IDE:eclipse

在eclipse新建项目的时候在"Librarys",里加入

slf4j-api-1.5.6

slf4j-nop-1.5.6

log4j-over-slf4j-1.5.6

mina-core-2.0.0-M5

SamplMinaServerHandler.java

============================================

package com.javake.mina.sampleserver;

import org.apache.mina.core.service.*;

import org.apache.mina.core.session.*;

public class SamplMinaServerHandler extends IoHandlerAdapter{

public void sessionOpened(IoSession session) throws Exception {

System.out.println("incomming client : "+session.getRemoteAddress());

}

//当一个客户端关闭时

@Override

public void sessionClosed(IoSession session) {

System.out.println("one Clinet Disconnect !");

}

//当客户端发送的消息到达时:

@Override

public void messageReceived(IoSession session, Object message)

throws Exception {

//我们己设定了服务器解析消息的规则是一行一行读取,这里就可转为String:

String s=(String)message;

// Write the received data back to remote peer

System.out.println("收到客户机发来的消息: "+s);

//测试将消息回送给客户端

session.write(s+count);

count++;

}

private int count=0;

}

===============================================

MainServer.java

================================================

package com.javake.mina.sampleserver;

import java.net.InetSocketAddress;

import org.apache.mina.core.filterchain.*;

import org.apache.mina.filter.codec.ProtocolCodecFilter;

import org.apache.mina.filter.codec.textline.TextLineCodecFactory;

import org.apache.mina.transport.socket.SocketAcceptor;

import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

public class MainServer {

public static void main(String[] args) throws Exception {

//创建一个非阻塞的Server端Socket,用NIO

SocketAcceptor acceptor = new NioSocketAcceptor();

//创建接收数据的过滤器

DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();

//设定这个过滤器将一行一行(/r/n)的读取数据

chain.addLast("myChin", new ProtocolCodecFilter(new TextLineCodecFactory()));

//设定服务器端的消息处理器:一个SamplMinaServerHandler对象,

acceptor.setHandler(new SamplMinaServerHandler());

// 服务器端绑定的端口

int bindPort=9988;

//绑定端口,启动服务器

acceptor.bind(new InetSocketAddress(bindPort));

System.out.println("Mina Server is Listing on:= " + bindPort);

}

}

================================================