apache mina + myeclipse
【主要参考资料】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。然后回车。
页:
[1]