[incubator-shenyu] branch master updated: [ISSUE #2173] fix websocket send message unsafe (#2174)

[xiaoyu]

This is an automated email from the ASF dual-hosted git repository.

xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-shenyu.git


The following commit(s) were added to refs/heads/master by this push:
     new c852ed5  [ISSUE #2173] fix websocket send message unsafe (#2174)
c852ed5 is described below

commit c852ed5d38d9656c1bf8a34b36121f3dd8127373
Author: sunrui849 <rui.849...@outlook.com>
AuthorDate: Thu Sep 30 10:53:20 2021 +0800

    [ISSUE #2173] fix websocket send message unsafe (#2174)
    
    * fix websocket not safe
    
    * fix websocket not safe
    
    Co-authored-by: rui_849...@163.com <sunru...@jd.com>
---
 .../org/apache/shenyu/admin/listener/websocket/WebsocketCollector.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/websocket/WebsocketCollector.java
 
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/websocket/WebsocketCollector.java
index ef9c5a1..189b78e 100644
--- 
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/websocket/WebsocketCollector.java
+++ 
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/websocket/WebsocketCollector.java
@@ -136,7 +136,7 @@ public class WebsocketCollector {
         }
     }
 
-    private static void sendMessageBySession(final Session session, final 
String message) {
+    private static synchronized void sendMessageBySession(final Session 
session, final String message) {
         try {
             session.getBasicRemote().sendText(message);
         } catch (IOException e) {