ChannelGroup—广播

1.channelGroup    广播

    关键语句:ChannelGroup channelgroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

     MyChannelHandlerPool.channelgroup.add(ctx.channel());

     MyChannelHandlerPool.channelgroup.remove(ctx.channel());

     MyChannelHandlerPool.channelgroup.writeAndFlush(str);


     实现在任意一个客服端向服务端发送消息,服务端和所有已连接客户端都能接收此消息。(广播)


Server服务器端

ChannelGroup—广播ChannelGroup—广播


ChildChannelHandler  类


ChannelGroup—广播


ServerHandler   处理类

ChannelGroup—广播ChannelGroup—广播


MyChannelHandlerPool   类

ChannelGroup—广播


运行效果:

ChannelGroup—广播