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

前言介绍:

    我们的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));
  28. // 基于指定字符串【换行符,这样功能等同于LineBasedFrameDecoder】
  29. // e.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, false, Delimiters.lineDelimiter()));
  30. // 基于最大长度
  31. // e.pipeline().addLast(new FixedLengthFrameDecoder(4));
  32. // 解码转String
  33. e.pipeline().addLast(new StringDecoder());
  34.  
  35. // 编码器 String
  36. e.pipeline().addLast(new StringEncoder());
  37. // 在管道中添加我们自己的接收数据实现方法
  38. e.pipeline().addLast(new MyServerHanlder());
  39.  
  40. }
  41.  
  42. }

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);
  17. }



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 {
  23. System.out.println(ctx.channel().localAddress().toString()+" channelActive");
  24. //添加到channelGroup 通道组
  25. MyChannelHandlerPool.channelGroup.add(ctx.channel());
  26. //通知您已经链接上客户端
  27. String str = "您已经开启与服务端链接"+" "+ctx.channel().id()+new Date()+" "+ctx.channel().localAddress();
  28. ctx.writeAndFlush(str);
  29. }
  30. /*
  31. * channelInactive
  32. *
  33. * channel 通道
  34. * Inactive 不活跃的
  35. *
  36. * 当客户端主动断开服务端的链接后,这个通道就是不活跃的。也就是说客户端与服务端的关闭了通信通道并且不可以传输数据
  37. *
  38. */
  39. public void channelInactive(ChannelHandlerContext ctx) throws Exception {
  40. // 从channelGroup中移除,当有客户端退出后,移除channel。
  41. MyChannelHandlerPool.channelGroup.remove(ctx.channel());
  42. System.out.println(ctx.channel().localAddress().toString()+" channelInactive");
  43. }
  44. /*
  45. * channelRead
  46. *
  47. * channel 通道
  48. * Read 读
  49. *
  50. * 简而言之就是从通道中读取数据,也就是服务端接收客户端发来的数据
  51. * 但是这个数据在不进行解码时它是ByteBuf类型的后面例子我们在介绍
  52. *
  53. */
  54. public void channelRead(ChannelHandlerContext ctx, Object msg)
  55. throws Exception {
  56. //注意此处已经不需要手工解码了
  57. System.out.println(ctx.channel().id()+""+new Date()+" "+msg);
  58. //通知您已经链接上客户端[给客户端穿回去的数据加个换行]
  59. String str = "服务端收到:"+ctx.channel().id()+new Date()+" "+msg+"\r\n";
  60. //收到信息后,群发给所有小伙伴
  61. MyChannelHandlerPool.channelGroup.writeAndFlush(str);
  62. }
  63. /*
  64. * channelReadComplete
  65. *
  66. * channel 通道
  67. * Read 读取
  68. * Complete 完成
  69. *
  70. * 在通道读取完成后会在这个方法里通知,对应可以做刷新操作
  71. * ctx.flush()
  72. *
  73. */
  74. public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
  75. ctx.flush();
  76. }
  77. /*
  78. * exceptionCaught
  79. *
  80. * exception 异常
  81. * Caught 抓住
  82. *
  83. * 抓住异常,当发生异常的时候,可以做一些相应的处理,比如打印日志、关闭链接
  84. *
  85. */
  86. public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
  87. throws Exception {
  88. ctx.close();
  89. System.out.println("异常信息:\r\n"+cause.getMessage());
  90. }
  91. }

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) {
  13. try {
  14. System.out.println("服务端开启等待客户端链接");
  15. new NettyServer().bing(7397);
  16. } catch (Exception e) {
  17. e.printStackTrace();
  18. }
  19. }
  20. public void bing(int port) throws Exception{
  21. EventLoopGroup bossGroup = new NioEventLoopGroup();
  22. EventLoopGroup workGroup = new NioEventLoopGroup();
  23. try {
  24. ServerBootstrap b = new ServerBootstrap();
  25. b.group(bossGroup, workGroup);
  26. b.channel(NioServerSocketChannel.class);
  27. b.option(ChannelOption.SO_BACKLOG, 1024);
  28. b.childHandler(new ChildChannelHandler());
  29. // 绑定端口
  30. ChannelFuture f = b.bind(port).sync();
  31. // 等待服务端监听端口关闭
  32. f.channel().closeFuture().sync();
  33. } finally {
  34. // 优雅的退出
  35. bossGroup.shutdownGracefully();
  36. workGroup.shutdownGracefully();
  37. }
  38. }
  39. }

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. ---------------------------------------------

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。