xiewenjie vor 3 Jahren
Ursprung
Commit
a22d128ac7

+ 3 - 3
sxz-application/src/main/resources/application-prod.properties

@@ -34,8 +34,8 @@ spring.datasource.hikari.connection-timeout=30000
 #rabbitmq
 spring.rabbitmq.host=127.0.0.1
 spring.rabbitmq.port=5672
-spring.rabbitmq.username=guest
-spring.rabbitmq.password=guest
+spring.rabbitmq.username=admin
+spring.rabbitmq.password=sxz12341
 # 开启重试
 spring.rabbitmq.listener.simple.retry.enabled=true
 # 重试次数,默认为3次
@@ -70,7 +70,7 @@ j2cache.j2CacheConfig.serialization=fastjson
 j2cache.cache-clean-mode=active
 j2cache.redis-client=lettuce
 j2cache.j2CacheConfig.hosts=127.0.0.1:6379
-j2cache.j2CacheConfig.password=
+j2cache.j2CacheConfig.password=sxz123321SxZ@
 j2cache.j2CacheConfig.database=15
 oss.point=http://oss-cn-shenzhen.aliyuncs.com
 oss.key=LTAIUrvuHqj8pvry

+ 3 - 0
sxz-core/src/main/java/com/fdkk/sxz/webApi/socket/ComponentSocket.java

@@ -66,6 +66,8 @@ public class ComponentSocket {
     @OnOpen
     public void onOpen(Session session, HttpHeaders headers, @PathVariable Map pathMap) {
         ComponentSocket.log.info("new connection, sessionId-{},Host-{}", session.id(), headers.get("Host"));
+        session.sendText("onOpen" + session.id().toString());
+
     }
 
     @OnClose
@@ -75,6 +77,7 @@ public class ComponentSocket {
             Thread.sleep(1000);
             thread.interrupt();
         }
+        session.sendText("onClose" + session.id().toString());
     }
 
     @OnError

+ 2 - 0
sxz-core/src/main/java/com/fdkk/sxz/webApi/socket/ModelUploadSocket.java

@@ -66,6 +66,7 @@ public class ModelUploadSocket {
     @OnOpen
     public void onOpen(Session session, HttpHeaders headers, @PathVariable Map pathMap) {
         ModelUploadSocket.log.info("new connection, sessionId-{},Host-{}", session.id(), headers.get("Host"));
+        session.sendText("onOpen" + session.id().toString());
     }
 
     @OnClose
@@ -75,6 +76,7 @@ public class ModelUploadSocket {
             Thread.sleep(1000);
             thread.interrupt();
         }
+        session.sendText("onClose" + session.id().toString());
     }
 
     @OnError