一个基于MINA框架应用的最简单例子

你的名字 2022-04-22 13:48 236阅读 0赞

直接上代码。关于原理和主要的API以后在说。先能跑通了在说。

主要的包：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项目包里有。最后一个到官网上下吧。![icon_wink.gif][]

服务器类：

import java.io.IOException;
    import java.net.InetSocketAddress;
    
    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;
    
    public class MinaServer {
    	private static final int PORT = 22222;
    	public static void main(String[] args) {
    		//创建一个非阻塞的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));
    		try {
    			acceptor.bind();
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		System.out.println("Mina Server is Listen on:" + PORT);
    	}
    }

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

import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import org.apache.mina.core.service.IoHandlerAdapter;
    import org.apache.mina.core.session.IoSession;
    
    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了。

(备注：有的系统可能不支持telnet，可以通过远程测试)

[icon_wink.gif]: /images/20220422/f48fa1f6d57f4beea944e4efc53901b0.png