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
6889e078
Commit
6889e078
authored
May 16, 2023
by
duanruiming
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
[update] 测试端口
parent
bdba4d50
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
2 additions
and
1 deletion
+2
-1
NettyClient.java
...ervice/src/main/java/net/wanji/com/netty/NettyClient.java
+2
-1
No files found.
signal-utc-dt-service/src/main/java/net/wanji/com/netty/NettyClient.java
View file @
6889e078
...
@@ -42,6 +42,7 @@ public class NettyClient {
...
@@ -42,6 +42,7 @@ public class NettyClient {
.
channel
(
NioDatagramChannel
.
class
)
.
channel
(
NioDatagramChannel
.
class
)
.
option
(
ChannelOption
.
RCVBUF_ALLOCATOR
,
new
FixedRecvByteBufAllocator
(
65535
))
.
option
(
ChannelOption
.
RCVBUF_ALLOCATOR
,
new
FixedRecvByteBufAllocator
(
65535
))
.
localAddress
(
5051
)
.
localAddress
(
5051
)
.
remoteAddress
(
new
InetSocketAddress
(
"10.102.1.204"
,
5050
))
.
handler
(
new
ChannelInitializer
<
NioDatagramChannel
>()
{
.
handler
(
new
ChannelInitializer
<
NioDatagramChannel
>()
{
@Override
@Override
protected
void
initChannel
(
NioDatagramChannel
datagramChannel
)
{
protected
void
initChannel
(
NioDatagramChannel
datagramChannel
)
{
...
@@ -49,7 +50,7 @@ public class NettyClient {
...
@@ -49,7 +50,7 @@ public class NettyClient {
.
addLast
(
new
NettyServerHandler
(
threadPoolExecutor
));
.
addLast
(
new
NettyServerHandler
(
threadPoolExecutor
));
}
}
});
});
ChannelFuture
channelFuture
=
bootstrap
.
bind
(
port
).
sync
();
ChannelFuture
channelFuture
=
bootstrap
.
bind
().
sync
();
Runtime
.
getRuntime
().
addShutdownHook
(
new
Thread
(()
->
{
Runtime
.
getRuntime
().
addShutdownHook
(
new
Thread
(()
->
{
group
.
shutdownGracefully
();
group
.
shutdownGracefully
();
channelFuture
.
channel
().
closeFuture
().
syncUninterruptibly
();
channelFuture
.
channel
().
closeFuture
().
syncUninterruptibly
();
...
...
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