From c50e7293cb05a212d9c67828e42cbc82f28d087d Mon Sep 17 00:00:00 2001
From: nnnjjj123 <494715143@qq.com>
Date: Thu, 07 Jan 2021 17:24:53 +0800
Subject: [PATCH] 1.netty调整 2.客户列表
---
src/main/java/org/springblade/modules/nettyServer/ServerHandler.java | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/src/main/java/org/springblade/modules/nettyServer/ServerHandler.java b/src/main/java/org/springblade/modules/nettyServer/ServerHandler.java
index ba26193..4e07b6c 100644
--- a/src/main/java/org/springblade/modules/nettyServer/ServerHandler.java
+++ b/src/main/java/org/springblade/modules/nettyServer/ServerHandler.java
@@ -10,11 +10,29 @@
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.util.CharsetUtil;
import io.netty.util.concurrent.GlobalEventExecutor;
+import org.springblade.modules.alarm.service.IAlarmService;
+import org.springblade.modules.alarm.vo.AlarmVO;
+import org.springblade.modules.catalog.service.catalogService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import javax.annotation.PostConstruct;
import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+@Component
public class ServerHandler extends ChannelInboundHandlerAdapter {
+ @Autowired
+ private catalogService catalogService;
+
+ private static ServerHandler serverHandler;
+
+ @PostConstruct
+ public void init() {
+ serverHandler = this;
+ }
/**
* 客户端与服务端创建连接的时候调用
*/
@@ -64,6 +82,8 @@
String body = new String(req, "UTF-8");
System.out.println("接收客户端数据:" + body);
channelHandlerContext.writeAndFlush(Unpooled.copiedBuffer("LEOK#@!", CharsetUtil.UTF_8));
+ List<Map<String, Object>> list = serverHandler.catalogService.selectCatalogList();
+ System.out.println(list);
// ByteBuf pingMessage = Unpooled.buffer();
// pingMessage.writeBytes(req);
// channelHandlerContext.writeAndFlush(pingMessage);
--
Gitblit v1.9.3