From 9aa66699aaa610be66f5bd0c22e90cae114311f9 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期五, 07 七月 2023 17:15:16 +0800
Subject: [PATCH] 优化外联设备报警解析并上传mqtt
---
src/main/java/com/ard/utils/udp/NettyUdpServer.java | 5 ++---
1 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/ard/utils/udp/NettyUdpServer.java b/src/main/java/com/ard/utils/udp/NettyUdpServer.java
index 724458d..caa5a8e 100644
--- a/src/main/java/com/ard/utils/udp/NettyUdpServer.java
+++ b/src/main/java/com/ard/utils/udp/NettyUdpServer.java
@@ -18,9 +18,8 @@
/**
* 鍚姩鏈嶅姟
*/
- @Async
+ @Async("alarm")
public void init(int port) {
-
//琛ㄧず鏈嶅姟鍣ㄨ繛鎺ョ洃鍚嚎绋嬬粍锛屼笓闂ㄦ帴鍙� accept 鏂扮殑瀹㈡埛绔痗lient 杩炴帴
EventLoopGroup bossLoopGroup = new NioEventLoopGroup();
try {
@@ -40,7 +39,7 @@
//7銆佺洃鍚�氶亾鍏抽棴浜嬩欢锛屽簲鐢ㄧ▼搴忎細涓�鐩寸瓑寰咃紝鐩村埌channel鍏抽棴
channelFuture.channel().closeFuture().sync();
} catch (Exception e) {
- log.error("error:"+e.getMessage());
+ log.error("error:" + e.getMessage());
} finally {
log.info("netty udp close!");
//8 鍏抽棴EventLoopGroup锛�
--
Gitblit v1.9.3