作者：小傅哥
部落格：https://bugstack.cn
沉澱、分享、成長，讓自己和他人都能有所收獲！
前言介紹
本章節我們模仿微信聊天頁面，開發一個基于Netty搭建WebSocket通信案例。Netty的應用方面非常廣；聊天、MQ、RPC、資料等等，在5G到來的時候更加需要大量資料傳輸，Netty的應用也會更加廣闊。
- 這個案例使用SpringBoot+Netty+WebSocket搭建功能。
- 使用Netty提供的HttpServerCodec、HttpObjectAggregator、ChunkedWriteHandler進行編碼解碼處理。
- 通信邏輯盡可能簡化到隻了解根本，便于後續個人應用及開發的拓展。 用戶端連結成功後，向服務端發送請求擷取個人資訊，也可以拓展為登入請求。擷取個人資訊後，就可以知道差異化展示消息到頁面。
開發環境
- jdk1.8【jdk1.7以下隻能部分支援netty】
- Netty4.1.36.Final【netty3.x 4.x 5每次的變化較大，接口類名也随着變化】
- jquery.min.js、jquery.serialize-object.min.js
代碼示例
itstack-demo-netty-2-05
└── src
├── main
│ ├── java
│ │ └── org.itstack.demo.netty
│ │ ├── domain
│ │ │ ├── ClientMsgProtocol.java
│ │ │ └── ServerMsgProtocol.java
│ │ ├── server
│ │ │ ├── MyChannelInitializer.java
│ │ │ ├── MyServerHandler.java
│ │ │ └── NettyServer.java
│ │ ├── util
│ │ │ ├── ChannelHandler.java
│ │ │ └── MsgUtil.java
│ │ └── web
│ │ ├── NettyApplication.java
│ │ └── NettyController.java
│ └── resources
│ │ └── application.yml
│ └── webapp
│ ├── res
│ └── WEB-INF
│ └── index.jsp
│
└── test
└── java
└── org.itstack.demo.test
├── ApiTest.java
├── NettyClientTest.java
└── NettyServerTest.java
示範部分重點代碼塊，完整代碼下載下傳關注公衆号；bugstack蟲洞棧
server/MyChannelInitializer.java *websocket處理協定
/**
* 消息傳輸協定
* 蟲洞棧：https://bugstack.cn
* Create by fuzhengwei on @2019
*/
public class MyChannelInitializer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel channel) {
channel.pipeline().addLast("http-codec", new HttpServerCodec());
channel.pipeline().addLast("aggregator", new HttpObjectAggregator(65536));
channel.pipeline().addLast("http-chunked", new ChunkedWriteHandler());
// 在管道中添加我們自己的接收資料實作方法
channel.pipeline().addLast(new MyServerHandler());
}
}
server/MyServerHandler.java *處理websocket消息資訊
/**
* 消息傳輸協定
* 蟲洞棧：https://bugstack.cn
* Create by fuzhengwei on @2019
*/
public class MyServerHandler extends ChannelInboundHandlerAdapter {
private Logger logger = LoggerFactory.getLogger(MyServerHandler.class);
private WebSocketServerHandshaker handshaker;
/**
* 當用戶端主動連結服務端的連結後，這個通道就是活躍的了。也就是用戶端與服務端建立了通信通道并且可以傳輸資料
*/
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
SocketChannel channel = (SocketChannel) ctx.channel();
logger.info("連結報告開始");
logger.info("連結報告資訊：有一用戶端連結到本服務端");
logger.info("連結報告IP:{}", channel.localAddress().getHostString());
logger.info("連結報告Port:{}", channel.localAddress().getPort());
logger.info("連結報告完畢");
ChannelHandler.channelGroup.add(ctx.channel());
}
/**
* 當用戶端主動斷開服務端的連結後，這個通道就是不活躍的。也就是說用戶端與服務端的關閉了通信通道并且不可以傳輸資料
*/
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
logger.info("用戶端斷開連結{}", ctx.channel().localAddress().toString());
ChannelHandler.channelGroup.remove(ctx.channel());
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
//http
if (msg instanceof FullHttpRequest) {
FullHttpRequest httpRequest = (FullHttpRequest) msg;
if (!httpRequest.decoderResult().isSuccess()) {
DefaultFullHttpResponse httpResponse = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.BAD_REQUEST);
// 傳回應答給用戶端
if (httpResponse.status().code() != 200) {
ByteBuf buf = Unpooled.copiedBuffer(httpResponse.status().toString(), CharsetUtil.UTF_8);
httpResponse.content().writeBytes(buf);
buf.release();
}
// 如果是非Keep-Alive，關閉連接配接
ChannelFuture f = ctx.channel().writeAndFlush(httpResponse);
if (httpResponse.status().code() != 200) {
f.addListener(ChannelFutureListener.CLOSE);
}
return;
}
WebSocketServerHandshakerFactory wsFactory = new WebSocketServerHandshakerFactory("ws:/" + ctx.channel() + "/websocket", null, false);
handshaker = wsFactory.newHandshaker(httpRequest);
if (null == handshaker) {
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(ctx.channel());
} else {
handshaker.handshake(ctx.channel(), httpRequest);
}
return;
}
//ws
if (msg instanceof WebSocketFrame) {
WebSocketFrame webSocketFrame = (WebSocketFrame) msg;
//關閉請求
if (webSocketFrame instanceof CloseWebSocketFrame) {
handshaker.close(ctx.channel(), (CloseWebSocketFrame) webSocketFrame.retain());
return;
}
//ping請求
if (webSocketFrame instanceof PingWebSocketFrame) {
ctx.channel().write(new PongWebSocketFrame(webSocketFrame.content().retain()));
return;
}
//隻支援文本格式，不支援二進制消息
if (!(webSocketFrame instanceof TextWebSocketFrame)) {
throw new Exception("僅支援文本格式");
}
String request = ((TextWebSocketFrame) webSocketFrame).text();
System.out.println("服務端收到：" + request);
ClientMsgProtocol clientMsgProtocol = JSON.parseObject(request, ClientMsgProtocol.class);
//1請求個人資訊
if (1 == clientMsgProtocol.getType()) {
ctx.channel().writeAndFlush(MsgUtil.buildMsgOwner(ctx.channel().id().toString()));
return;
}
//群發消息
if (2 == clientMsgProtocol.getType()) {
TextWebSocketFrame textWebSocketFrame = MsgUtil.buildMsgAll(ctx.channel().id().toString(), clientMsgProtocol.getMsgInfo());
ChannelHandler.channelGroup.writeAndFlush(textWebSocketFrame);
}
}
}
/**
* 抓住異常，當發生異常的時候，可以做一些相應的處理，比如列印日志、關閉連結
*/
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
ctx.close();
logger.info("異常資訊：\r\n" + cause.getMessage());
}
}
util/MsgUtil.java *消息建構工具類
/**
* 消息傳輸協定
* 蟲洞棧：https://bugstack.cn
* Create by fuzhengwei on @2019
*/
public class MsgUtil {
public static TextWebSocketFrame buildMsgAll(String channelId, String msgInfo) {
//模拟頭像
int i = Math.abs(channelId.hashCode()) % 10;
ServerMsgProtocol msg = new ServerMsgProtocol();
msg.setType(2); //連結資訊;1自發資訊、2群發消息
msg.setChannelId(channelId);
msg.setUserHeadImg("head" + i + ".jpg");
msg.setMsgInfo(msgInfo);
return new TextWebSocketFrame(JSON.toJSONString(msg));
}
public static TextWebSocketFrame buildMsgOwner(String channelId) {
ServerMsgProtocol msg = new ServerMsgProtocol();
msg.setType(1); //連結資訊;1連結資訊、2消息資訊
msg.setChannelId(channelId);
return new TextWebSocketFrame(JSON.toJSONString(msg));
}
}
resources/application.yml *基礎配置資訊，包括了；應用端口、netty服務端端口等
server:
port: 8080
netty:
host: 127.0.0.1
port: 7397
spring:
mvc:
view:
prefix: /WEB-INF/
suffix: .jsp
WEB-INF/index.jsp *模仿微信聊天界面
<!-- left -->
<div style="width:60px; height:667px; background-color:#2D2B2A; float:left;">
<!-- 頭像 -->
<div style="width:35px; height:35px; margin:0 auto; margin-top:19px; margin-left:12px; float:left; border:1px solid #666666;border-radius:3px;-moz-border-radius:3px;">
<img src="res/img/bugstack.png" width="35px" height="35px"/>
</div>
<!-- 聊天 -->
<div style="width:28px; height:28px; margin:0 auto; margin-top:25px; margin-left:16px; float:left;">
<img src="res/img/chat.png" width="28px" height="28px"/>
</div>
<!-- 好友 -->
<div style="width:28px; height:28px; margin:0 auto; margin-top:20px; margin-left:16px; float:left;">
<img src="res/img/friend.png" width="28px" height="28px"/>
</div>
<!-- 收藏 -->
<div style="width:28px; height:28px; margin:0 auto; margin-top:20px; margin-left:16px; float:left;">
<img src="res/img/collection.png" width="28px" height="28px"/>
</div>
<!-- 設定 -->
<div style="width:20px; height:20px; margin:0 auto; margin-left:20px; float:left; position:absolute;bottom:0; margin-bottom:12px;">
<img src="res/img/set.png" width="20px" height="20px"/>
</div>
</div>
<!-- center -->
<div style="width:250px; height:667px; background-color:#EBE9E8; float:left;">
<div style=" background-image:url(res/img/search.png); background-repeat:no-repeat;margin:0 auto; margin-top:25px; padding-top:5px; padding-bottom:5px; width:210px; background-color:#DBD9D8;border-radius:3px;-moz-border-radius:3px; float:left; margin-left:20px; font-size:12px; color:#333333;text-indent:27px;">
http://bugstack.cn
</div>
<!-- friendList -->
<div id="friendList" style="float:left; margin-top:5px;">
<div style="width:250px; height:65px;">
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head1.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">哪咤寶</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">付政委：[圖檔]</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#C9C7C6;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head2.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">bugstack蟲洞棧</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">北京程式猿-小白：netty開發..</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head3.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">鹹魚江湖</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">背包沖：情人節沒禮物，不存..</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head4.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">整條街最靓</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">公司-老闆：[檔案]下個Q的KPI</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head5.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">Sniper</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">Sniper：雨後天晴寫下，年華..</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head7.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">星星點燈照亮我的家門</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">王老闆：不吹牛的說我家77套..</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head8.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">詹姆斯·高斯林</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">詹姆斯·高斯林：我所說的都關..</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head9.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">叮褲貓</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">叮褲貓：那還第一次見</td>
</tr>
</table>
<table style="width:240px; height:60px; margin:0 auto; margin-top:2px; background-color:#E5E5E5;">
<tr>
<td rowspan="2" width="50"><img src="res/img/head10.jpg" width="50px" height="50px" style="border-radius:3px;-moz-border-radius:3px;"/></td>
<td style="color:#333333; text-indent:5px; font-size:12px; vertical-align:bottom; font-weight:bolder;">背鍋沖</td>
</tr>
<tr>
<td style="color:#999999; text-indent:5px; font-size:10px;">背鍋沖：大樹說的，不讓去。</td>
</tr>
</table>
</div>
</div>
</div>
... ...
測試結果
啟動SpringBoot Netty會随着啟動
打開網頁websocket用戶端；http://localhost:8080/index
服務端執行結果
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.0.4.RELEASE)
2019-08-04 19:44:59.132 INFO 9208 --- [ main] o.i.demo.netty.web.NettyApplication : Starting NettyApplication on JRA1W11T0247 with PID 9208 (E:\itstack\GIT\itstack.org\itstack-demo-netty\itstack-demo-netty-2-05\target\classes started by fuzhengwei1 in E:\itstack\GIT\itstack.org\itstack-demo-netty\itstack-demo-netty-2-05)
2019-08-04 19:44:59.138 INFO 9208 --- [ main] o.i.demo.netty.web.NettyApplication : No active profile set, falling back to default profiles: default
2019-08-04 19:44:59.437 INFO 9208 --- [ main] ConfigServletWebServerApplicationContext : Refreshing org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@32cc499f: startup date [Sun Aug 04 19:44:59 CST 2019]; root of context hierarchy
2019-08-04 19:45:00.702 INFO 9208 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8080 (http)
2019-08-04 19:45:00.738 INFO 9208 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
2019-08-04 19:45:00.738 INFO 9208 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet Engine: Apache Tomcat/8.5.32
2019-08-04 19:45:00.748 INFO 9208 --- [ost-startStop-1] o.a.catalina.core.AprLifecycleListener : The APR based Apache Tomcat Native library which allows optimal performance in production environments was not found on the java.library.path: [C:\Program Files\Java\jdk1.8.0_45\bin;C:\windows\Sun\Java\bin;C:\windows\system32;C:\windows;C:\ProgramData\Oracle\Java\javapath;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\Intel\iCLS Client\;C:\Program Files\Intel\iCLS Client\;C:\windows\system32;C:\windows;C:\windows\System32\Wbem;C:\windows\System32\WindowsPowerShell\v1.0\;C:\Program Files\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files\Intel\Intel(R) Management Engine Components\IPT;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\IPT;C:\Program Files\Java\jdk1.8.0_45/bin;C:\Program Files\Java\jdk1.8.0_45/jre/bin;D:\Program Files\SlikSvn\bin;D:\Program Files\TortoiseSVN\bin;D:\Program Files (x86)\apache-maven-2.2.1\bin;D:\Program Files\TortoiseGit\bin;D:\Program Files\nodejs\;D:\Program Files (x86)\SSH Communications Security\SSH Secure Shell;C:\Users\fuzhengwei1\AppData\Roaming\npm;;.]
2019-08-04 19:45:00.985 INFO 9208 --- [ost-startStop-1] org.apache.jasper.servlet.TldScanner : At least one JAR was scanned for TLDs yet contained no TLDs. Enable debug logging for this logger for a complete list of JARs that were scanned but no TLDs were found in them. Skipping unneeded JARs during scanning can improve startup time and JSP compilation time.
2019-08-04 19:45:00.994 INFO 9208 --- [ost-startStop-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
2019-08-04 19:45:00.997 INFO 9208 --- [ost-startStop-1] o.s.web.context.ContextLoader : Root WebApplicationContext: initialization completed in 1560 ms
2019-08-04 19:45:01.082 INFO 9208 --- [ost-startStop-1] o.s.b.w.servlet.ServletRegistrationBean : Servlet dispatcherServlet mapped to [/]
2019-08-04 19:45:01.086 INFO 9208 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'characterEncodingFilter' to: [/*]
2019-08-04 19:45:01.086 INFO 9208 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'hiddenHttpMethodFilter' to: [/*]
2019-08-04 19:45:01.086 INFO 9208 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'httpPutFormContentFilter' to: [/*]
2019-08-04 19:45:01.086 INFO 9208 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'requestContextFilter' to: [/*]
2019-08-04 19:45:01.334 INFO 9208 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**/favicon.ico] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2019-08-04 19:45:01.497 INFO 9208 --- [ main] s.w.s.m.m.a.RequestMappingHandlerAdapter : Looking for @ControllerAdvice: org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@32cc499f: startup date [Sun Aug 04 19:44:59 CST 2019]; root of context hierarchy
2019-08-04 19:45:01.578 INFO 9208 --- [ main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/index]}" onto public java.lang.String org.itstack.demo.netty.web.NettyController.index(org.springframework.ui.Model)
2019-08-04 19:45:01.581 INFO 9208 --- [ main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/error]}" onto public org.springframework.http.ResponseEntity<java.util.Map<java.lang.String, java.lang.Object>> org.springframework.boot.autoconfigure.web.servlet.error.BasicErrorController.error(javax.servlet.http.HttpServletRequest)
2019-08-04 19:45:01.582 INFO 9208 --- [ main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/error],produces=[text/html]}" onto public org.springframework.web.servlet.ModelAndView org.springframework.boot.autoconfigure.web.servlet.error.BasicErrorController.errorHtml(javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse)
2019-08-04 19:45:01.606 INFO 9208 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/webjars/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2019-08-04 19:45:01.606 INFO 9208 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2019-08-04 19:45:01.673 INFO 9208 --- [ main] o.s.b.a.w.s.WelcomePageHandlerMapping : Adding welcome page template: index
2019-08-04 19:45:01.771 INFO 9208 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Registering beans for JMX exposure on startup
2019-08-04 19:45:01.832 INFO 9208 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8080 (http) with context path ''
2019-08-04 19:45:01.836 INFO 9208 --- [ main] o.i.demo.netty.web.NettyApplication : Started NettyApplication in 3.205 seconds (JVM running for 6.314)
2019-08-04 19:45:02.002 INFO 9208 --- [ main] o.itstack.demo.netty.server.NettyServer : itstack-demo-netty server start done. {關注公衆号：bugstack蟲洞棧，擷取源碼}
2019-08-04 19:45:04.850 INFO 9208 --- [nio-8080-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring FrameworkServlet 'dispatcherServlet'
2019-08-04 19:45:04.850 INFO 9208 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet : FrameworkServlet 'dispatcherServlet': initialization started
2019-08-04 19:45:04.867 INFO 9208 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet : FrameworkServlet 'dispatcherServlet': initialization completed in 17 ms
2019-08-04 19:45:06.137 INFO 9208 --- [ntLoopGroup-3-1] o.i.demo.netty.server.MyServerHandler : 連結報告開始
2019-08-04 19:45:06.137 INFO 9208 --- [ntLoopGroup-3-1] o.i.demo.netty.server.MyServerHandler : 連結報告資訊：有一用戶端連結到本服務端
2019-08-04 19:45:06.137 INFO 9208 --- [ntLoopGroup-3-1] o.i.demo.netty.server.MyServerHandler : 連結報告IP:127.0.0.1
2019-08-04 19:45:06.137 INFO 9208 --- [ntLoopGroup-3-1] o.i.demo.netty.server.MyServerHandler : 連結報告Port:7397
2019-08-04 19:45:06.137 INFO 9208 --- [ntLoopGroup-3-1] o.i.demo.netty.server.MyServerHandler : 連結報告完畢
服務端收到：{"type":1,"msgInfo":"請求個人資訊"}
2019-08-04 19:45:10.590 INFO 9208 --- [ntLoopGroup-3-2] o.i.demo.netty.server.MyServerHandler : 連結報告開始
2019-08-04 19:45:10.590 INFO 9208 --- [ntLoopGroup-3-2] o.i.demo.netty.server.MyServerHandler : 連結報告資訊：有一用戶端連結到本服務端
2019-08-04 19:45:10.591 INFO 9208 --- [ntLoopGroup-3-2] o.i.demo.netty.server.MyServerHandler : 連結報告IP:127.0.0.1
2019-08-04 19:45:10.591 INFO 9208 --- [ntLoopGroup-3-2] o.i.demo.netty.server.MyServerHandler : 連結報告Port:7397
2019-08-04 19:45:10.591 INFO 9208 --- [ntLoopGroup-3-2] o.i.demo.netty.server.MyServerHandler : 連結報告完畢
服務端收到：{"type":1,"msgInfo":"請求個人資訊"}
2019-08-04 19:45:12.374 INFO 9208 --- [ntLoopGroup-3-3] o.i.demo.netty.server.MyServerHandler : 連結報告開始
2019-08-04 19:45:12.374 INFO 9208 --- [ntLoopGroup-3-3] o.i.demo.netty.server.MyServerHandler : 連結報告資訊：有一用戶端連結到本服務端
2019-08-04 19:45:12.374 INFO 9208 --- [ntLoopGroup-3-3] o.i.demo.netty.server.MyServerHandler : 連結報告IP:127.0.0.1
2019-08-04 19:45:12.374 INFO 9208 --- [ntLoopGroup-3-3] o.i.demo.netty.server.MyServerHandler : 連結報告Port:7397
2019-08-04 19:45:12.374 INFO 9208 --- [ntLoopGroup-3-3] o.i.demo.netty.server.MyServerHandler : 連結報告完畢
服務端收到：{"type":1,"msgInfo":"請求個人資訊"}
服務端收到：{"type":2,"msgInfo":"你好在嗎，我是bugstack蟲洞棧的作者，付政委。"}
服務端收到：{"type":2,"msgInfo":"我在的，我已經關注了這個公衆号；bugstack蟲洞棧，裡面的很多知識都是幹貨，真的能幫助到我的學習，他還有部落格網站；https://bugstack.cn 感謝作者！讓我學習到這麼多知識。"}
服務端收到：{"type":2,"msgInfo":"呀和！原來這麼多人在群裡。哈哈哈，大家一起學習真好。我的頭像是随機的哦，你們的也是。像公告的資訊一樣；不平凡的歲月終究來自你每日不停歇的刻苦拼搏，猶如；承遇朝霞，年少正恰，整裝戎馬，刻印風華。"}
Process finished with exit code -1
微信搜尋「bugstack蟲洞棧」公衆号，關注後回複「Netty專題案例」擷取本文源碼&更多原創專題案例！