From ab0ac24c86067aaec92a2839280d73c08e458170 Mon Sep 17 00:00:00 2001 From: guoyuji <guoyujie@ng.com> Date: 星期六, 03 二月 2024 11:46:14 +0800 Subject: [PATCH] 2024.2.3提交sd模块相关代码 --- north-glass-erp/src/main/java/com/example/erp/tools/netty/MyChannelHandlerPool.java | 26 ++++++++++++++++++++++++++ 1 files changed, 26 insertions(+), 0 deletions(-) diff --git a/north-glass-erp/src/main/java/com/example/erp/tools/netty/MyChannelHandlerPool.java b/north-glass-erp/src/main/java/com/example/erp/tools/netty/MyChannelHandlerPool.java new file mode 100644 index 0000000..4483d19 --- /dev/null +++ b/north-glass-erp/src/main/java/com/example/erp/tools/netty/MyChannelHandlerPool.java @@ -0,0 +1,26 @@ +package com.example.erp.tools.netty; + +import io.netty.channel.group.ChannelGroup; +import io.netty.channel.group.DefaultChannelGroup; +import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; +import io.netty.util.concurrent.GlobalEventExecutor; +import org.springframework.context.annotation.Bean; + +/** + * MyChannelHandlerPool + * 閫氶亾缁勬睜锛岀鐞嗘墍鏈墂ebsocket杩炴帴 + */ + + +public class MyChannelHandlerPool { + + public MyChannelHandlerPool(){} + + public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); + + public void sendMsg(String message){ + channelGroup.writeAndFlush(new TextWebSocketFrame(message)); + } +} + + -- Gitblit v1.8.0