Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
T
traffic-signal-platform
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
signal
traffic-signal-platform
Commits
3ae72e4c
Commit
3ae72e4c
authored
Jan 19, 2024
by
duanruiming
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
[update] ws客户端连接添加日志
parent
cd8e8b58
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
3 additions
and
1 deletion
+3
-1
WebSocketClient.java
...ce/src/main/java/net/wanji/utc/cache/WebSocketClient.java
+1
-0
WebSocketClientHandler.java
.../java/net/wanji/utc/websocket/WebSocketClientHandler.java
+2
-1
No files found.
signal-utc-service/src/main/java/net/wanji/utc/cache/WebSocketClient.java
View file @
3ae72e4c
...
@@ -37,6 +37,7 @@ public class WebSocketClient implements CommandLineRunner {
...
@@ -37,6 +37,7 @@ public class WebSocketClient implements CommandLineRunner {
String
crossId
=
crossInfoPO
.
getId
();
String
crossId
=
crossInfoPO
.
getId
();
String
uri
=
"ws://localhost:32000/utc/signalStatus/"
+
crossId
+
",preload"
;
String
uri
=
"ws://localhost:32000/utc/signalStatus/"
+
crossId
+
",preload"
;
session
=
container
.
connectToServer
(
WebSocketClientHandler
.
class
,
URI
.
create
(
uri
));
session
=
container
.
connectToServer
(
WebSocketClientHandler
.
class
,
URI
.
create
(
uri
));
log
.
info
(
"ws客户端建立成功:[{}]"
,
crossId
);
}
}
}
}
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
...
...
signal-utc-service/src/main/java/net/wanji/utc/websocket/WebSocketClientHandler.java
View file @
3ae72e4c
...
@@ -16,6 +16,7 @@ import javax.websocket.*;
...
@@ -16,6 +16,7 @@ import javax.websocket.*;
public
class
WebSocketClientHandler
{
public
class
WebSocketClientHandler
{
@OnOpen
@OnOpen
public
void
onOpen
(
Session
session
)
{
public
void
onOpen
(
Session
session
)
{
log
.
info
(
"WebSocketClientHandler onOpen: {}"
,
session
);
WebSocketClient
.
session
=
session
;
WebSocketClient
.
session
=
session
;
}
}
...
@@ -31,7 +32,7 @@ public class WebSocketClientHandler {
...
@@ -31,7 +32,7 @@ public class WebSocketClientHandler {
@OnClose
@OnClose
public
void
close
()
{
public
void
close
()
{
log
.
info
(
"WebSocketClientHandler close: {}"
,
WebSocketClient
.
session
);
}
}
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment