var ws = new WebSocket(“ws://localhost:9999/ws/huhy/”);   
ws.onopen = function(){ws.send(“Test!”); }; 
ws.onmessage = function(evt){console.log(evt.data);ws.close();}; 
ws.onclose = function(evt){console.log(“WebSocketClosed!”);}; 
ws.onerror = function(evt){console.log(“WebSocketError!”);};

注：

第一行代码是在申请一个WebSocket对象，参数是需要连接的服务器端的地址，同http协议使用http://开头一样，WebSocket协议的URL使用ws://开头，另外安全的WebSocket协议使用wss://开头。

第二行到第五行为WebSocket对象注册消息的处理函数，WebSocket对象一共支持四个消息 onopen, onmessage, onclose和onerror，当Browser和WebSocketServer连接成功后，会触发onopen消息；如果连接失败，发送、接收数据失败或者处理数据出现错误，browser会触发onerror消息；当Browser接收到WebSocketServer发送过来的数据时，就会触发onmessage消息，参数evt中包含server传输过来的数据；当Browser接收到WebSocketServer端发送的关闭连接请求时，就会触发onclose消息。我们可以看出所有的操作都是采用消息的方式触发的，这样就不会阻塞UI，使得UI有更快的响应时间，得到更好的用户体验。

  1 package com.huhy.web.websocket;
  2 
  3 /**
  4  * @Author:{huhy}
  5  * @DATE:Created on 2017/11/20 10:34
  6  * @Class Description:
  7  */
  8 import org.springframework.stereotype.Component;
  9 
 10 import javax.websocket.*;
 11 import javax.websocket.server.PathParam;
 12 import javax.websocket.server.ServerEndpoint;
 13 import java.io.IOException;
 14 import java.util.Map;
 15 import java.util.concurrent.ConcurrentHashMap;
 16 
 17 /**
 18  * ServerEndpoint
 19  * <p>
 20  * 使用springboot的唯一区别是要@Component声明下，而使用独立容器是由容器自己管理websocket的，但在springboot中连容器都是spring管理的。
 21  * <p>
 22  * 虽然@Component默认是单例模式的，但springboot还是会为每个websocket连接初始化一个bean，所以可以用一个静态set保存起来。
 23  */
 24 @ServerEndpoint("/ws/huhy/{userName}") //WebSocket客户端建立连接的地址
 25 @Component
 26 public class ChatRoomServerEndpoint {
 27 
 28     /**
 29      * 存活的session集合（使用线程安全的map保存）
 30      */
 31     private static Map<String, Session> livingSessions = new ConcurrentHashMap<>();
 32 
 33     /**
 34      * 建立连接的回调方法
 35      *
 36      * @param session  与客户端的WebSocket连接会话
 37      * @param userName 用户名，WebSocket支持路径参数
 38      */
 39     @OnOpen
 40     public void onOpen(Session session, @PathParam("userName") String userName) {
 41         livingSessions.put(session.getId(), session);
 42         sendMessageToAll(userName + " 加入聊天室");
 43     }
 44 
 45     /**
 46      * 收到客户端消息的回调方法
 47      *
 48      * @param message 客户端传过来的消息
 49      * @param session 对应的session
 50      */
 51     @OnMessage
 52     public void onMessage(String message, Session session, @PathParam("userName") String userName) {
 53         sendMessageToAll(userName + " : " + message);
 54     }
 55 
 56 
 57     /**
 58      * 发生错误的回调方法
 59      *
 60      * @param session
 61      * @param error
 62      */
 63     @OnError
 64     public void onError(Session session, Throwable error) {
 65         System.out.println("发生错误");
 66         error.printStackTrace();
 67     }
 68 
 69     /**
 70      * 关闭连接的回调方法
 71      */
 72     @OnClose
 73     public void onClose(Session session, @PathParam("userName") String userName) {
 74         livingSessions.remove(session.getId());
 75         sendMessageToAll(userName + " 退出聊天室");
 76     }
 77 
 78 
 79     /**
 80      * 单独发送消息
 81      *
 82      * @param session
 83      * @param message
 84      */
 85     public void sendMessage(Session session, String message) {
 86         try {
 87             session.getBasicRemote().sendText(message);
 88         } catch (IOException e) {
 89             e.printStackTrace();
 90         }
 91     }
 92 
 93     /**
 94      * 群发消息
 95      *
 96      * @param message
 97      */
 98     public void sendMessageToAll(String message) {
 99         livingSessions.forEach((sessionId, session) -> {
100             sendMessage(session, message);
101         });
102     }
103 
104 }