<dependency> 
	<groupId>org.springframework.boot</groupId> 
	<artifactId>spring-boot-starter-websocket</artifactId> 
</dependency> 

package com.tuhu.websocketsample.configuration;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
@Configuration
public class WebSocketConfig {
  @Bean
  public ServerEndpointExporter serverEndpointExporter() {
    return new ServerEndpointExporter();
  }
}

package com.tuhu.websocketsample.controller;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;

@Component
@ServerEndpoint("/websocket/{sid}")
@Slf4j
public class WebSocketServer {

  /**
   * 靜態(tài)變量，用來(lái)記錄當(dāng)前在線連接數(shù)。應(yīng)該把它設(shè)計(jì)成線程安全的。
   */
  private static int onlineCount = 0;
  /**
   * concurrent包的線程安全Set，用來(lái)存放每個(gè)客戶端對(duì)應(yīng)的MyWebSocket對(duì)象。
   */
  private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<>();
  /**
   * 與某個(gè)客戶端的連接會(huì)話，需要通過(guò)它來(lái)給客戶端發(fā)送數(shù)據(jù)
   */
  private Session session;
  /**
   * 接收sid
   */
  private String sid="";
  /**
   * 連接建立成功調(diào)用的方法
   **/
  @OnOpen
  public void onOpen(Session session,@PathParam("sid") String sid) {
    this.session = session;
    //加入set中
    webSocketSet.add(this);
    //在線數(shù)加1
    addOnlineCount();
    log.info("有新窗口開(kāi)始監(jiān)聽(tīng):"+sid+",當(dāng)前在線人數(shù)為" + getOnlineCount());
    this.sid=sid;
    try {
      sendMessage("連接成功");
    } catch (IOException e) {
      log.error("websocket IO異常");
    }
  }
  /**
   * 連接關(guān)閉調(diào)用的方法
   */
  @OnClose
  public void onClose() {
    //從set中刪除
    webSocketSet.remove(this);
    //在線數(shù)減1
    subOnlineCount();
    log.info("有一連接關(guān)閉！當(dāng)前在線人數(shù)為" + getOnlineCount());
  }
  /**
   * 收到客戶端消息后調(diào)用的方法
   * @param message 客戶端發(fā)送過(guò)來(lái)的消息
   **/
  @OnMessage
  public void onMessage(String message, Session session) {
    log.info("收到來(lái)自窗口"+sid+"的信息:"+message);
    //群發(fā)消息
    for (WebSocketServer item : webSocketSet) {
      try {
        item.sendMessage(message);
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }
  /**
   * @param session
   * @param error
   */
  @OnError
  public void onError(Session session, Throwable error) {
    log.error("發(fā)生錯(cuò)誤");
    error.printStackTrace();
  }
  /**
   * 實(shí)現(xiàn)服務(wù)器主動(dòng)推送
   */
  public void sendMessage(String message) throws IOException {
    this.session.getBasicRemote().sendText(message);
  }
  /**
   * 群發(fā)自定義消息
   * */
  public static void sendInfo(String message,@PathParam("sid") String sid) throws IOException {
    log.info("推送消息到窗口"+sid+"，推送內(nèi)容:"+message);
    for (WebSocketServer item : webSocketSet) {
      try {
        //這里可以設(shè)定只推送給這個(gè)sid的，為null則全部推送
        if(sid==null) {
          item.sendMessage(message);
        }else if(item.sid.equals(sid)){
          item.sendMessage(message);
        }
      } catch (IOException e) {
        continue;
      }
    }
  }
  public static synchronized int getOnlineCount() {
    return onlineCount;
  }
  public static synchronized void addOnlineCount() {
    WebSocketServer.onlineCount++;
  }
  public static synchronized void subOnlineCount() {
    WebSocketServer.onlineCount--;
  }
}

package com.tuhu.websocketsample.controller;

import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;
import java.io.IOException;

@RestController
@RequestMapping("/checkcenter")
public class CheckCenterController {
  /**
   * 頁(yè)面請(qǐng)求
   * @param cid
   * @return
   */
  @GetMapping("/socket/{cid}")
  public ModelAndView socket(@PathVariable String cid) {
    ModelAndView mav=new ModelAndView("/socket");
    mav.addObject("cid", cid);
    return mav;
  }
  /**
   * 推送數(shù)據(jù)接口
   * @param cid
   * @param message
   * @return
   */
  @ResponseBody
  @RequestMapping("/socket/push/{cid}")
  public String pushToWeb(@PathVariable String cid,String message) {
    try {
      WebSocketServer.sendInfo(message,cid);
    } catch (IOException e) {
      e.printStackTrace();
      return "error:"+cid+"#"+e.getMessage();
    }
    return "success:"+cid;
  }

}

var socket; 
  if(typeof(WebSocket) == "undefined") { 
    console.log("您的瀏覽器不支持WebSocket"); 
  }else{ 
    console.log("您的瀏覽器支持WebSocket"); 
    	//實(shí)現(xiàn)化WebSocket對(duì)象，指定要連接的服務(wù)器地址與端口 建立連接
      socket = new WebSocket("ws://localhost:8080/websocket/20"); 
      //打開(kāi)事件
      socket.onopen = function() { 
        console.log("Socket 已打開(kāi)"); 
        //socket.send("這是來(lái)自客戶端的消息" + location.href + new Date());
      }; 
      //獲得消息事件
      socket.onmessage = function(msg) { 
        console.log(msg.data); 
        //發(fā)現(xiàn)消息進(jìn)入  開(kāi)始處理前端觸發(fā)邏輯
      }; 
      //關(guān)閉事件
      socket.onclose = function() { 
        console.log("Socket已關(guān)閉"); 
      }; 
      //發(fā)生了錯(cuò)誤事件
      socket.onerror = function() { 
        alert("Socket發(fā)生了錯(cuò)誤"); 
        //此時(shí)可以嘗試刷新頁(yè)面
      } 
      //離開(kāi)頁(yè)面時(shí)，關(guān)閉socket
      //jquery1.8中已經(jīng)被廢棄，3.0中已經(jīng)移除
      // $(window).unload(function(){
      //   socket.close();
      //});
  }

socket = new WebSocket("ws://localhost:8080/websocket/20") ； 

socket = new WebSocket("ws://localhost:8080/websocket/22") ;

org.springframework.beans.factory.BeanCreationException: Error creating bean with name ‘serverEndpointExporter' defined in class path resource [com/xxx/WebSocketConfig.class]: Invocation of init method failed; nested exception is java.lang.IllegalStateException: javax.websocket.server.ServerContainer not available