記錄一下jetty和webSocket使用的一個坑

項目中有個功能需要使用webScoket，需求很簡單，就是當后台一段業務邏輯執行后，通過webScoket發送一個消息到前端；看了下項目依賴，

然后再網上搜了一下，說是jetty啟動類里面要加一句這個:

 然后websocket后端代碼是這樣的

package com.gmyl.parking.websocket;

import java.io.IOException;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;

import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * websocket的service
 * @author cjz
 *
 */
@ServerEndpoint("/webSocket")
public class WebSocketDemo {

    private Session session;
    
    private static Logger logger = LoggerFactory.getLogger(WebSocketDemo.class);
    
    private static final  Set<WebSocketDemo> webSocketSet = new CopyOnWriteArraySet<WebSocketDemo>();
    

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        webSocketSet.add(this);
        logger.info("【websocket消息】有新的連接, 總數:{}", webSocketSet.size());
    }

    @OnClose
    public void onClose() {
        webSocketSet.remove(this);
        logger.info("【websocket消息】連接斷開, 總數:{}", webSocketSet.size());
    }

    @OnMessage
    public void onMessage(String message) {
        logger.info("【websocket消息】收到客戶端發來的消息:{}", message);
    }

    
    /**
     * 推送消息到客戶端
     * @param message
     * @throws IOException 
     */
    public static void sendMessage(String message) {
        System.out.println("--------------------:"+webSocketSet.size());
        for (WebSocketDemo webSocket: webSocketSet) {
            logger.info("【websocket消息】廣播消息, message:{}", message);
            try {
                webSocket.session.getBasicRemote().sendText(message);
            //發生異常 關閉連接
            } catch (Exception e) {
                logger.info("【websocket消息】廣播消息發送發生異常, exception:{}", e.getMessage());
                webSocketSet.remove(webSocket);
                try {
                    webSocket.session.close();
                //連接關閉異常
                } catch (IOException e1) {
                    logger.info("【websocket消息】關閉連接發生異常, exception:{}", e.getMessage());
                }
            }
        }
    }

}

 前端js代碼是這樣的

var  ws = commonutil.getWebSocket('webSocket');

ws.onopen = function (event) {
    console.log('建立連接');
}

ws.onclose = function (event) {
    console.log('連接關閉');
}

ws.onmessage = function (event) {
    console.log('收到后台推送的消息:' + event.data)
}

ws.onerror = function () {
    alert('websocket通信發生錯誤！');
}

業務邏輯的service最后調用了一下：WebSocketDemo.sendMessage("后台消息");

啟動jetty運行項目，打開頁面，頁面控制台打印出：【websocket消息】有新的連接, 總數:1，一切正常，但是調試中發現，觸發WebSocketDemo.sendMessage這個方法的時候，sendMessage這個方法中，第一行代碼:System.out.println("--------------------:"+webSocketSet.size()); 打印出來始終是0；搞了半天，很郁悶，這里明明已經打印出連接數1了，而且webSocketSet是static final的，

 private static final  Set<WebSocketDemo> webSocketSet = new CopyOnWriteArraySet<WebSocketDemo>();
    

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        webSocketSet.add(this);
        logger.info("【websocket消息】有新的連接, 總數:{}", webSocketSet.size());
    }

怎么會變成0呢，然后問了下同事，說是換成tomcat啟動就可以了 ，jetty貌似有什么bug，用不了，然后我把項目放到tomcat中啟動，居然真的可以了。。。。。。。。。。。。。。。。具體的原因還不知道，在此記錄一下，順帶說下jetty的版本是：9.2.9.v20150224，spring版本是3.2.5的，spring4之后的版本，支持websocket， 估計如果用spring4自帶的websocket應該會靠譜些吧。補充下js中的commonutil的代碼：

var commonutil = commonutil || {};
/**
 * Description: 建立websocket鏈接並返回實例，如果當前瀏覽器不支持websocket則返回null
 * @returns 
 */
commonutil.getWebSocket = function(subUrl) {
    var url = 'ws://' + location.host + "/"+ subUrl;
    if ('WebSocket' in window)
        ws = new WebSocket(url);
    else if ('MozWebSocket' in window)
        ws = new MozWebSocket(url);
    else
        alert('當前瀏覽器不支持websocket，請使用IE10+、Chrome17+、Firefox7+');
    return ws;
};