關(guān)于這段HTML代碼，我說(shuō)如下幾點(diǎn)：

1.一開(kāi)始發(fā)送按鈕處于不可用狀態(tài)，必須先連接
2.連接時(shí)必須先輸入昵稱(chēng)，如果不輸入昵稱(chēng)則彈出提示
3.連接成功之后連接按鈕處于不可點(diǎn)擊狀態(tài)而發(fā)送按鈕處于可點(diǎn)擊狀態(tài)
4.在連接按鈕的點(diǎn)擊事件中初始化WebSocket對(duì)象以及WebSocket中涉及到的一些方法的初始化
5.所有的信息（連接成功，連接出錯(cuò)以及接收到消息）最后都顯示在resultDiv中
6.連接地址是動(dòng)態(tài)變化的，最后的字符是連接的用戶(hù)名

創(chuàng)建WebSocket服務(wù)端

由于我們這里要做的是群聊，所以服務(wù)端的主要功能就是接收客戶(hù)端傳來(lái)的消息并將之廣播給所有的客戶(hù)端。服務(wù)端代碼如下：

@ServerEndpoint("/myws2/{nickname}")
public class WebSocketServer2 {
    private String nickname;
    private Session session;
    private static final Set WEB_SOCKET_SERVER_2_SET = new CopyOnWriteArraySet();

    @OnMessage
    public void onMessage(String message, @PathParam(value = "nickname") String nickname) throws IOException {
        System.out.println("收到了客戶(hù)端發(fā)來(lái)的消息：" + message);
        sendText(nickname+"發(fā)來(lái)了:"+message);
    }

    private static void sendText(String msg) {
        for (WebSocketServer2 webSocketServer2 : WEB_SOCKET_SERVER_2_SET) {
            try {
                synchronized (webSocketServer2) {
                    webSocketServer2.session.getBasicRemote().sendText(msg);
                }
            } catch (IOException e) {
                WEB_SOCKET_SERVER_2_SET.remove(webSocketServer2);
                try {
                    webSocketServer2.session.close();
                } catch (IOException e1) {
                }
                sendText(webSocketServer2.nickname + "同學(xué)已經(jīng)下線(xiàn)");
            }
        }
    }

    @OnOpen
    public void onOpen(Session session, @PathParam(value = "nickname") String nickname) throws IOException {
        this.nickname = nickname;
        this.session = session;
        WEB_SOCKET_SERVER_2_SET.add(this);
        sendText(nickname + "進(jìn)入房間");
        StringBuffer sb = new StringBuffer();
        for (WebSocketServer2 webSocketServer2 : WEB_SOCKET_SERVER_2_SET) {
            sb.append(webSocketServer2.nickname).append(";");
        }
        sendText("當(dāng)前房間有："+sb.toString());
    }

    @OnClose
    public void onClose(Session session) throws IOException {
        WEB_SOCKET_SERVER_2_SET.remove(this);
        sendText(this.nickname+"童鞋已下線(xiàn)");
    }
}

關(guān)于這個(gè)服務(wù)端我解釋如下幾點(diǎn)：

1.第一行的代碼表示服務(wù)端的名字，但是名字里邊有一個(gè){nickname},表示獲取服務(wù)端傳遞來(lái)的最后一個(gè)參數(shù)，在方法里邊可以通過(guò)@PathParam來(lái)獲取，這個(gè)和SpringMVC的參數(shù)注解如出一轍
2.第三行和第四行創(chuàng)建了兩個(gè)對(duì)象，因?yàn)楫?dāng)客戶(hù)端臉上服務(wù)端之后，一個(gè)客戶(hù)端將對(duì)應(yīng)一個(gè)WebSocketServer2對(duì)象，我需要將每一個(gè)客戶(hù)端的有關(guān)信息保存下來(lái)，因此創(chuàng)建出nickname表示該對(duì)象對(duì)應(yīng)的客戶(hù)端的用戶(hù)昵稱(chēng)，session表示該對(duì)象對(duì)應(yīng)的客戶(hù)端的session
3.第五行創(chuàng)建一個(gè)Set集合，該集合是static final類(lèi)型的，表示不管WebSocketServer2的對(duì)象有多少個(gè)，WEB_SOCKET_SERVER_2_SET集合始終是同一個(gè)，該集合主要用來(lái)保存所有連接的客戶(hù)端對(duì)應(yīng)的WebSocketServer2對(duì)象
4.第30行到41行是open方法的邏輯，該方法有兩個(gè)參數(shù)，第一個(gè)session，第二個(gè)nickname，nickname參數(shù)有一個(gè)注解@PathParam表示該參數(shù)的值就是連接地址里邊的最后一個(gè)字符串，這個(gè)參數(shù)是可選的。在該方法里，首先將nickname和session賦值給對(duì)應(yīng)的全局變量，然后將當(dāng)前對(duì)象添加到set集合中，然后調(diào)用sendText方法發(fā)送一條消息，告訴所有的客戶(hù)端XXX進(jìn)入房間啦，最后遍歷set集合中的所有用戶(hù)，拿到所有用戶(hù)的用戶(hù)名，再告訴所有客戶(hù)端當(dāng)前的房間都有誰(shuí)誰(shuí)誰(shuí)。
5.第13-28行的sendText方法是一個(gè)自定義的靜態(tài)方法，該方法主要用來(lái)向所有的客戶(hù)端廣播消息，該方法的基本邏輯就是遍歷set集合，拿到set集合中的每一個(gè)對(duì)象和每一個(gè)對(duì)象中的session，再利用session向?qū)?yīng)的客戶(hù)端發(fā)送消息，如果消息發(fā)送失敗，則將該用戶(hù)從集合中移除，同時(shí)告訴剩余的客戶(hù)端某某人已經(jīng)下線(xiàn)。
6.第7-10行的代碼主要用來(lái)處理客戶(hù)端發(fā)送來(lái)的消息，默認(rèn)的String類(lèi)型的參數(shù)表示客戶(hù)端發(fā)送來(lái)的消息，其他的String類(lèi)型參數(shù)都要加上注解才可以，我們這里第一個(gè)參數(shù)表示客戶(hù)端發(fā)送來(lái)的消息，第二個(gè)參數(shù)表示發(fā)送客戶(hù)端消息的用戶(hù)昵稱(chēng)，這里收到消息之后，再利用sendText廣播給所有用戶(hù)。
7.第43行到47行表示當(dāng)其中一個(gè)用戶(hù)下線(xiàn)了了會(huì)回調(diào)的close方法，在這里方法里首先從集合中移除該客戶(hù)端對(duì)應(yīng)的WebSocketServer2對(duì)象，然后廣播一條消息將該用戶(hù)下線(xiàn)的事告訴所有人。

到此，關(guān)于“如何創(chuàng)建WebSocket服務(wù)端”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！