首页 > 代码库 > 基于Netty5.0入门案例六之NettyServer群发消息

基于Netty5.0入门案例六之NettyServer群发消息

2024-11-02 01:15:02   204人阅读

前言介绍：

    我们的NettyServer收到数据后，需要群发给当前链接到服务端的所有小伙伴。

    技术点：

    1、ChannelGroup 【io.netty.channel.group.DefaultChannelGroup】

   欢迎加入：itstack | Netty The Sniper 5360692

环境需求：

    1、jdk1.7以上【jdk1.7以下只能部分支持netty】

    2、Netty-all-5.0【netty3.x 4.x 5每次的变化较大，接口类名也随着变化】

    3、telnet 测试【可以现在你的win7机器上测试这个命令，用于链接到服务端的测试命令】【本案例中已经很不好满足测试需求了】

    4、最好下载个网络调试助手，它能帮助你测试服务端、客户端

代码部分：

======================

TestNettyServerBaseDemo

    src

        com.itstack

            ChildChannelHandler.java

            MyChannelHandlerPool.java

            MyServerHanlder.java

            NettyServer.java

======================

ChildChannelHandler.java



  1. package com.itstack;
  2.  
  3. import io.netty.buffer.ByteBuf;
  4. import io.netty.buffer.Unpooled;
  5. import io.netty.channel.ChannelInitializer;
  6. import io.netty.channel.socket.SocketChannel;
  7. import io.netty.handler.codec.DelimiterBasedFrameDecoder;
  8. import io.netty.handler.codec.Delimiters;
  9. import io.netty.handler.codec.FixedLengthFrameDecoder;
  10. import io.netty.handler.codec.LineBasedFrameDecoder;
  11. import io.netty.handler.codec.string.StringDecoder;
  12. import io.netty.handler.codec.string.StringEncoder;
  13.  
  14. public class ChildChannelHandler extends ChannelInitializer<SocketChannel> {
  15.  
  16. @Override
  17. protected void initChannel(SocketChannel e) throws Exception {
  18.  
  19. System.out.println("报告");
  20. System.out.println("信息：有一客户端链接到本服务端");
  21. System.out.println("IP:" + e.localAddress().getHostName());
  22. System.out.println("Port:" + e.localAddress().getPort());
  23. System.out.println("报告完毕");
  24.  
  25. // 解码器
  26. // 基于换行符号
  27. e.pipeline().addLast(new LineBasedFrameDecoder(1024));
  29. // 基于指定字符串【换行符，这样功能等同于LineBasedFrameDecoder】
  30. // e.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, false, Delimiters.lineDelimiter()));
  31. // 基于最大长度
  32. // e.pipeline().addLast(new FixedLengthFrameDecoder(4));
  33. // 解码转String
  34. e.pipeline().addLast(new StringDecoder());
  35.  
  36. // 编码器 String
  37. e.pipeline().addLast(new StringEncoder());
  39. // 在管道中添加我们自己的接收数据实现方法
  40. e.pipeline().addLast(new MyServerHanlder());
  41.  
  42. }
  43.  
  44. }

MyChannelHandlerPool.java


  1. package com.itstack;
  2.  
  3. import io.netty.channel.group.ChannelGroup;
  4. import io.netty.channel.group.DefaultChannelGroup;
  5. import io.netty.util.concurrent.GlobalEventExecutor;
  6.  
  7. /**
  8. *
  9. * 这里讲ChannelGroup单独放到一个类里，并有多个客户端使用
  10. * 同时ChannelGroup是static的
  11. * 说明：这不是唯一的处理方式
  12. *
  13. */
  14. public class MyChannelHandlerPool {
  15.  
  16. public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
  18. }



MyServerHanlder.java


  1. package com.itstack;
  2.  
  3. import java.util.Date;
  4.  
  5. import io.netty.buffer.ByteBuf;
  6. import io.netty.buffer.Unpooled;
  7. import io.netty.channel.ChannelHandlerAdapter;
  8. import io.netty.channel.ChannelHandlerContext;
  9. import io.netty.handler.codec.bytes.ByteArrayDecoder;
  10.  
  11. public class MyServerHanlder extends ChannelHandlerAdapter{
  12.  
  13. /*
  14. * channelAction
  15. *
  16. * channel 通道
  17. * action 活跃的
  18. *
  19. * 当客户端主动链接服务端的链接后，这个通道就是活跃的了。也就是客户端与服务端建立了通信通道并且可以传输数据
  20. *
  21. */
  22. public void channelActive(ChannelHandlerContext ctx) throws Exception {
  24. System.out.println(ctx.channel().localAddress().toString()+" channelActive");
  26. //添加到channelGroup 通道组
  27. MyChannelHandlerPool.channelGroup.add(ctx.channel());
  29. //通知您已经链接上客户端
  30. String str = "您已经开启与服务端链接"+" "+ctx.channel().id()+new Date()+" "+ctx.channel().localAddress();
  31. ctx.writeAndFlush(str);
  33. }
  35. /*
  36. * channelInactive
  37. *
  38. * channel 通道
  39. * Inactive 不活跃的
  40. *
  41. * 当客户端主动断开服务端的链接后，这个通道就是不活跃的。也就是说客户端与服务端的关闭了通信通道并且不可以传输数据
  42. *
  43. */
  44. public void channelInactive(ChannelHandlerContext ctx) throws Exception {
  46. // 从channelGroup中移除，当有客户端退出后，移除channel。
  47. MyChannelHandlerPool.channelGroup.remove(ctx.channel());
  49. System.out.println(ctx.channel().localAddress().toString()+" channelInactive");
  51. }
  53. /*
  54. * channelRead
  55. *
  56. * channel 通道
  57. * Read 读
  58. *
  59. * 简而言之就是从通道中读取数据，也就是服务端接收客户端发来的数据
  60. * 但是这个数据在不进行解码时它是ByteBuf类型的后面例子我们在介绍
  61. *
  62. */
  63. public void channelRead(ChannelHandlerContext ctx, Object msg)
  64. throws Exception {
  66. //注意此处已经不需要手工解码了
  67. System.out.println(ctx.channel().id()+""+new Date()+" "+msg);
  69. //通知您已经链接上客户端[给客户端穿回去的数据加个换行]
  70. String str = "服务端收到："+ctx.channel().id()+new Date()+" "+msg+"\r\n";
  72. //收到信息后，群发给所有小伙伴
  73. MyChannelHandlerPool.channelGroup.writeAndFlush(str);
  74. }
  76. /*
  77. * channelReadComplete
  78. *
  79. * channel 通道
  80. * Read 读取
  81. * Complete 完成
  82. *
  83. * 在通道读取完成后会在这个方法里通知，对应可以做刷新操作
  84. * ctx.flush()
  85. *
  86. */
  87. public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
  88. ctx.flush();
  89. }
  91. /*
  92. * exceptionCaught
  93. *
  94. * exception 异常
  95. * Caught 抓住
  96. *
  97. * 抓住异常，当发生异常的时候，可以做一些相应的处理，比如打印日志、关闭链接
  98. *
  99. */
  100. public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
  101. throws Exception {
  102. ctx.close();
  103. System.out.println("异常信息：\r\n"+cause.getMessage());
  104. }
  108. }

NettyServer.java



  1. package com.itstack;
  2.  
  3. import io.netty.bootstrap.ServerBootstrap;
  4. import io.netty.channel.ChannelFuture;
  5. import io.netty.channel.ChannelOption;
  6. import io.netty.channel.EventLoopGroup;
  7. import io.netty.channel.nio.NioEventLoopGroup;
  8. import io.netty.channel.socket.nio.NioServerSocketChannel;
  9.  
  10. public class NettyServer {
  11.  
  12. public static void main(String[] args) {
  14. try {
  15. System.out.println("服务端开启等待客户端链接");
  16. new NettyServer().bing(7397);
  17. } catch (Exception e) {
  18. e.printStackTrace();
  19. }
  21. }
  23. public void bing(int port) throws Exception{
  25. EventLoopGroup bossGroup = new NioEventLoopGroup();
  26. EventLoopGroup workGroup = new NioEventLoopGroup();
  28. try {
  30. ServerBootstrap b = new ServerBootstrap();
  31. b.group(bossGroup, workGroup);
  32. b.channel(NioServerSocketChannel.class);
  33. b.option(ChannelOption.SO_BACKLOG, 1024);
  34. b.childHandler(new ChildChannelHandler());
  36. // 绑定端口
  37. ChannelFuture f = b.bind(port).sync();
  39. // 等待服务端监听端口关闭
  40. f.channel().closeFuture().sync();
  42. } finally {
  44. // 优雅的退出
  45. bossGroup.shutdownGracefully();
  46. workGroup.shutdownGracefully();
  47. }
  49. }
  51. }

1、启动NettyServer

2、控制台输出：

----------------------------------------------

服务端开启等待客户端链接

----------------------------------------------

3、开启2个以上客户端模拟软件


4、

服务端端控制台输出：

----------------------------------------------

报告
信息：有一客户端链接到本服务端
IP:user-PC
Port:7397
报告完毕
user-PC/192.168.30.223:7397 channelActive
defa23d9Tue Dec 30 16:54:51 CST 2014 群号：5360692
defa23d9Tue Dec 30 16:54:51 CST 2014 群号：5360692
defa23d9Tue Dec 30 16:54:52 CST 2014 群号：5360692
defa23d9Tue Dec 30 16:54:53 CST 2014 群号：5360692
报告
信息：有一客户端链接到本服务端
IP:localhost.localdomain
Port:7397
报告完毕
localhost.localdomain/127.0.0.1:7397 channelActive
5f735249Tue Dec 30 16:55:02 CST 2014 1
5f735249Tue Dec 30 16:55:03 CST 2014 1
5f735249Tue Dec 30 16:55:04 CST 2014 1
5f735249Tue Dec 30 16:55:04 CST 2014 1
5f735249Tue Dec 30 16:55:04 CST 2014 1
5f735249Tue Dec 30 16:55:05 CST 2014 1
5f735249Tue Dec 30 16:55:05 CST 2014 1
5f735249Tue Dec 30 16:55:05 CST 2014 1
5f735249Tue Dec 30 16:55:05 CST 2014 1
defa23d9Tue Dec 30 16:55:10 CST 2014 群号：5360692

----------------------------------------------

其中一个客户端控制输出：

---------------------------------------------


    1. 您已经开启与服务端链接 defa23d9Tue Dec 30 16:54:49 CST 2014 user-PC/192.168.30.223:7397
    2. 服务端收到：defa23d9Tue Dec 30 16:54:51 CST 2014 群号：5360692
    3.  
    4. 服务端收到：defa23d9Tue Dec 30 16:54:51 CST 2014 群号：5360692
    5.  
    6. 服务端收到：defa23d9Tue Dec 30 16:54:52 CST 2014 群号：5360692
    7.  
    8. 服务端收到：defa23d9Tue Dec 30 16:54:53 CST 2014 群号：5360692
    9.  
    10. 服务端收到：5f735249Tue Dec 30 16:55:02 CST 2014 1
    11.  
    12. 服务端收到：5f735249Tue Dec 30 16:55:03 CST 2014 1
    13.  
    14. 服务端收到：5f735249Tue Dec 30 16:55:04 CST 2014 1
    15.  
    16. 服务端收到：5f735249Tue Dec 30 16:55:04 CST 2014 1
    17.  
    18. 服务端收到：5f735249Tue Dec 30 16:55:04 CST 2014 1
    19.  
    20. 服务端收到：5f735249Tue Dec 30 16:55:05 CST 2014 1
    21.  
    22. 服务端收到：5f735249Tue Dec 30 16:55:05 CST 2014 1
    23.  
    24. 服务端收到：5f735249Tue Dec 30 16:55:05 CST 2014 1
    25.  
    26. 服务端收到：5f735249Tue Dec 30 16:55:05 CST 2014 1
    27.  
    28. 服务端收到：defa23d9Tue Dec 30 16:55:10 CST 2014 群号：5360692
    29.  
    30. ---------------------------------------------

基于Netty5.0入门案例六之NettyServer群发消息


联系
我们