From cf42bfe56c852e3d9ab30f2ca0deab2a4a0927d5 Mon Sep 17 00:00:00 2001 From: HuangXin Date: Tue, 8 Aug 2023 23:20:08 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E5=A2=9E=E5=8A=A0Netty=E4=B8=BB=E5=8A=A8?= =?UTF-8?q?=E5=8F=91=E9=80=81=E6=95=B0=E6=8D=AE=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adapter/impl/netty/MessageHandler.java | 5 +++++ .../pojo/vo/ControlAdapterSocketCtx.java | 12 ++++++++++++ 2 files changed, 17 insertions(+) create mode 100644 src/main/java/com/zjyr/beidouservice/pojo/vo/ControlAdapterSocketCtx.java diff --git a/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java b/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java index 60c5fd5..93618a1 100644 --- a/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java +++ b/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java @@ -1,6 +1,7 @@ package com.zjyr.beidouservice.adapter.impl.netty; import com.zjyr.beidouservice.misc.HelperUtils; +import com.zjyr.beidouservice.pojo.vo.ControlAdapterSocketCtx; import com.zjyr.beidouservice.pojo.vo.YuanRongBinProtocol; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; @@ -10,11 +11,15 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; +import java.util.concurrent.ConcurrentHashMap; + @Slf4j @Component @ChannelHandler.Sharable @RequiredArgsConstructor public class MessageHandler extends SimpleChannelInboundHandler { + public static ConcurrentHashMap ctxMap = new ConcurrentHashMap<>(); + @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { log.info("{}:: Trigger Heart Signle", ctx.channel().id()); diff --git a/src/main/java/com/zjyr/beidouservice/pojo/vo/ControlAdapterSocketCtx.java b/src/main/java/com/zjyr/beidouservice/pojo/vo/ControlAdapterSocketCtx.java new file mode 100644 index 0000000..ab346e4 --- /dev/null +++ b/src/main/java/com/zjyr/beidouservice/pojo/vo/ControlAdapterSocketCtx.java @@ -0,0 +1,12 @@ +package com.zjyr.beidouservice.pojo.vo; + +import io.netty.channel.ChannelHandlerContext; +import lombok.Data; +import lombok.RequiredArgsConstructor; + +@Data +@RequiredArgsConstructor +public class ControlAdapterSocketCtx { + private Long controlAdapterId; + private ChannelHandlerContext ctx; +}