Apache的Mina（Multipurpose Infrastructure Networked Applications）是一個(gè)網(wǎng)絡(luò)應(yīng)用框架，可以幫助用戶開發(fā)高性能和高擴(kuò)展性的網(wǎng)絡(luò)應(yīng)用程序；它提供

了一個(gè)抽象的、事件驅(qū)動(dòng)的異步API，使Java NIO在各種傳輸協(xié)議（如TCP/IP，UDP/IP協(xié)議等）下快速高效開發(fā)。
簡(jiǎn)單實(shí)現(xiàn)：

client:

 // 創(chuàng)建客戶端連接器.
        NioSocketConnector connector = new NioSocketConnector();

        connector.getFilterChain().addLast("logger", new LoggingFilter());
        // 設(shè)置編碼過濾器
        connector.getFilterChain().addLast(
                "codec",
                new ProtocolCodecFilter(new TextLineCodecFactory(Charset
                        .forName("UTF-8"))));
        connector.setConnectTimeout(30);
        // 設(shè)置事件處理器
        connector.setHandler(new ClientHandler());
        // 建立連接
        ConnectFuture cf = connector.connect(new InetSocketAddress("127.0.0.1",
                9100));
        // 等待連接創(chuàng)建完成
        cf.awaitUninterruptibly();
        // 發(fā)送消息
        cf.getSession().write("hello");
     
        // 等待連接斷開
        cf.getSession().getCloseFuture().awaitUninterruptibly();

        connector.dispose();

server端：

IoAcceptor acceptor = new NioSocketAcceptor();

 acceptor.getFilterChain().addLast("logger", new LoggingFilter());
// 指定編碼過濾器
acceptor.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"))));
// 指定業(yè)務(wù)邏輯處理器
acceptor.setHandler(new ServerHandler());
// 設(shè)置端口號(hào)
acceptor.setDefaultLocalAddress(new InetSocketAddress(9100));
// 啟動(dòng)監(jiān)聽
acceptor.bind();

server 處理器
class ServerHandler extends IoHandlerAdapter
{

    @Override
    public void sessionCreated(IoSession session)
    {
        // 顯示客戶端的ip和端口
        System.out
                .println(session.getRemoteAddress().toString() + "   service");
    }

    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception
    {
        String str = message.toString();

        if (str.trim().equalsIgnoreCase("hello"))
        {
            // System.out.println(str + "  client sent : hello");
            // 結(jié)束會(huì)話
            session.close();
            return;
        }

        Date date = new Date();
        // 返回當(dāng)前時(shí)間的字符串
        session.write(date.toString());
    }


}

標(biāo)簽： isp 網(wǎng)絡(luò)

版權(quán)申明：本站文章部分自網(wǎng)絡(luò)，如有侵權(quán)，請(qǐng)聯(lián)系：west999com@outlook.com
特別注意：本站所有轉(zhuǎn)載文章言論不代表本站觀點(diǎn)！
本站所提供的圖片等素材，版權(quán)歸原作者所有，如需使用，請(qǐng)與原作者聯(lián)系。