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

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


/**
?*?@ServerEndpoint?注解是一個(gè)類層次的注解，它的功能主要是將目前的類定義成一個(gè)websocket服務(wù)器端
?*?注解的值將被用于監(jiān)聽用戶連接的終端訪問URL地址客戶端可以通過這個(gè)URL來連接到WebSocket服務(wù)器端
?*/
@ServerEndpoint（“/socketdemo“）
public?class?WebSocketDemo{
????//靜態(tài)變量，用來記錄當(dāng)前在線連接數(shù)。應(yīng)該把它設(shè)計(jì)成線程安全的。
????private?static?int?onlineCount?=?0;

????//concurrent包的線程安全Set，用來存放每個(gè)客戶端對應(yīng)的MyWebSocket對象。若要實(shí)現(xiàn)服務(wù)端與單一客戶端通信的話，可以使用Map來存放，其中Key可以為用戶標(biāo)識
????private?static?CopyOnWriteArraySet?webSocketSet?=?new?CopyOnWriteArraySet（）;

????//與某個(gè)客戶端的連接會(huì)話，需要通過它來給客戶端發(fā)送數(shù)據(jù)
????private?Session?session;

????/**
?????*?連接建立成功調(diào)用的方法
?????*?@param?session??可選的參數(shù)。session為與某個(gè)客戶端的連接會(huì)話，需要通過它來給客戶端發(fā)送數(shù)據(jù)
?????*/
????@OnOpen
????public?void?onOpen（Session?session）{
????????this.session?=?session;
????????webSocketSet.add（this）;?????//加入set中
????????addOnlineCount（）;???????????//在線數(shù)加1
????????System.out.println（“有新連接加入！當(dāng)前在線人數(shù)為“?+?getOnlineCount（））;
????}

????/**
?????*?連接關(guān)閉調(diào)用的方法
?????*/
????@OnClose
????public?void?onClose（）{
????????webSocketSet.remove（this）;??//從set中刪除
????????subOnlineCount（）;???????????//在線數(shù)減1
????????System.out.println（“有一連接關(guān)閉！當(dāng)前在線人數(shù)為“?+?getOnlineCount（））;
????}

????/**
?????*?收到客戶端消息后調(diào)用的方法
?????*?@param?message?客戶端發(fā)送過來的消息
?????*?@param?session?可選的參數(shù)
?????*/
????@OnMessage
????public?void?onMessage（String?message?Session?session）?{
????????System.out.println（“來自客戶端的消息:“?+?message）;
????????//群發(fā)消息
????????for（WebSocketDemo?item:?webSocketSet）{
????????????try?{
????????????????item.sendMessage（message）;
????????????}?catch?（IOException?e）?{
????????????????e.printStackTrace（）;
????????????????continue;
????????????}
????????}
????}

????/**
?????*?發(fā)生錯(cuò)誤時(shí)調(diào)用
?????*?@param?session
?????*?@param?error
?????*/
????@onerror
????public?void?onerror（Session?session?Throwable?error）{
????????System.out.println（“發(fā)生錯(cuò)誤“）;
????????error.printStackTrace（）;
????}

????/**
?????*?這個(gè)方法與上面幾個(gè)方法不一樣。沒有用注解，是根據(jù)自己需要添加的方法。
?????*?@param?message
?????*?@throws?IOException
?????*/
????public?void?sendMessage（String?message）?throws?IOException{
????????this.session.getBasicRemote（）.sendText（message）;
????????//this.session.getAsyncRemote（）.sendText（message）;
????}

????public?static?synchronized?int?getOnlineCount（）?{
????????return?onlineCount;
????}

????public?static?synchronized?void?addOnlineCount（）?{
????	WebSocketDemo.onlineCount++;
????}

????public?static?synchronized?void?subOnlineCount（）?{
????	WebSocketDemo.onlineCount--;
????}
}

?屬性????????????大小?????日期????時(shí)間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\
?????文件?????????996??2017-05-16?09:08??WebSocketDemo\.classpath
?????文件????????1046??2017-05-16?09:08??WebSocketDemo\.project
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\.settings\
?????文件?????????517??2017-05-16?09:08??WebSocketDemo\.settings\.jsdtscope
?????文件?????????364??2017-05-16?09:08??WebSocketDemo\.settings\org.eclipse.jdt.core.prefs
?????文件?????????471??2017-05-16?09:08??WebSocketDemo\.settings\org.eclipse.wst.common.component
?????文件?????????305??2017-05-16?09:08??WebSocketDemo\.settings\org.eclipse.wst.common.project.facet.core.xml
?????文件??????????49??2017-05-16?09:08??WebSocketDemo\.settings\org.eclipse.wst.jsdt.ui.superType.container
?????文件???????????6??2017-05-16?09:08??WebSocketDemo\.settings\org.eclipse.wst.jsdt.ui.superType.name
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\WebContent\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\WebContent\meta-INF\
?????文件??????????25??2017-05-16?09:08??WebSocketDemo\WebContent\meta-INF\MANIFEST.MF
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\WebContent\WEB-INF\
?????目錄???????????0??2017-05-16?09:09??WebSocketDemo\WebContent\WEB-INF\lib\
?????文件?????????401??2017-05-16?09:08??WebSocketDemo\WebContent\WEB-INF\web.xml
?????文件????????1921??2017-05-16?09:08??WebSocketDemo\WebContent\index.jsp
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\build\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\build\classes\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\build\classes\com\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\build\classes\com\cn\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\build\classes\com\cn\angell\
?????文件????????3229??2017-05-16?09:08??WebSocketDemo\build\classes\com\cn\angell\WebSocketDemo.class
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\src\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\src\com\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\src\com\cn\
?????目錄???????????0??2017-05-16?09:08??WebSocketDemo\src\com\cn\angell\
?????文件????????3509??2017-05-16?09:08??WebSocketDemo\src\com\cn\angell\WebSocketDemo.java