netty-socketio是一個開源的Socket.io伺服器端的一個java的實現， 它基於Netty框架。可應用於服務端主動推送訊息到客戶端等場景，比如說股票價格變化、k線圖的走勢，和websocket是一個作用，只不過socketio可支援所有的瀏覽器。 專案地址為： https://github.com/mrniko/netty-socketio。

Socket.IO除了支援WebSocket通訊協議外，還支援許多種輪詢（Polling）機制以及其它實時通訊方式，並封裝成了通用的介面，並且在服務端實現了這些實時機制的相應程式碼。Socket.IO實現的Polling通訊機制包括Adobe Flash Socket、AJAX長輪詢、AJAX multipart streaming、持久Iframe、JSONP輪詢等。Socket.IO能夠根據瀏覽器對通訊機制的支援情況自動地選擇最佳的方式來實現網路實時應用。

一、下載Netty-SocketIO

1. socket.io-client-master
2. netty-socketio-master
3. netty-socketio-demo-master

從netty-socketio的git上可下載到以上三個壓縮包，分別對應的是web 客戶端的所需檔案、netty socketio的java服務端實現、以及對應的可以應用web推送的demo。

二、部署server的資源專案

從git上下載的socketio server壓縮包中沒有專案所需的jar包，我是自己新建了一個專案，本來上傳到了CSDN的程式碼庫裡了，但寫部落格的時候怎麼也打不開了，那麼只能提供對應專案導航圖，同時提供jar包的下載地址，需要的可動手去獲得。

然後將jar包新增到專案中。 
切記jdk的版本一定要在1.7以上，我在本地環境中用的1.7，但是伺服器上一直用的是1.6，部署專案的時候沒有注意，導致服務端可以接收到客戶端的socketio 的connect，但是客戶端的response相應中卻連線不通，開始的時候以為是跨域問題導致的，搜了好多帖子，但問題根本就是不是跨域引起的，jdk的版本換成1.7就ok了，因為netty的nio是基於java的1.7的。

三、應用server

在需要應用socketio的專案上右鍵，為專案新增socketio專案支援（注意紅色標出的）。 

新建main類。

public static void
 
 main(String[] args) throws InterruptedException {

    Configuration config = new Configuration();
    config.setHostname("localhost");
    config.setPort(10015);
    SocketIOServer server = new SocketIOServer(config);
    server.addConnectListener(new ConnectListener() {// 新增客戶端連線監聽器
        @Override
        public void onConnect(SocketIOClient client) {
            logger.info(client.getRemoteAddress() + " web客戶端接入");
            client.sendEvent("helloPush", "hello");
        }
    });
                    // 握手請求
    server.addEventListener("helloevent", HelloUid.class, new DataListener<HelloUid>() {
        @Override
        public void onData(final SocketIOClient client, HelloUid data, AckRequest ackRequest) {
            // 握手
            if (data.getMessage().equals("hello")) {
                int userid = data.getUid();
                logger.info(Thread.currentThread().getName() + "web讀取到的userid：" + userid);


                // send message back to client with ack callback
                // WITH data
                client.sendEvent("hellopush", new AckCallback<String>(String.class) {
                    @Override
                    public void onSuccess(String result) {
                        logger.info("ack from client: " + client.getSessionId() + " data: " + result);
                    }
                }, sessionTime);

            } else {
                logger.info("行情接收到了不應該有的web客戶端請求1111...");
            }
        }
    });

        server.start();

        Thread.sleep(Integer.MAX_VALUE);

        server.stop();
    }

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44

當client通過ip和埠連線到server後，會構造一個SocketIOClient client的物件，在實際的應用中，可以將該client儲存起來，通過client.sendEvent("helloPush", "hello");就可以向client端傳送相應的資料了。

四、應用client

①、引入socket.io.js

<script type="text/javascript" src="${ctx}/components/socketio/socket.io.js"></script>

• 1

②、建立connection的公共方法

function connectQuotation(uid, callback) {
    // 連結行情server
    socket = io.connect('http://localhost:10015');

    // 如果使用者在web端登陸，那麼傳送握手請求
    if (uid) {
        // 連線上server後
        socket.on('connect', function() {
            // 傳送握手請求
            var jsonObject = {
                uid : parseInt(uid),
                message : "hello"
            };
            this.emit('helloevent', jsonObject);

            this.on('hellopush', function(data, ackServerCallback, arg1) {
                // base64轉碼的資料，可忽視
                YUNM.session = {
                    sessionId : $.base64.atob(data.sessionId),
                    time : $.base64.atob(data.time)
                };
                if (ackServerCallback) {
                    ackServerCallback('server message was delivered to client!');
                }
            });
        });
    }

    // 如果web端session超時，socket斷開，10分鐘掃描一次
    int = window.setInterval(function() {
        // 我是通過ajax判斷session超時的，你也可以通過其他方式
        $.ajax({
            type : 'POST',
            url : common.ctx + "/getSessionTimeout",
            dataType : "json",
            cache : false,
            success : function(json) {
                var timeout = parseInt(json.message);
                // session超時後，socket斷開，服務端就可以監聽到釋放資源
                if (timeout == 0) {
                    socket.disconnect();
                }
            },
            error : function() {
                socket.disconnect();
                // 清除
                window.clearInterval(int);
            }

        });
    }, YUNM._set.interval);

    callback();
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44
• 45
• 46
• 47
• 48
• 49
• 50
• 51
• 52
• 53
• 54

③、需要web推送的頁面進行socketio的連線

$(function() {
connectQuotation($("#global_uid").val(), function() {
    socket.on("pushQuotation", function(message) {

        if (message.type == "dealOrder") {
            var msg = message.response.result;
            // 輸出服務端訊息
            YUNM.debug(msg);
        }
    });
});
});

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12

五、注意事項

1. 關於socketio的ssl應用，一直沒有弄出來，主要是java的toolkey生成的jks總是不被瀏覽器識別，socketio提供的例子也不能執行，在各大網站上暫時沒有解決問題。可通過瀏覽器新增https的例外做法來規避錯誤，但不可取，後面還需要研究。
2. socketio在瀏覽器重新整理後，舊的連線斷開，需要重新建立連線，這個請注意。
3. 客戶端session超時後，切記關閉socket，我是通過10分鐘一次的掃描進行的session超時驗證，該方法不夠理想。
4. server端，在實際應用中，需要將客戶端斷開的socket進行垃圾清理，注意判斷方法如下：

NamespaceClient client = (NamespaceClient) socket;

if (client.getBaseClient().isConnected()) {
    SessionManager.getSession(getSession().getSessionId());
} else {
    logger.warn("web傳送心跳包失敗，客戶端連線執行緒[" + this.getName() + "]已斷開");
    running = false;
    break;
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9

整體Netty-SocketIO的Web推送還是非常易於掌握的，但是缺少api，做起來需要不停實踐，另外解決問題的方法不多，希望本篇可以給你提供些許幫助。