ThbTech/SmartSubstationPlatform
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改UDP信号协议模块使用线程池方式开启服务

Browse Source
This commit is contained in:
weitang 2025-04-23 14:13:54 +08:00
parent 38859ea331
commit 4c4f61d496
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
riis-system/src/main/java/com/yfd/platform/component/nettyudpserver/NettyUdpRunner.java
View File

@ -1,6 +1,8 @@
package com.yfd.platform.component.nettyudpserver; package com.yfd.platform.component.nettyudpserver;
import com.yfd.platform.component.nettyserver.NettyServer;
import com.yfd.platform.utils.ExecutionJob;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -16,7 +18,7 @@ public class NettyUdpRunner implements CommandLineRunner {
@Override @Override
public void run(String... args) throws Exception { public void run(String... args) throws Exception {
new Thread(() -> { ExecutionJob.EXECUTOR.submit(() -> {
NettyUdpServer server = null; NettyUdpServer server = null;
try { try {
server = new NettyUdpServer(9300); server = new NettyUdpServer(9300);
@ -24,14 +26,14 @@ public class NettyUdpRunner implements CommandLineRunner {
logger.info("NettyUdpRunner running"); logger.info("NettyUdpRunner running");
channel.closeFuture().sync(); channel.closeFuture().sync();
} catch (Exception e) { } catch (Exception e) {
logger.error(e.getMessage());; logger.error(e.getMessage());
;
} finally { } finally {
if(server!=null){ if (server != null) {
server.stop(); server.stop();
} }
} }
} });
).start();
} }