Mina框架HelloWorld入門

首先推薦幾篇Mina框架的好文章：

Mina框架研究（1）

Mina框架研究（2）

Mina框架研究（3）

 

環境准備：

1. 首先到官方網站下載最新的 MINA 版本，地址是：http://mina.apache.org。下載之前先介紹一下 MINA 的兩個版本：1.0.x 適合運行環境為 JDK1.4，1.1.x 適合 JDK1.5 的版本，兩者的編譯環境都需要 JDK1.5。JDK1.5 已經是非常普遍了，本文中使用 1.1.5 版本的 MINA，編譯和運行所需的文件是 mina-core-1.1.5.jar。
2. 下載 MINA 的依賴包 slf4j。MINA 使用此項目作為日志信息的輸出，而 MINA 本身並不附帶此項目包，請到http://www.slf4j.org/download.html 地址下載 slf4j 包，slf4j 項目解壓后有很多的文件，本例中只需要其中的 slf4j-api-1.4.3.jar 和 slf4j-simple-1.4.3.jar 這兩個 jar 文件。如果沒有這兩個文件就會導致啟動例子程序的時候報 org/slf4j/LoggerFactory 類沒找到的錯誤。
3. 當然要求機器上必須裝有 1.5 或者更新版本的 JDK。
4. 最好你應該選擇一個順手的 Java 開發環境例如 Eclipse 或者 NetBeans 之類的，可以更方便的編碼和調試，雖然我們的最低要求只是一個簡單的文本編輯器而已。

 

　　

Mina第一個HelloWorld程序:

服務端程序：

Minaserver.java: 

public class MinaServer {
    private IoAcceptor ioAcceptor;
    
    public MinaServer(int port)
    {
        ioAcceptor = new NioSocketAcceptor();
        try {
            //設置處理器
            ioAcceptor.setHandler(new MyHandler());
            //綁定端口
            ioAcceptor.bind(new InetSocketAddress(port));
            //規定協議，設定過濾，這里用TextLineCodecFactory文本協議
            ioAcceptor.getFilterChain().addLast("test", new ProtocolCodecFilter(new TextLineCodecFactory()));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 MyHandler.java:  (服務端接收消息后的業務邏輯處理)

public class MyHandler extends IoHandlerAdapter {
    /**接收到信息后進行邏輯處理*/
    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception {
        String getmessage = message.toString();
        System.out.println(getmessage);
    }
}

 

客戶端程序：

MinaClient.java:

public class MinaClient {
    private IoConnector ioConnector;
    
    public MinaClient(String host, int port)
    {
        ioConnector = new NioSocketConnector();
        //過濾信息，封裝成文本格式輸出
        ioConnector.getFilterChain().addLast("test", new ProtocolCodecFilter(new TextLineCodecFactory()));
        
        ioConnector.setHandler(new ClientHandler("Hello world!"));
        ioConnector.connect(new InetSocketAddress(host, port));
    }
}

ClientHandler.java:

public class ClientHandler extends IoHandlerAdapter {
    //發送給服務端的消息
    private String sendToServer;
    
    public ClientHandler(String words)
    {
        sendToServer = words;
    }
    
    @Override
    public void sessionOpened(IoSession session) throws Exception {
        session.write(sendToServer);
    }
}