WebFlux 中 WebSocket 实现通信

liqiangqiang · liqiangqiang · commit 0da9ac1a88d3 · 2018-05-03T15:23:29.000+08:00
diff --git a/springboot-webflux-8-websocket/src/main/java/org/spring/springboot/handler/EchoHandler.java b/springboot-webflux-8-websocket/src/main/java/org/spring/springboot/handler/EchoHandler.java
@@ -12,6 +12,7 @@ public class EchoHandler implements WebSocketHandler {
     public Mono<Void> handle(final WebSocketSession session) {
         return session.send(
                 session.receive()
-                        .map(msg -> session.textMessage("服务端返回：小明， -> " + msg.getPayloadAsText())));
+                        .map(msg -> session.textMessage(
+                                "服务端返回：小明， " + msg.getPayloadAsText())));
     }
 }
diff --git a/springboot-webflux-8-websocket/src/main/resources/websocket-client.html b/springboot-webflux-8-websocket/src/main/resources/websocket-client.html
@@ -6,22 +6,24 @@
 </head>
 <body>
 
-<div class="events"></div>
+<div class="chat"></div>
+
 <script>
   var clientWebSocket = new WebSocket("ws://localhost:8080/echo");
+
   clientWebSocket.onopen = function () {
     console.log("clientWebSocket.onopen", clientWebSocket);
     console.log("clientWebSocket.readyState", "websocketstatus");
-    clientWebSocket.send("你好");
+    clientWebSocket.send("你好！");
   }
 
   clientWebSocket.onclose = function (error) {
     console.log("clientWebSocket.onclose", clientWebSocket, error);
-    events("再见");
+    events("聊天会话关闭！");
   }
 
   function events(responseEvent) {
-    document.querySelector(".events").innerHTML += responseEvent + "<br>";
+    document.querySelector(".chat").innerHTML += responseEvent + "<br>";
   }
 </script>
 </body>
diff --git a/springboot-webflux-8-websocket/src/test/java/WSClient.java b/springboot-webflux-8-websocket/src/test/java/WSClient.java
@@ -7,6 +7,8 @@
 import java.time.Duration;
 
 public class WSClient {
+
+
     public static void main(final String[] args) {
         final WebSocketClient client = new ReactorNettyWebSocketClient();
         client.execute(URI.create("ws://localhost:8080/echo"), session ->

Original file line number	Diff line number	Diff line change
`@@ -12,6 +12,7 @@ public class EchoHandler implements WebSocketHandler {`
`12`	`12`	`public Mono<Void> handle(final WebSocketSession session) {`
`13`	`13`	`return session.send(`
`14`	`14`	`session.receive()`
`15`		`- .map(msg -> session.textMessage("服务端返回：小明， -> " + msg.getPayloadAsText())));`
	`15`	`+ .map(msg -> session.textMessage(`
	`16`	`+ "服务端返回：小明， " + msg.getPayloadAsText())));`
`16`	`17`	`}`
`17`	`18`	`}`