前言：
此时同学们对“apachesocketmina”大体比较重视，同学们都想要分析一些“apachesocketmina”的相关内容。那么小编同时在网摘上收集了一些对于“apachesocketmina””的相关知识，希望我们能喜欢，各位老铁们一起来学习一下吧！主要的包：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”，表示你连接成功了
然后你在命令行随便写个字符，然后回车。如果可以看到由服务器返回来的时间串就OK了。如果输入的是中文，服务器会收不到！这个问题还没仔细解决！还有就是你可以开多个命令行去连接！
版权声明：
本站文章均来自互联网搜集，如有侵犯您的权益，请联系我们删除，谢谢。
标签： #apachesocketmina
