基於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));
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. ---------------------------------------------