websocket

dk-common/common-websocket/src/main/java/org/dromara/common/websocket/handler/PlusWebSocketHandler.java

@@ -55,10 +55,11 @@ public class PlusWebSocketHandler extends AbstractWebSocketHandler {
             return;
         }
         // 创建WebSocket消息DTO对象
-        WebSocketMessageDto webSocketMessageDto = new WebSocketMessageDto();
+        /*WebSocketMessageDto webSocketMessageDto = new WebSocketMessageDto();
         webSocketMessageDto.setSessionKeys(List.of(loginUser.getUserId()));
-        webSocketMessageDto.setMessage(message.getPayload());
-        WebSocketUtils.publishMessage(webSocketMessageDto);
+        webSocketMessageDto.setMessage(message.getPayload());*/
+        WebSocketUtils.sendMessage(loginUser.getUserId(),"pong");
+        WebSocketUtils.sendPongMessage(session);
     }
 
     /**

dk-common/common-websocket/src/main/java/org/dromara/common/websocket/utils/WebSocketUtils.java

@@ -98,15 +98,11 @@ public class WebSocketUtils {
             ObjectMapper mapper = new ObjectMapper();
             mapper.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE);
             mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
-            WebSocketMessageDto broadcastMessage = new WebSocketMessageDto();
-            broadcastMessage.setMessage(mapper.writeValueAsString(message));
-            RedisUtils.publish(WEB_SOCKET_TOPIC, broadcastMessage, consumer -> {
-                log.info("WebSocket发送主题订阅消息topic:{} message:{}", WEB_SOCKET_TOPIC, message);
+            String jsonString = mapper.writeValueAsString(message);
+            WebSocketSessionHolder.getSessionsAll().forEach(key -> {
+                WebSocketSession session = WebSocketSessionHolder.getSessions(key);
+                sendMessage(session, jsonString);
             });
-//            WebSocketSessionHolder.getSessionsAll().forEach(key -> {
-//                WebSocketSession session = WebSocketSessionHolder.getSessions(key);
-//                sendMessage(session, jsonString);
-//            });
         }catch (Exception e) {
           e.printStackTrace();
         }

dk-modules/resource/pom.xml

@@ -92,10 +92,10 @@
             <artifactId>common-translation</artifactId>
         </dependency>
 
-        <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>common-websocket</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.dromara</groupId>-->
+<!--            <artifactId>common-websocket</artifactId>-->
+<!--        </dependency>-->
 
         <dependency>
             <groupId>org.dromara</groupId>

pom.xml

@@ -16,7 +16,7 @@
         <revision>2.2.2</revision>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-        <java.version>17</java.version>
+        <java.version>21</java.version>
         <spring-boot.version>3.2.11</spring-boot.version>
         <spring-cloud.version>2023.0.3</spring-cloud.version>
         <spring-boot-admin.version>3.2.3</spring-boot-admin.version>
@@ -85,7 +85,7 @@
             <id>dev</id>
             <properties>
                 <!-- 环境标识，需要与配置文件的名称相对应 -->
-                <profiles.active>dev</profiles.active>
+                <profiles.active>wuyuan</profiles.active>
                 <nacos.server>127.0.0.1:8848</nacos.server>
                 <nacos.discovery.group>DEFAULT_GROUP</nacos.discovery.group>
                 <nacos.config.group>DEFAULT_GROUP</nacos.config.group>