apache mina + myeclipse

13916729435

　　【主要参考资料】
　　http://mina.apache.org/documentation.html
　　http://tianting-wx.javaeye.com/blog/265045
　　【主要过程】




　　说明：如果以上过程都顺利完成，有问题的话，关闭myeclipse,然后重新启动myeclipse.
　　[主要代码]
　　1。MainServer.java
　　package com.javake.mina.sampleserver;
　　import java.net.InetSocketAddress;
　　import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
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;
　　/**
* 简单Mina Server示例
* @author javaFound
*/
　　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);
　　}
　　}
　　2。SamplMinaServerHandler.java
　　package com.javake.mina.sampleserver;
　　import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
　　
　　/**
　　* 自定议的消息处理器,必须实现IoHandlerAdapter类
　　* @author javaFound
　　*/
　　public class SamplMinaServerHandler extends IoHandlerAdapter {
　　
　　//当一个客端端连结进入时
　　@Override
　　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;
　　}
　　
【测试方式】
　　1。运行程序
　　2。在cmd状态下，输入：telnet localhost 9988
　　3。然后回车。