| New file |
| | |
|---|
| | | 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 |
|---|
| | | * 通道组池，管理所有websocket连接 |
|---|
| | | */ |
|---|
| | | |
|---|
| | | |
|---|
| | | public class MyChannelHandlerPool { |
|---|
| | | |
|---|
| | | public MyChannelHandlerPool(){} |
|---|
| | | |
|---|
| | | public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); |
|---|
| | | |
|---|
| | | public void sendMsg(String message){ |
|---|
| | | channelGroup.writeAndFlush(new TextWebSocketFrame(message)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
