apache mina2.0 (apache妗嗘灦璁剧疆)

主要的包:mina-core-2.0.0.jar【到官网上*载下**完整项目包里面还有文档和依赖包】,jcl-over-slf4j-1.5.11.jar,slf4j-api-1.5.11.jar,slf4j-nop-1.5.11.jar这三个是mina使用的日志包。前面二个mina项目包里有。最后一个到官网上下吧,或者加群找我要!

mina服务类:

package com.mina;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

import java.io.IOException;
import java.net.InetSocketAddress;

public class MinaServer {
 private static final int PORT = 22222;// 定义监听端口
 public static void main(String[] args) throws IOException {
 //创建一个非阻塞的Server端socket,用NIO
 IoAcceptor acceptor = new NioSocketAcceptor();
 //创建接受数据的过滤器
 DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
 //设定这个过滤器将一行一行的读取数据
 chain.addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory()));// 指定编码过滤器
 // 指定业务逻辑处理器
 acceptor.setHandler(new Handler());
 // 设置端口号
 acceptor.setDefaultLocalAddress(new InetSocketAddress(PORT));
 acceptor.bind(); //启动监听
 System.out.println("Mina Server is Listen on:"+PORT);
 }
}

处理类。用来处理请求连接的。

package com.mina;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

import java.text.SimpleDateFormat;
import java.util.Date;

public class Handler extends IoHandlerAdapter {

 //当一个客户端连接进入时
 @Override
 public void sessionOpened(IoSession session)throws Exception {
 System.out.println("incoming client:"+session.getRemoteAddress());
 }
 //当客户端发送消息到达时
 @Override
 public void messageReceived(IoSession session, Object message)throws Exception {
 String s = message.toString();
 System.out.println("client send message is:"+s);
 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd mm:hh:ss");
 Date date = new Date();
 session.write(sdf.format(date));// 返回当前时间的字符串
 System.out.println("message written...");
 }
 //当一个客户端连接关闭时
 @Override
 public void sessionClosed(IoSession session)throws Exception {
 System.out.println("one client closed");
 }
}

完事了,

运行MinaServer就行了。

然后测试下。在命令行运行“telnet 127.0.0.1 22222”,当服务器端出现“incoming client:/127.0.0.1:2333”,表示你连接成功了

apachemina涓枃,apache鏁欏

然后你在命令行随便写个字符,然后回车。如果可以看到由服务器返回来的时间串就OK了。如果输入的是中文,服务器会收不到!这个问题还没仔细解决!还有就是你可以开多个命令行去连接!