change message send mode

src/main/java/com/ctrip/fun/admin/eventhandler/NewStateWebSocket.java

@@ -20,7 +20,7 @@ import javax.websocket.server.ServerEndpoint;
 @ServerEndpoint("/websocket/{userName}")
 public class NewStateWebSocket {
 	
-	public NewStateWebSocket(){}
+	private NewStateWebSocket(){}
 	private static NewStateWebSocket single = null;
 	public static NewStateWebSocket getInstance(){
 		if(single==null){
@@ -39,15 +39,15 @@ public class NewStateWebSocket {
 	  public void onMessage(String message,Session session,@PathParam(value="userName")String userName)throws Exception {
 	   
 	    try {
-	    	Iterator<String> it = sessionMap.keySet().iterator();
+//	    	Iterator<String> it = sessionMap.keySet().iterator();
 	    	//循环给每个客户端发送信息
-	    	while(it.hasNext()){
-	    		String key = (String) it.next();
-	    		Session value = sessionMap.get(key);
-	    		value.getBasicRemote().sendText(message);
-	    	}
-	    	 System.out.println("用户"+userName+"说："+message+"。");
-	    	 System.out.println("当前在线人数："+sessionMap.size());
+//	    	while(it.hasNext()){
+//	    		String key = (String) it.next();
+//	    		Session value = sessionMap.get(key);
+	    	session.getBasicRemote().sendText(message);
+//	    	}
+//	    	 System.out.println("用户"+userName+"说："+message+"。");
+//	    	 System.out.println("当前在线人数："+sessionMap.size());
 		} catch (Exception e) {
 			System.out.println("接收消息事件异常!");
 		}
@@ -93,14 +93,10 @@ public class NewStateWebSocket {
 		String message = "/system/user/"+mobileNo+"/detailByUid";
 		Session session = sessionMap.get(username);
 		System.out.println("unicast--------------------------------------------------"+message+" "+session.getBasicRemote().toString());
-		//NewStateWebSocket socket = NewStateWebSocket.getInstance();
+		NewStateWebSocket socket = NewStateWebSocket.getInstance();
 		try {
-			if(session!=null){
-				session.getBasicRemote().sendText(message);
-			}else{
-				System.out.println("没有找到分机号是"+username+"的会话,绑定手机号码是"+mobileNo+".");
-			}
-			//socket.onMessage(message, session, username);
+//			session.getBasicRemote().sendText(message);
+			socket.onMessage(message, session, username);
 		} catch (Exception e) {
 			e.printStackTrace();
 		}