Skip to content

T
traffic-signal-platform
Commit 12c1088b authored by duanruiming's avatar duanruiming
Browse files
Options

[update] 初始化websocketClient逻辑优化

parent c8bdcfdd
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 7 deletions
signal-utc-service/src/main/java/net/wanji/utc/cache/WebSocketClient.java
View file @ 12c1088b
...@@ -14,7 +14,6 @@ import javax.websocket.Session; ...@@ -14,7 +14,6 @@ import javax.websocket.Session;
import javax.websocket.WebSocketContainer; import javax.websocket.WebSocketContainer;
import java.net.URI; import java.net.URI;
import java.util.List; import java.util.List;
import java.util.Objects;
/** /**
* @author duanruiming * @author duanruiming
...@@ -39,12 +38,10 @@ public class WebSocketClient implements CommandLineRunner { ...@@ -39,12 +38,10 @@ public class WebSocketClient implements CommandLineRunner {
List<CrossInfoPO> crossInfoList = CrossInfoCache.crossInfoList; List<CrossInfoPO> crossInfoList = CrossInfoCache.crossInfoList;
if (!CollectionUtils.isEmpty(crossInfoList)) { if (!CollectionUtils.isEmpty(crossInfoList)) {
for (CrossInfoPO crossInfoPO : crossInfoList) { for (CrossInfoPO crossInfoPO : crossInfoList) {
if (!Objects.equals(23, crossInfoPO.getManufacturerId())) { String crossId = crossInfoPO.getId();
String crossId = crossInfoPO.getId(); String uri = "ws://localhost:" + port + "/utc/signalStatus/" + crossId + ",preload";
String uri = "ws://localhost:" + port + "/utc/signalStatus/" + crossId + ",preload"; session = container.connectToServer(WebSocketClientHandler.class, URI.create(uri));
session = container.connectToServer(WebSocketClientHandler.class, URI.create(uri)); log.info("ws客户端建立成功：[{}]", crossId);
log.info("ws客户端建立成功：[{}]", crossId);
}
} }
} }
} catch (Exception e) { } catch (Exception e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment