{"id":4353,"date":"2022-07-02T21:55:21","date_gmt":"2022-07-02T13:55:21","guid":{"rendered":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/spring-boot%e6%95%b4%e5%90%88websocket%e5%ae%9e%e7%8e%b0%e5%ae%9e%e6%97%b6%e6%b6%88%e6%81%af%e6%8e%a8%e9%80%81\/"},"modified":"2022-07-02T21:55:21","modified_gmt":"2022-07-02T13:55:21","slug":"spring-boot%e6%95%b4%e5%90%88websocket%e5%ae%9e%e7%8e%b0%e5%ae%9e%e6%97%b6%e6%b6%88%e6%81%af%e6%8e%a8%e9%80%81","status":"publish","type":"post","link":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/spring-boot%e6%95%b4%e5%90%88websocket%e5%ae%9e%e7%8e%b0%e5%ae%9e%e6%97%b6%e6%b6%88%e6%81%af%e6%8e%a8%e9%80%81\/","title":{"rendered":"Spring Boot\u6574\u5408WebSocket\u5b9e\u73b0\u5b9e\u65f6\u6d88\u606f\u63a8\u9001"},"content":{"rendered":"
\n

\u5982\u679c\u6559\u7a0b\u4e2d\u4ee3\u7801\u4e0d\u4fbf\u4e8e\u9605\u8bfb\uff0c\u8bf7\u4f7f\u7528\u7535\u8111\u67e5\u770b\u6216\u70b9\u51fb\u9605\u8bfb\u539f\u6587\u3002<\/span><\/h1>\n

<\/span><\/p>\n

0. \u5f00\u53d1\u73af\u5883<\/span><\/h1>\n
    \n
  • \n

    JDK\uff1a1.8<\/span><\/p>\n<\/li>\n

  • \n

    Spring Boot\uff1a2.1.1.RELEASE<\/span><\/p>\n<\/li>\n<\/ul>\n

    1. \u5f15\u5165\u4f9d\u8d56<\/span><\/h1>\n
        <<\/span>dependency<\/span>><\/span><\/span>      <<\/span>groupId<\/span>><\/span>org.springframework.boot<\/<\/span>groupId<\/span>><\/span><\/span>      <<\/span>artifactId<\/span>><\/span>spring-boot-starter-websocket<\/<\/span>artifactId<\/span>><\/span><\/span>    <\/<\/span>dependency<\/span>><\/span><\/span><\/pre>\n
    2. \u65b0\u5efaWebSocket\u914d\u7f6e\u7c7b<\/span><\/h1>\n
    import<\/span> org<\/span>.springframework<\/span>.context<\/span>.annotation<\/span>.Bean<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.context<\/span>.annotation<\/span>.Configuration<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.web<\/span>.socket<\/span>.server<\/span>.standard<\/span>.ServerEndpointExporter<\/span>;<\/span><\/span>@Configuration<\/span><\/span>public<\/span> class<\/span> WebSocketConfig<\/span> {<\/span><\/span>  \/**<\/span><\/span>   * ServerEndpointExporter\u6ce8\u5165<\/span><\/span>   * \u8be5Bean\u4f1a\u81ea\u52a8\u6ce8\u518c\u4f7f\u7528@ServerEndpoint\u6ce8\u89e3\u7533\u660e\u7684WebSocket endpoint<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> ServerEndpointExporter<\/span> serverEndpointExporter<\/span>() {<\/span>    return<\/span> new<\/span> ServerEndpointExporter<\/span>();<\/span>   }<\/span>}<\/span><\/pre>\n
    3. \u65b0\u5efaWebSocket\u670d\u52a1\u7c7b<\/span><\/h1>\n
    package<\/span> cn<\/span>.wbnull<\/span>.springbootdemo<\/span>.service<\/span>;<\/span><\/span>import<\/span> org<\/span>.slf4j<\/span>.Logger<\/span>;<\/span>import<\/span> org<\/span>.slf4j<\/span>.LoggerFactory<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.stereotype<\/span>.Component<\/span>;<\/span><\/span>import<\/span> javax<\/span>.websocket<\/span>.*<\/span>;<\/span>import<\/span> javax<\/span>.websocket<\/span>.server<\/span>.PathParam<\/span>;<\/span>import<\/span> javax<\/span>.websocket<\/span>.server<\/span>.ServerEndpoint<\/span>;<\/span>import<\/span> java<\/span>.io<\/span>.IOException<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.Map<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.concurrent<\/span>.ConcurrentHashMap<\/span>;<\/span><\/span>@Component<\/span><\/span>@ServerEndpoint<\/span>(\"\/websocket\/{terminalId}\"<\/span>)<\/span>public<\/span> class<\/span> WebSocketService<\/span> {<\/span><\/span>  private<\/span> final<\/span> Logger<\/span> logger<\/span> =<\/span> LoggerFactory<\/span>.getLogger<\/span>(WebSocketService<\/span>.class<\/span>);<\/span><\/span>  \/**<\/span><\/span>   * \u4fdd\u5b58\u8fde\u63a5\u4fe1\u606f<\/span><\/span>   *\/<\/span><\/span>  private<\/span> static<\/span> final<\/span> Map<\/span><<\/span>String<\/span>, Session<\/span>><\/span> CLIENTS<\/span> =<\/span> new<\/span> ConcurrentHashMap<\/span><><\/span>();<\/span><\/span>  @OnOpen<\/span><\/span>  public<\/span> void<\/span> onOpen<\/span>(@PathParam<\/span>(\"terminalId\"<\/span>) String<\/span> terminalId<\/span>, Session<\/span> session<\/span>) throws<\/span> Exception<\/span> {<\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u6253\u5f00\u8fde\u63a5\u5f00\u59cb\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span><\/span>    \/\/\u5f53\u524d\u8fde\u63a5\u5df2\u5b58\u5728\uff0c\u5173\u95ed<\/span><\/span>    if<\/span> (CLIENTS<\/span>.containsKey<\/span>(terminalId<\/span>)) {<\/span>      onClose<\/span>(CLIENTS<\/span>.get<\/span>(terminalId<\/span>));<\/span>     }<\/span><\/span>    CLIENTS<\/span>.put<\/span>(terminalId<\/span>, session<\/span>);<\/span><\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u6253\u5f00\u8fde\u63a5\u5b8c\u6210\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span>   }<\/span><\/span>  @OnClose<\/span><\/span>  public<\/span> void<\/span> onClose<\/span>(@PathParam<\/span>(\"terminalId\"<\/span>) String<\/span> terminalId<\/span>, Session<\/span> session<\/span>) throws<\/span> Exception<\/span> {<\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u5173\u95ed\u8fde\u63a5\u5f00\u59cb\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span><\/span>    CLIENTS<\/span>.remove<\/span>(terminalId<\/span>);<\/span><\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u5173\u95ed\u8fde\u63a5\u5b8c\u6210\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span>   }<\/span><\/span>  @OnMessage<\/span><\/span>  public<\/span> void<\/span> onMessage<\/span>(String<\/span> message<\/span>, Session<\/span> session<\/span>) {<\/span>    logger<\/span>.info<\/span>(\"\u524d\u53f0\u53d1\u9001\u6d88\u606f\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span><\/span>  @OnError<\/span><\/span>  public<\/span> void<\/span> onError<\/span>(Session<\/span> session<\/span>, Throwable<\/span> error<\/span>) {<\/span>    logger<\/span>.error<\/span>(error<\/span>.toString<\/span>());<\/span>   }<\/span><\/span>  public<\/span> void<\/span> onClose<\/span>(Session<\/span> session<\/span>) {<\/span>    \/\/\u5224\u65ad\u5f53\u524d\u8fde\u63a5\u662f\u5426\u5728\u7ebf<\/span><\/span>\/\/     if (!session.isOpen()) {<\/span><\/span>\/\/       return;<\/span><\/span>\/\/     }<\/span><\/span><\/span>    try<\/span> {<\/span>      session<\/span>.close<\/span>();<\/span>     } catch<\/span> (IOException<\/span> e<\/span>) {<\/span>      logger<\/span>.error<\/span>(\"\u91d1\u6597\u4e91\u5173\u95ed\u8fde\u63a5\u5f02\u5e38\uff1a\"<\/span> +<\/span> e<\/span>);<\/span>     }<\/span>   }<\/span><\/span>  public<\/span> void<\/span> sendMessage<\/span>(String<\/span> message<\/span>, Session<\/span> session<\/span>) {<\/span>    try<\/span> {<\/span>      session<\/span>.getAsyncRemote<\/span>().sendText<\/span>(message<\/span>);<\/span><\/span>      logger<\/span>.info<\/span>(\"\u63a8\u9001\u6210\u529f\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>     } catch<\/span> (Exception<\/span> e<\/span>) {<\/span>      logger<\/span>.error<\/span>(\"\u63a8\u9001\u5f02\u5e38\uff1a\"<\/span> +<\/span> e<\/span>);<\/span>     }<\/span>   }<\/span><\/span>  public<\/span> boolean<\/span> sendMessage<\/span>(String<\/span> terminalId<\/span>, String<\/span> message<\/span>) {<\/span>    try<\/span> {<\/span>      Session<\/span> session<\/span> =<\/span> CLIENTS<\/span>.get<\/span>(terminalId<\/span>);<\/span>      session<\/span>.getAsyncRemote<\/span>().sendText<\/span>(message<\/span>);<\/span><\/span>      logger<\/span>.info<\/span>(\"\u63a8\u9001\u6210\u529f\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>      return<\/span> true<\/span>;<\/span>     } catch<\/span> (Exception<\/span> e<\/span>) {<\/span>      logger<\/span>.error<\/span>(\"\u63a8\u9001\u5f02\u5e38\uff1a\"<\/span> +<\/span> e<\/span>);<\/span>      return<\/span> false<\/span>;<\/span>     }<\/span>   }<\/span>}<\/span><\/pre>\n
    4. \u65b0\u5efaWeb\u7aef\u8fde\u63a5\u9875\u9762<\/span><\/h1>\n
    <!DOCTYPE html><\/span><\/span><<\/span>html<\/span> lang<\/span>=\"en\"<\/span>><\/span><\/span><<\/span>head<\/span>><\/span><\/span>  <<\/span>meta<\/span> charset<\/span>=\"UTF-8\"<\/span>><\/span><\/span>  <<\/span>title<\/span>><\/span>WebSocket Test<\/<\/span>title<\/span>><\/span><\/span><\/<\/span>head<\/span>><\/span><\/span><<\/span>body<\/span>><\/span><\/span><\/span><<\/span>label<\/span> for<\/span>=\"text\"<\/span>><\/<\/span>label<\/span>><<\/span>input<\/span> id<\/span>=\"text\"<\/span> type<\/span>=\"text\"<\/span>\/><\/span><\/span><<\/span>button<\/span> onclick<\/span>=\"sendMessage()\"<\/span>><\/span>\u53d1\u9001\u6d88\u606f<\/<\/span>button<\/span>><\/span><\/span><<\/span>button<\/span> onclick<\/span>=\"closeWebSocket()\"<\/span>><\/span>\u5173\u95ed\u8fde\u63a5<\/<\/span>button<\/span>><\/span><\/span><<\/span>div<\/span> id<\/span>=\"message\"<\/span>><\/<\/span>div<\/span>><\/span><\/span><\/<\/span>body<\/span>><\/span><\/span><\/span><<\/span>script<\/span> type<\/span>=\"text\/javascript\"<\/span>><\/span><\/span>  let<\/span> websocket<\/span> =<\/span> null<\/span>;<\/span><\/span>  \/\/\u5224\u65ad\u5f53\u524d\u6d4f\u89c8\u5668\u662f\u5426\u652f\u6301WebSocket<\/span><\/span>  if<\/span> ('WebSocket'<\/span> in<\/span> window<\/span>) {<\/span>    websocket<\/span> =<\/span> new<\/span> WebSocket<\/span>(\"ws:\/\/localhost:8090\/websocket\/123456\"<\/span>);<\/span>   } else<\/span> {<\/span>    alert<\/span>('Not support websocket'<\/span>);<\/span>   }<\/span><\/span>  \/\/\u8fde\u63a5\u53d1\u751f\u9519\u8bef\u7684\u56de\u8c03\u65b9\u6cd5<\/span><\/span>  websocket<\/span>.onerror<\/span> =<\/span> function<\/span> () {<\/span>    showMessage<\/span>(\"\u6253\u5f00\u8fde\u63a5\u5931\u8d25\"<\/span>);<\/span>   };<\/span><\/span>  \/\/\u8fde\u63a5\u6210\u529f\u5efa\u7acb\u7684\u56de\u8c03\u65b9\u6cd5<\/span><\/span>  websocket<\/span>.onopen<\/span> =<\/span> function<\/span> (event<\/span>) {<\/span>    showMessage<\/span>(\"\u6253\u5f00\u8fde\u63a5\u6210\u529f\"<\/span>);<\/span>   }<\/span><\/span>  \/\/\u63a5\u6536\u5230\u6d88\u606f\u7684\u56de\u8c03\u65b9\u6cd5<\/span><\/span>  websocket<\/span>.onmessage<\/span> =<\/span> function<\/span> (event<\/span>) {<\/span>    showMessage<\/span>(event<\/span>.data<\/span>);<\/span>   }<\/span><\/span>  \/\/\u8fde\u63a5\u5173\u95ed\u7684\u56de\u8c03\u65b9\u6cd5<\/span><\/span>  websocket<\/span>.onclose<\/span> =<\/span> function<\/span> () {<\/span>    showMessage<\/span>(\"\u5173\u95ed\u8fde\u63a5\u6210\u529f\"<\/span>);<\/span>   }<\/span><\/span>  \/\/\u76d1\u542c\u7a97\u53e3\u5173\u95ed\u4e8b\u4ef6\uff0c\u5f53\u7a97\u53e3\u5173\u95ed\u65f6\uff0c\u4e3b\u52a8\u5173\u95edWebSocket\u8fde\u63a5<\/span><\/span>  window<\/span>.onbeforeunload<\/span> =<\/span> function<\/span> () {<\/span>    websocket<\/span>.close<\/span>();<\/span>   }<\/span><\/span>  function<\/span> showMessage<\/span>(message<\/span>) {<\/span>    document<\/span>.getElementById<\/span>('message'<\/span>).innerHTML<\/span> +=<\/span> message<\/span> +<\/span> '<br\/>'<\/span>;<\/span>   }<\/span><\/span>  function<\/span> closeWebSocket<\/span>() {<\/span>    websocket<\/span>.close<\/span>();<\/span>   }<\/span><\/span>  \/\/\u53d1\u9001\u6d88\u606f<\/span><\/span>  function<\/span> sendMessage<\/span>() {<\/span>    const<\/span> message<\/span> =<\/span> document<\/span>.getElementById<\/span>('text'<\/span>).value<\/span>;<\/span>    websocket<\/span>.send<\/span>(message<\/span>);<\/span>   }<\/span><\/<\/span>script<\/span>><\/span><\/span><\/<\/span>html<\/span>><\/span><\/span><\/pre>\n
    5. \u8bbe\u7f6e\u540e\u7aef\u6d88\u606f\u63a8\u9001<\/span><\/h1>\n
    \u4e3a\u4fbf\u4e8e\u6d4b\u8bd5\uff0c\u76f4\u63a5\u4fee\u6539WebSocketService\uff0c\u5f53\u6536\u5230\u524d\u53f0\u6d88\u606f\u65f6\uff0c\u76f4\u63a5\u7ed9\u524d\u53f0\u53d1\u9001\u6d88\u606f<\/span><\/p>\n
       @OnMessage<\/span>   public void onMessage(String message, Session session) {<\/span>     logger.info(\"\u524d\u53f0\u53d1\u9001\u6d88\u606f\uff1a\" + message);<\/span><\/span>     sendMessage(\"\u6536\u5230\u6d88\u606f\uff1a\" + message, session);<\/span>   }<\/span><\/pre>\n
    6. \u6d4b\u8bd5<\/span><\/h1>\n
    \u6d4f\u89c8\u5668\u8bbf\u95ee<\/span>http:\/\/127.0.0.1:8090\/<\/span>\uff0c\u9875\u9762\u663e\u793a\u5982\u4e0b\uff1a<\/span><\/p>\n
    \u540e\u53f0\u65e5\u5fd7\u5982\u4e0b\uff1a<\/span><\/p>\n
    2022-07-02 21:03:22.753  INFO 9168 --- [nio-8090-exec-2] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u6253\u5f00\u8fde\u63a5\u5f00\u59cb\uff1a0<\/span>2022-07-02 21:03:22.753  INFO 9168 --- [nio-8090-exec-2] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u6253\u5f00\u8fde\u63a5\u5b8c\u6210\uff1a0<\/span><\/pre>\n
    \u5f53\u6211\u4eec\u6d4f\u89c8\u5668\u6253\u5f00\u7b2c\u4e8c\u4e2a\u9875\u9762\uff0c\u7b2c\u4e00\u4e2a\u9875\u9762\u4f1a\u663e\u793a\u65ad\u5f00\u8fde\u63a5<\/span><\/p>\n
    \u540e\u53f0\u65e5\u5fd7\u5982\u4e0b\uff1a<\/span><\/p>\n
    2022-07-02 21:04:01.936  INFO 9168 --- [nio-8090-exec-4] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u6253\u5f00\u8fde\u63a5\u5f00\u59cb\uff1a1<\/span>2022-07-02 21:04:01.938  INFO 9168 --- [nio-8090-exec-4] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u5173\u95ed\u8fde\u63a5\u5f00\u59cb\uff1a0<\/span>2022-07-02 21:04:01.938  INFO 9168 --- [nio-8090-exec-4] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u5173\u95ed\u8fde\u63a5\u5b8c\u6210\uff1a0<\/span>2022-07-02 21:04:01.938  INFO 9168 --- [nio-8090-exec-4] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u6253\u5f00\u8fde\u63a5\u5b8c\u6210\uff1a1<\/span><\/pre>\n
    \u524d\u53f0\u9875\u9762\u5f55\u5165\u6d88\u606f\u5e76\u53d1\u9001\uff0c\u540e\u53f0\u53ef\u6b63\u5e38\u6536\u5230\u6d88\u606f<\/span><\/p>\n
    2022-07-02 21:08:21.860  INFO 1772 --- [nio-8090-exec-3] c.w.s.service.WebSocketService      : \u524d\u53f0\u53d1\u9001\u6d88\u606f\uff1a\u6d4b\u8bd5\u6d88\u606f<\/span>2022-07-02 21:08:21.863  INFO 1772 --- [nio-8090-exec-3] c.w.s.service.WebSocketService      : \u63a8\u9001\u6210\u529f\uff1a\u6536\u5230\u6d88\u606f\uff1a\u6d4b\u8bd5\u6d88\u606f<\/span><\/pre>\n
    \u524d\u53f0\u9875\u9762\u663e\u793a\u6b63\u5e38<\/span><\/p>\n
    \u70b9\u51fb\u5173\u95ed\u8fde\u63a5\uff0c\u53ef\u4ee5\u6b63\u5e38\u5173\u95ed<\/span><\/p>\n
    7. \u670d\u52a1\u4fdd\u6d3b<\/span><\/h1>\n
    \u5bf9\u4e8e\u5b9e\u65f6\u6d88\u606f\u63a8\u9001\u76f8\u5173\u670d\u52a1\uff0c\u90fd\u5b58\u5728\u4fdd\u6d3b\u95ee\u9898\u3002\u8fd9\u91cc\u6211\u4eec\u91c7\u7528\u5fc3\u8df3\u4fdd\u6d3b\u3002\u4fee\u6539WebSocketService\u7c7b<\/span><\/p>\n
    import<\/span> org<\/span>.slf4j<\/span>.Logger<\/span>;<\/span>import<\/span> org<\/span>.slf4j<\/span>.LoggerFactory<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.stereotype<\/span>.Component<\/span>;<\/span><\/span>import<\/span> javax<\/span>.websocket<\/span>.*<\/span>;<\/span>import<\/span> javax<\/span>.websocket<\/span>.server<\/span>.PathParam<\/span>;<\/span>import<\/span> javax<\/span>.websocket<\/span>.server<\/span>.ServerEndpoint<\/span>;<\/span>import<\/span> java<\/span>.io<\/span>.IOException<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.HashMap<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.Map<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.concurrent<\/span>.ConcurrentHashMap<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.concurrent<\/span>.atomic<\/span>.AtomicInteger<\/span>;<\/span><\/span>@Component<\/span><\/span>@ServerEndpoint<\/span>(\"\/websocket\/{terminalId}\"<\/span>)<\/span>public<\/span> class<\/span> WebSocketService<\/span> {<\/span><\/span>  private<\/span> final<\/span> Logger<\/span> logger<\/span> =<\/span> LoggerFactory<\/span>.getLogger<\/span>(WebSocketService<\/span>.class<\/span>);<\/span><\/span>  \/**<\/span><\/span>   * \u4fdd\u5b58\u8fde\u63a5\u4fe1\u606f<\/span><\/span>   *\/<\/span><\/span>  private<\/span> static<\/span> final<\/span> Map<\/span><<\/span>String<\/span>, Session<\/span>><\/span> CLIENTS<\/span> =<\/span> new<\/span> ConcurrentHashMap<\/span><><\/span>();<\/span>  private<\/span> static<\/span> final<\/span> Map<\/span><<\/span>String<\/span>, AtomicInteger<\/span>><\/span> TERMINAL_IDS<\/span> =<\/span> new<\/span> HashMap<\/span><><\/span>();<\/span><\/span>  @OnOpen<\/span><\/span>  public<\/span> void<\/span> onOpen<\/span>(@PathParam<\/span>(\"terminalId\"<\/span>) String<\/span> terminalId<\/span>, Session<\/span> session<\/span>) throws<\/span> Exception<\/span> {<\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u6253\u5f00\u8fde\u63a5\u5f00\u59cb\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span><\/span>    \/\/\u5f53\u524d\u8fde\u63a5\u5df2\u5b58\u5728\uff0c\u5173\u95ed<\/span><\/span>    if<\/span> (CLIENTS<\/span>.containsKey<\/span>(terminalId<\/span>)) {<\/span>      onClose<\/span>(CLIENTS<\/span>.get<\/span>(terminalId<\/span>));<\/span>     }<\/span><\/span>    TERMINAL_IDS<\/span>.put<\/span>(terminalId<\/span>, new<\/span> AtomicInteger<\/span>(0<\/span>));<\/span>    CLIENTS<\/span>.put<\/span>(terminalId<\/span>, session<\/span>);<\/span><\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u6253\u5f00\u8fde\u63a5\u5b8c\u6210\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span>   }<\/span><\/span>  @OnClose<\/span><\/span>  public<\/span> void<\/span> onClose<\/span>(@PathParam<\/span>(\"terminalId\"<\/span>) String<\/span> terminalId<\/span>, Session<\/span> session<\/span>) throws<\/span> Exception<\/span> {<\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u5173\u95ed\u8fde\u63a5\u5f00\u59cb\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span><\/span>    CLIENTS<\/span>.remove<\/span>(terminalId<\/span>);<\/span>    TERMINAL_IDS<\/span>.remove<\/span>(terminalId<\/span>);<\/span><\/span>    logger<\/span>.info<\/span>(session<\/span>.getRequestURI<\/span>().getPath<\/span>() +<\/span> \"\uff0c\u5173\u95ed\u8fde\u63a5\u5b8c\u6210\uff1a\"<\/span> +<\/span> session<\/span>.getId<\/span>());<\/span>   }<\/span><\/span>  @OnMessage<\/span><\/span>  public<\/span> void<\/span> onMessage<\/span>(String<\/span> message<\/span>, Session<\/span> session<\/span>) {<\/span>    logger<\/span>.info<\/span>(\"\u524d\u53f0\u53d1\u9001\u6d88\u606f\uff1a\"<\/span> +<\/span> message<\/span>);<\/span><\/span>    if<\/span> (\"\u5fc3\u8df3\"<\/span>.equals<\/span>(message<\/span>)) {<\/span>      \/\/\u91cd\u7f6e\u5f53\u524d\u7ec8\u7aef\u5fc3\u8df3\u6b21\u6570<\/span><\/span>      TERMINAL_IDS<\/span>.get<\/span>(message<\/span>).set<\/span>(0<\/span>);<\/span>      return<\/span>;<\/span>     }<\/span><\/span>    sendMessage<\/span>(\"\u6536\u5230\u6d88\u606f\uff1a\"<\/span> +<\/span> message<\/span>, session<\/span>);<\/span>   }<\/span><\/span>  @OnError<\/span><\/span>  public<\/span> void<\/span> onError<\/span>(Session<\/span> session<\/span>, Throwable<\/span> error<\/span>) {<\/span>    logger<\/span>.error<\/span>(error<\/span>.toString<\/span>());<\/span>   }<\/span><\/span>  public<\/span> void<\/span> onClose<\/span>(Session<\/span> session<\/span>) {<\/span>    \/\/\u5224\u65ad\u5f53\u524d\u8fde\u63a5\u662f\u5426\u5728\u7ebf<\/span><\/span>\/\/     if (!session.isOpen()) {<\/span><\/span>\/\/       return;<\/span><\/span>\/\/     }<\/span><\/span><\/span>    try<\/span> {<\/span>      session<\/span>.close<\/span>();<\/span>     } catch<\/span> (IOException<\/span> e<\/span>) {<\/span>      logger<\/span>.error<\/span>(\"\u91d1\u6597\u4e91\u5173\u95ed\u8fde\u63a5\u5f02\u5e38\uff1a\"<\/span> +<\/span> e<\/span>);<\/span>     }<\/span>   }<\/span><\/span>  public<\/span> void<\/span> heartbeat<\/span>() {<\/span>    \/\/\u68c0\u67e5\u6240\u6709\u7ec8\u7aef\u5fc3\u8df3\u6b21\u6570<\/span><\/span>    for<\/span> (String<\/span> key<\/span> : TERMINAL_IDS<\/span>.keySet<\/span>()) {<\/span>      \/\/\u5fc3\u8df33\u6b21\u53ca\u4ee5\u4e0a\u7684\u4e3b\u52a8\u65ad\u5f00<\/span><\/span>      if<\/span> ((TERMINAL_IDS<\/span>.get<\/span>(key<\/span>).intValue<\/span>() >=<\/span> 3<\/span>)) {<\/span>        logger<\/span>.info<\/span>(\"\u5fc3\u8df3\u8d85\u65f6\uff0c\u5173\u95ed\u8fde\u63a5\uff1a\"<\/span> +<\/span> key<\/span>);<\/span>        onClose<\/span>(CLIENTS<\/span>.get<\/span>(key<\/span>));<\/span>       }<\/span>     }<\/span><\/span>    for<\/span> (String<\/span> key<\/span> : CLIENTS<\/span>.keySet<\/span>()) {<\/span>      \/\/\u8bb0\u5f55\u5f53\u524d\u7ec8\u7aef\u5fc3\u8df3\u6b21\u6570<\/span><\/span>      TERMINAL_IDS<\/span>.get<\/span>(key<\/span>).incrementAndGet<\/span>();<\/span>      sendMessage<\/span>(\"\u5fc3\u8df3\"<\/span>, CLIENTS<\/span>.get<\/span>(key<\/span>));<\/span>     }<\/span>   }<\/span><\/span>  public<\/span> void<\/span> sendMessage<\/span>(String<\/span> message<\/span>, Session<\/span> session<\/span>) {<\/span>    try<\/span> {<\/span>      session<\/span>.getAsyncRemote<\/span>().sendText<\/span>(message<\/span>);<\/span><\/span>      logger<\/span>.info<\/span>(\"\u63a8\u9001\u6210\u529f\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>     } catch<\/span> (Exception<\/span> e<\/span>) {<\/span>      logger<\/span>.error<\/span>(\"\u63a8\u9001\u5f02\u5e38\uff1a\"<\/span> +<\/span> e<\/span>);<\/span>     }<\/span>   }<\/span><\/span>  public<\/span> boolean<\/span> sendMessage<\/span>(String<\/span> terminalId<\/span>, String<\/span> message<\/span>) {<\/span>    try<\/span> {<\/span>      Session<\/span> session<\/span> =<\/span> CLIENTS<\/span>.get<\/span>(terminalId<\/span>);<\/span>      session<\/span>.getAsyncRemote<\/span>().sendText<\/span>(message<\/span>);<\/span><\/span>      logger<\/span>.info<\/span>(\"\u63a8\u9001\u6210\u529f\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>      return<\/span> true<\/span>;<\/span>     } catch<\/span> (Exception<\/span> e<\/span>) {<\/span>      logger<\/span>.error<\/span>(\"\u63a8\u9001\u5f02\u5e38\uff1a\"<\/span> +<\/span> e<\/span>);<\/span>      return<\/span> false<\/span>;<\/span>     }<\/span>   }<\/span>}<\/span><\/pre>\n
    8. \u65b0\u589e\u5b9a\u65f6\u4efb\u52a1<\/span><\/h1>\n
    \u65b0\u589e\u5b9a\u65f6\u4efb\u52a1\uff0c\u5b9a\u65f6\u7ed9\u8fde\u63a5\u5230WebSocket\u7684\u7ec8\u7aef\u53d1\u9001\u6d88\u606f\uff0c\u8d85\u8fc7\u6307\u5b9a\u6b21\u6570\u672a\u56de\u5e94\u7684\u7ec8\u7aef\u89c6\u4e3a\u79bb\u7ebf\uff0c\u4e3b\u52a8\u5173\u95ed\u8fde\u63a5\u3002<\/span><\/p>\n
    import<\/span> cn<\/span>.wbnull<\/span>.springbootdemo<\/span>.service<\/span>.WebSocketService<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.beans<\/span>.factory<\/span>.annotation<\/span>.Autowired<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.scheduling<\/span>.annotation<\/span>.EnableScheduling<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.scheduling<\/span>.annotation<\/span>.Scheduled<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.stereotype<\/span>.Component<\/span>;<\/span><\/span>@EnableScheduling<\/span><\/span>@Component<\/span><\/span>public<\/span> class<\/span> WebSocketScheduled<\/span> {<\/span><\/span>  @Autowired<\/span><\/span>  private<\/span> WebSocketService<\/span> webSocketService<\/span>;<\/span><\/span>  @Scheduled<\/span>(cron<\/span> =<\/span> \"0\/15 * * * * ?\"<\/span>)<\/span>  public<\/span> void<\/span> heartbeat<\/span>() {<\/span>    webSocketService<\/span>.heartbeat<\/span>();<\/span>   }<\/span>}<\/span><\/pre>\n
    \u540c\u6837\u7684\uff0c\u524d\u53f0\u4e5f\u9700\u8981\u5b9a\u65f6\u5fc3\u8df3WebSocket\uff0c\u8fd9\u91cc\u4e0d\u505a\u8d58\u8ff0\u3002<\/span><\/p>\n
    9. Bean\u6ce8\u5165<\/span><\/h1>\n
    WebSocket\u670d\u52a1\u7c7b\u4e2d\uff0c\u4f7f\u7528@Autowired\u76f4\u63a5\u6ce8\u5165Service\u6216\u666e\u901aBean\u65f6\uff0c\u4f1a\u62a5\u7a7a\u6307\u9488\u9519\u8bef\u3002\u8fd9\u662f\u56e0\u4e3aSpring\u7ba1\u7406\u5bf9\u8c61\u65f6\u4f7f\u7528\u5355\u4f8b\u6a21\u5f0f\uff0c\u4f46WebSocket\u670d\u52a1\u4e3a\u591a\u5bf9\u8c61\u3002<\/span><\/p>\n
    Spring Boot\u9879\u76ee\u5728\u542f\u52a8\u521d\u59cb\u5316\u65f6\uff0c\u4f1a\u521d\u59cb\u5316\u975e\u7528\u6237\u8fde\u63a5\u7684WebSocket\u670d\u52a1\uff0c\u4e3a\u5176\u6ce8\u5165Service\uff0c\u6b64\u65f6\u4f7f\u7528@Autowired\u6ce8\u5165\u7684Service\u4e0d\u4e3anull\uff0c\u5373\u88ab\u6210\u529f\u6ce8\u5165\u3002\u4f46\uff0cSpring\u9ed8\u8ba4\u7ba1\u7406\u7684\u662f\u5355\u4f8b\uff0c\u6240\u4ee5\u53ea\u4f1a\u6ce8\u5165\u4e00\u6b21Service\u3002\u5f53\u65b0\u7528\u6237\u8fde\u63a5\u65f6\uff0c\u7cfb\u7edf\u53c8\u4f1a\u521b\u5efa\u4e00\u4e2a\u65b0\u7684WebSocket\u5bf9\u8c61\uff0cSpring\u5c31\u4e0d\u4f1a\u7ed9\u7b2c\u4e8c\u4e2a WebSocket\u5bf9\u8c61\u6ce8\u5165Service\u4e86\uff0c\u6240\u4ee5\u5bfc\u81f4\u53ea\u8981\u662f\u7528\u6237\u8fde\u63a5\u521b\u5efa\u7684WebSocket \u5bf9\u8c61\uff0c\u90fd\u4e0d\u80fd\u518d\u6ce8\u5165\u4e86\u3002<\/span><\/p>\n
    import<\/span> org<\/span>.slf4j<\/span>.Logger<\/span>;<\/span>import<\/span> org<\/span>.slf4j<\/span>.LoggerFactory<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.beans<\/span>.factory<\/span>.annotation<\/span>.Autowired<\/span>;<\/span>import<\/span> org<\/span>.springframework<\/span>.stereotype<\/span>.Component<\/span>;<\/span><\/span>import<\/span> javax<\/span>.websocket<\/span>.*<\/span>;<\/span>import<\/span> javax<\/span>.websocket<\/span>.server<\/span>.PathParam<\/span>;<\/span>import<\/span> javax<\/span>.websocket<\/span>.server<\/span>.ServerEndpoint<\/span>;<\/span>import<\/span> java<\/span>.io<\/span>.IOException<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.HashMap<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.Map<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.concurrent<\/span>.ConcurrentHashMap<\/span>;<\/span>import<\/span> java<\/span>.util<\/span>.concurrent<\/span>.atomic<\/span>.AtomicInteger<\/span>;<\/span><\/span>@Component<\/span><\/span>@ServerEndpoint<\/span>(\"\/websocket\/{terminalId}\"<\/span>)<\/span>public<\/span> class<\/span> WebSocketService<\/span> {<\/span><\/span>    <\/span>\/\/code<\/span><\/span>  <\/span>  \/**<\/span><\/span>   * \u9700\u8981\u6ce8\u5165\u7684Service\u58f0\u660e\u4e3a\u9759\u6001\uff0c\u8ba9\u5176\u5c5e\u4e8e\u7c7b<\/span><\/span>   *\/<\/span><\/span>  private<\/span> static<\/span> TerminalService<\/span> terminalService<\/span>;<\/span><\/span>  \/**<\/span><\/span>   * \u6ce8\u5165\u7684\u65f6\u5019\uff0c\u7ed9\u7c7b\u7684Service\u6ce8\u5165<\/span><\/span>   *\/<\/span><\/span>  @Autowired<\/span><\/span>  public<\/span> void<\/span> setMchDeviceInfoService<\/span>(TerminalService<\/span> terminalService<\/span>) {<\/span>    WebSocketService<\/span>.terminalService<\/span> =<\/span> terminalService<\/span>;<\/span>   }<\/span><\/span>  @OnOpen<\/span><\/span>  public<\/span> void<\/span> onOpen<\/span>(@PathParam<\/span>(\"terminalId\"<\/span>) String<\/span> terminalId<\/span>, Session<\/span> session<\/span>) throws<\/span> Exception<\/span> {<\/span>    <\/span>    <\/span>\/\/code<\/span><\/span><\/span>    terminalService<\/span>.terminal<\/span>();<\/span>   }<\/span><\/span>  \/\/code<\/span><\/span>}<\/span><\/span><\/pre>\n
    \u6d4b\u8bd5\u65e5\u5fd7\u6253\u5370\u5982\u4e0b<\/span><\/p>\n
    2022-07-02 21:26:08.166  INFO 9924 --- [nio-8090-exec-2] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u6253\u5f00\u8fde\u63a5\u5f00\u59cb\uff1a0<\/span>2022-07-02 21:26:08.166  INFO 9924 --- [nio-8090-exec-2] c.w.s.service.WebSocketService      : \/websocket\/123456\uff0c\u6253\u5f00\u8fde\u63a5\u5b8c\u6210\uff1a0<\/span>2022-07-02 21:26:08.166  INFO 9924 --- [nio-8090-exec-2] c.w.s.service.TerminalService       : \u8fd9\u662f\u4e00\u6761\u6d4b\u8bd5\u65e5\u5fd7<\/span><\/pre>\n
    <\/span><\/p>\n
    \n
    GitHub\uff1a<\/span>https:\/\/github.com\/dkbnull\/SpringBootDemo<\/span><\/span><\/p>\n
    CSDN\uff1a<\/span>https:\/\/blog.csdn.net\/dkbnull\/article\/details\/125577993<\/span><\/span><\/p>\n
    \n
    \u672c\u7bc7\u6587\u7ae0\u6765\u6e90\u4e8e\u5fae\u4fe1\u516c\u4f17\u53f7:                 \u7a0b\u5e8f\u5458null              <\/p>\n<\/blockquote>\n<\/div>\n","raw":"","protected":false},"excerpt":{"rendered":"
    \u5982\u679c\u6559\u7a0b\u4e2d\u4ee3\u7801\u4e0d\u4fbf\u4e8e\u9605\u8bfb\uff0c\u8bf7\u4f7f\u7528\u7535\u8111\u67e5\u770b\u6216\u70b9\u51fb\u9605\u8bfb\u539f\u6587\u3002 0. \u5f00\u53d1\u73af\u5883 JDK\uff1a1.8 Spring Boot\uff1a2.1.1.RE …<\/p>\n","protected":false},"author":1,"featured_media":4346,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"emotion":"","emotion_color":"","title_style":"","license":"","footnotes":""},"categories":[7,37],"tags":[],"class_list":["post-4353","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-spring-boot","category-websocket"],"post_thumbnail_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153106628-150x150.jpeg","content_first_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153112733.png","post_medium_image_300":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153106628-300x127.jpeg","post_thumbnail_image_624":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153106628-1024x435.jpeg","post_frist_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153112733.png","post_medium_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153106628-300x127.jpeg","post_large_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153106628-1024x435.jpeg","post_full_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153106628.jpeg","post_all_images":[{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153112733.png","id":"image0"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153112733.png","id":"image1"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153115476.png","id":"image2"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153115476.png","id":"image3"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153118792.png","id":"image4"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153118792.png","id":"image5"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153122746.jpeg","id":"image6"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524153122746.jpeg","id":"image7"}],"videoAdId":"","listAd":"0","listAdId":"","listAdEvery":6,"total_comments":0,"category_name":"Spring Boot","post_date":"2022-07-02","like_count":"0","praiseWord":"\u9f13\u52b1","copyright_state":"","excitationAd":"0","rewardedVideoAdId":"","detailAdId":"","detailAd":"0","enterpriseMinapp":"0","audios":[],"postImageUrl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230519082947553.jpg","avatarurls":[],"related_posts":null,"pageviews":265,"next_post_id":96,"next_post_title":"Spring boot\u5f15\u5165knife4j\u5e76\u914d\u7f6e","previous_post_id":4358,"previous_post_title":"Spring Boot \u6574\u5408Logback\u8bb0\u5f55\u65e5\u5fd7","_links":{"self":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts\/4353","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/comments?post=4353"}],"version-history":[{"count":0,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts\/4353\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/media\/4346"}],"wp:attachment":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/media?parent=4353"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/categories?post=4353"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/tags?post=4353"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}