/*
?*??Licensed?to?the?Apache?Software?Foundation?（ASF）?under?one?or?more
?*??contributor?license?agreements.??See?the?NOTICE?file?distributed?with
?*??this?work?for?additional?information?regarding?copyright?ownership.
?*??The?ASF?licenses?this?file?to?You?under?the?Apache?License?Version?2.0
?*??（the?“License“）;?you?may?not?use?this?file?except?in?compliance?with
?*??the?License.??You?may?obtain?a?copy?of?the?License?at
?*
?*??????http://www.apache.org/licenses/LICENSE-2.0
?*
?*??Unless?required?by?applicable?law?or?agreed?to?in?writing?software
?*??distributed?under?the?License?is?distributed?on?an?“AS?IS“?BASIS
?*??WITHOUT?WARRANTIES?OR?CONDITIONS?OF?ANY?KIND?either?express?or?implied.
?*??See?the?License?for?the?specific?language?governing?permissions?and
?*??limitations?under?the?License.
?*/
package?com.zfsoft.terminalManagement.util.websocket;

import?java.io.IOException;
import?java.nio.CharBuffer;
import?java.util.Set;
import?java.util.concurrent.CopyOnWriteArraySet;
import?java.util.concurrent.atomic.AtomicInteger;

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;

import?com.alibaba.druid.support.logging.Log;
import?com.alibaba.druid.support.logging.LogFactory;
import?com.zfsoft.terminalManagement.util.websocket.SocketServer.ChatWebSocket;


@ServerEndpoint（value?=?“/websocket/chat“）
public?class?ChatAnnotation?{

????private?static?final?Log?log?=?LogFactory.getLog（ChatAnnotation.class）;

//????private?static?final?String?GUEST_PREFIX?=?“Guest“;
????private?static?final?AtomicInteger?connectionIds?=?new?AtomicInteger（0）;
????private?static?final?Set?connections?=
????????????new?CopyOnWriteArraySet<>（）;

????private?String?nickname;
????private?Session?session;

????public?ChatAnnotation（）?{
????????nickname?=??“#“+String.valueOf（connectionIds.getAndIncrement（））;
????}


????@OnOpen
????public?void?start（Session?session）?{
????????this.session?=?session;
????????connections.add（this）;
????????String?message?=?String.format（“*?%s?%s“?nickname?“has?joined.“）;
????????System.out.println（“message:“+message）;
????????String?msg?=?“NAME“?+?“\t“?+?nickname;
????????try?{
			this.session.getBasicRemote（）.sendText（msg）;
		}?catch?（IOException?e）?{
			//?TODO?Auto-generated?catch?block
			e.printStackTrace（）;
		}
????}


????@OnClose
????public?void?end（）?{
????????connections.remove（this）;
????????String?message?=?String.format（“*?%s?%s“
????????????????nickname?“has?disconnected.“）;
????????broadcast（message）;
????}


????@OnMessage
????public?void?incoming（String?message）?{
????????//?Never?trust?the?client
????????String?filteredMessage?=?String.format（“%s:?%s“
????????????????nickname?message.toString（））;
????????System.out.println（“filteredMessage:“+filteredMessage）;
??????

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件???????3700??2017-09-30?16:58??webSocket一對一聊天\chat.jsp

?????文件???????3838??2017-09-30?17:02??webSocket一對一聊天\ChatAnnotation.java

?????文件??????93682??2017-07-28?16:32??webSocket一對一聊天\jquery-1.8.3.min.js

?????文件????????467??2017-09-30?17:04??webSocket一對一聊天\TestController.java

?????文件?????????64??2017-09-30?17:06??webSocket一對一聊天\說明.txt

?????目錄??????????0??2017-09-30?17:05??webSocket一對一聊天

-----------?---------??----------?-----??----

???????????????101751????????????????????6