Skip to content

Commit 55d1b12

Browse files
author
YunaiV
committed
Netty 入门示例 - 增加注释
1 parent 05ec049 commit 55d1b12

40 files changed

+132
-56
lines changed

‎README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@
5555

5656
## RPC 开发
5757

58+
* [《芋道 Spring Boot Netty 入门》](http://www.iocoder.cn/Spring-Boot/Netty/?github) 对应 [lab-67](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-67)
5859
* [《芋道 Spring Boot Dubbo 入门》](http://www.iocoder.cn/Spring-Boot/Dubbo/?github) 对应 [lab-30](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-30)
5960
* [《芋道 Spring Boot 声明式调用 Feign 入门》](http://www.iocoder.cn/Spring-Boot/Feign/?github) 对应 [lab-58](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-58)
6061
* [《芋道 Spring Boot gRPC 入门》](http://www.iocoder.cn/Spring-Boot/gRPC/?github) 对应 [lab-64](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-64)

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/client/NettyClient.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,12 +44,13 @@ public class NettyClient {
4444
private volatile Channel channel;
4545

4646
/**
47-
* 启动 Netty Server
47+
* 启动 Netty Client
4848
*/
4949
@PostConstruct
5050
public void start() throws InterruptedException {
5151
// 创建 Bootstrap 对象，用于 Netty Client 启动
5252
Bootstrap bootstrap = new Bootstrap();
53+
// 设置 Bootstrap 的各种属性。
5354
bootstrap.group(eventGroup) // 设置一个 EventLoopGroup 对象
5455
.channel(NioSocketChannel.class) // 指定 Channel 为客户端 NioSocketChannel
5556
.remoteAddress(serverHost, serverPort) // 指定链接服务器的地址

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/client/handler/NettyClientHandler.java

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.client.handler;
22

33
import cn.iocoder.springboot.lab67.nettyclientdemo.client.NettyClient;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.codec.Invocation;
54
import cn.iocoder.springboot.lab67.nettyclientdemo.message.heartbeat.HeartbeatRequest;
5+
import cn.iocoder.springboot.lab67.nettycommondemo.codec.Invocation;
66
import io.netty.channel.ChannelFutureListener;
77
import io.netty.channel.ChannelHandler;
88
import io.netty.channel.ChannelHandlerContext;
@@ -22,19 +22,6 @@ public class NettyClientHandler extends ChannelInboundHandlerAdapter {
2222
@Autowired
2323
private NettyClient nettyClient;
2424

25-
@Override
26-
public void userEventTriggered(ChannelHandlerContext ctx, Object event) throws Exception {
27-
// 空闲时，向服务端发起一次心跳
28-
if (event instanceof IdleStateEvent) {
29-
HeartbeatRequest heartbeatRequest = new HeartbeatRequest();
30-
ctx.writeAndFlush(new Invocation(HeartbeatRequest.TYPE, heartbeatRequest))
31-
.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
32-
logger.info("[userEventTriggered][发起一次心跳]");
33-
} else {
34-
super.userEventTriggered(ctx, event);
35-
}
36-
}
37-
3825
@Override
3926
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
4027
// 发起重连
@@ -50,4 +37,17 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
5037
ctx.channel().close();
5138
}
5239

40+
@Override
41+
public void userEventTriggered(ChannelHandlerContext ctx, Object event) throws Exception {
42+
// 空闲时，向服务端发起一次心跳
43+
if (event instanceof IdleStateEvent) {
44+
logger.info("[userEventTriggered][发起一次心跳]");
45+
HeartbeatRequest heartbeatRequest = new HeartbeatRequest();
46+
ctx.writeAndFlush(new Invocation(HeartbeatRequest.TYPE, heartbeatRequest))
47+
.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
48+
} else {
49+
super.userEventTriggered(ctx, event);
50+
}
51+
}
52+
5353
}

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/client/handler/NettyClientHandlerInitializer.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,11 @@
22

33
import cn.iocoder.springboot.lab67.nettycommondemo.codec.InvocationDecoder;
44
import cn.iocoder.springboot.lab67.nettycommondemo.codec.InvocationEncoder;
5-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageDispatcher;
5+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageDispatcher;
66
import io.netty.channel.Channel;
77
import io.netty.channel.ChannelInitializer;
88
import io.netty.handler.timeout.IdleStateHandler;
9+
import io.netty.handler.timeout.ReadTimeoutHandler;
910
import org.springframework.beans.factory.annotation.Autowired;
1011
import org.springframework.stereotype.Component;
1112

@@ -28,6 +29,7 @@ protected void initChannel(Channel ch) {
2829
ch.pipeline()
2930
// 空闲检测
3031
.addLast(new IdleStateHandler(READ_TIMEOUT_SECONDS, 0, 0))
32+
.addLast(new ReadTimeoutHandler(3 * READ_TIMEOUT_SECONDS))
3133
// 编码器
3234
.addLast(new InvocationEncoder())
3335
// 解码器

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/config/NettyClientConfig.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.config;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageDispatcher;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandlerContainer;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageDispatcher;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandlerContainer;
55
import org.springframework.context.annotation.Bean;
66
import org.springframework.context.annotation.Configuration;
77

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/auth/AuthRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.auth;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 用户认证请求

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/auth/AuthResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.auth;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 用户认证响应

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/chat/ChatRedirectToUserRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 转发消息给一个用户的 Message

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/chat/ChatSendResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 聊天发送消息结果的 Response

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/chat/ChatSendToAllRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 发送给所有人的群聊消息的 Message

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/chat/ChatSendToOneRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 发送给指定人的私聊消息 Request

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/heartbeat/HeartbeatRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.heartbeat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 消息 - 心跳请求

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/message/heartbeat/HeartbeatResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.message.heartbeat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 消息 - 心跳响应

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/messagehandler/auth/AuthResponseHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.messagehandler.auth;
22

33
import cn.iocoder.springboot.lab67.nettyclientdemo.message.auth.AuthResponse;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandler;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandler;
55
import io.netty.channel.Channel;
66
import org.slf4j.Logger;
77
import org.slf4j.LoggerFactory;

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/messagehandler/chat/ChatRedirectToUserRequestHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.messagehandler.chat;
22

33
import cn.iocoder.springboot.lab67.nettyclientdemo.message.chat.ChatRedirectToUserRequest;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandler;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandler;
55
import io.netty.channel.Channel;
66
import org.slf4j.Logger;
77
import org.slf4j.LoggerFactory;

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/messagehandler/chat/ChatSendResponseHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.messagehandler.chat;
22

33
import cn.iocoder.springboot.lab67.nettyclientdemo.message.chat.ChatSendResponse;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandler;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandler;
55
import io.netty.channel.Channel;
66
import org.slf4j.Logger;
77
import org.slf4j.LoggerFactory;

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-client/src/main/java/cn/iocoder/springboot/lab67/nettyclientdemo/messagehandler/heartbeat/HeartbeatResponseHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyclientdemo.messagehandler.heartbeat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandler;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandler;
44
import cn.iocoder.springboot.lab67.nettyclientdemo.message.heartbeat.HeartbeatResponse;
55
import io.netty.channel.Channel;
66
import org.slf4j.Logger;

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-common/src/main/java/cn/iocoder/springboot/lab67/nettycommondemo/codec/Invocation.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,19 +1,23 @@
11
package cn.iocoder.springboot.lab67.nettycommondemo.codec;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44
import com.alibaba.fastjson.JSON;
55

6+
/**
7+
* 通信协议的消息体
8+
*/
69
public class Invocation {
710

811
/**
912
* 类型
1013
*/
1114
private String type;
1215
/**
13-
* 消息
16+
* 消息，JSON 格式
1417
*/
1518
private String message;
1619

20+
// 空构造方法
1721
public Invocation() {
1822
}
1923

@@ -52,4 +56,5 @@ public String toString() {
5256
", message='" + message + '\'' +
5357
'}';
5458
}
59+
5560
}

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-common/src/main/java/cn/iocoder/springboot/lab67/nettycommondemo/codec/InvocationDecoder.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,9 @@
1010

1111
import java.util.List;
1212

13+
/**
14+
* {@link Invocation} 解码器
15+
*/
1316
public class InvocationDecoder extends ByteToMessageDecoder {
1417

1518
private Logger logger = LoggerFactory.getLogger(getClass());

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-common/src/main/java/cn/iocoder/springboot/lab67/nettycommondemo/codec/InvocationEncoder.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,9 @@
77
import org.slf4j.Logger;
88
import org.slf4j.LoggerFactory;
99

10+
/**
11+
* {@link Invocation} 编码器
12+
*/
1013
public class InvocationEncoder extends MessageToByteEncoder<Invocation> {
1114

1215
private Logger logger = LoggerFactory.getLogger(getClass());

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-common/src/main/java/cn/iocoder/springboot/lab67/nettycommondemo/dispatcher/MessageDispatcher.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,9 @@ public class MessageDispatcher extends SimpleChannelInboundHandler<Invocation> {
1717
protected void channelRead0(ChannelHandlerContext ctx, Invocation invocation) {
1818
// 获得 type 对应的 MessageHandler 处理器
1919
MessageHandler messageHandler = messageHandlerContainer.getMessageHandler(invocation.getType());
20-
// 解析消息
20+
// 获得 MessageHandler 处理器 的消息类
2121
Class<? extends Message> messageClass = MessageHandlerContainer.getMessageClass(messageHandler);
22+
// 解析消息
2223
Message message = JSON.parseObject(invocation.getMessage(), messageClass);
2324
// 执行逻辑
2425
// noinspection unchecked

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-common/src/main/java/cn/iocoder/springboot/lab67/nettycommondemo/dispatcher/MessageHandlerContainer.java

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,15 +33,27 @@ public void afterPropertiesSet() throws Exception {
3333
logger.info("[afterPropertiesSet][消息处理器数量：{}]", handlers.size());
3434
}
3535

36-
protected MessageHandler getMessageHandler(String type) {
36+
/**
37+
* 获得类型对应的 MessageHandler
38+
*
39+
* @param type 类型
40+
* @return MessageHandler
41+
*/
42+
MessageHandler getMessageHandler(String type) {
3743
MessageHandler handler = handlers.get(type);
3844
if (handler == null) {
3945
throw new IllegalArgumentException(String.format("类型(%s) 找不到匹配的 MessageHandler 处理器", type));
4046
}
4147
return handler;
4248
}
4349

44-
public static Class<? extends Message> getMessageClass(MessageHandler handler) {
50+
/**
51+
* 获得 MessageHandler 处理的消息类
52+
*
53+
* @param handler 处理器
54+
* @return 消息类
55+
*/
56+
static Class<? extends Message> getMessageClass(MessageHandler handler) {
4557
// 获得 Bean 对应的 Class 类名。因为有可能被 AOP 代理过。
4658
Class<?> targetClass = AopProxyUtils.ultimateTargetClass(handler);
4759
// 获得接口的 Type 数组

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/config/NettyServerConfig.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.config;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageDispatcher;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandlerContainer;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageDispatcher;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandlerContainer;
55
import org.springframework.context.annotation.Bean;
66
import org.springframework.context.annotation.Configuration;
77

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/auth/AuthRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.auth;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 用户认证请求

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/auth/AuthResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.auth;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 用户认证响应

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/chat/ChatRedirectToUserRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 转发消息给一个用户的 Message

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/chat/ChatSendResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 聊天发送消息结果的 Response

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/chat/ChatSendToAllRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 发送给所有人的群聊消息的 Message

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/chat/ChatSendToOneRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.chat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 发送给指定人的私聊消息 Request

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/heartbeat/HeartbeatRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.heartbeat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 消息 - 心跳请求

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/message/heartbeat/HeartbeatResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.message.heartbeat;
22

3-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.Message;
3+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.Message;
44

55
/**
66
* 消息 - 心跳响应

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/messagehandler/auth/AuthRequestHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.messagehandler.auth;
22

33
import cn.iocoder.springboot.lab67.nettycommondemo.codec.Invocation;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandler;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandler;
55
import cn.iocoder.springboot.lab67.nettyserverdemo.message.auth.AuthRequest;
66
import cn.iocoder.springboot.lab67.nettyserverdemo.message.auth.AuthResponse;
77
import cn.iocoder.springboot.lab67.nettyserverdemo.server.NettyChannelManager;

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/messagehandler/chat/ChatSendToAllHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.messagehandler.chat;
22

33
import cn.iocoder.springboot.lab67.nettycommondemo.codec.Invocation;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandler;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandler;
55
import cn.iocoder.springboot.lab67.nettyserverdemo.message.chat.ChatSendResponse;
66
import cn.iocoder.springboot.lab67.nettyserverdemo.message.chat.ChatSendToAllRequest;
77
import cn.iocoder.springboot.lab67.nettyserverdemo.message.chat.ChatRedirectToUserRequest;

‎lab-67/lab-67-netty-demo/lab-67-netty-demo-server/src/main/java/cn/iocoder/springboot/lab67/nettyserverdemo/messagehandler/chat/ChatSendToOneHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package cn.iocoder.springboot.lab67.nettyserverdemo.messagehandler.chat;
22

33
import cn.iocoder.springboot.lab67.nettycommondemo.codec.Invocation;
4-
import cn.iocoder.springboot.lab67.nettycommondemo.dispacher.MessageHandler;
4+
import cn.iocoder.springboot.lab67.nettycommondemo.dispatcher.MessageHandler;
55
import cn.iocoder.springboot.lab67.nettyserverdemo.message.chat.ChatSendResponse;
66
import cn.iocoder.springboot.lab67.nettyserverdemo.message.chat.ChatSendToOneRequest;
77
import cn.iocoder.springboot.lab67.nettyserverdemo.message.chat.ChatRedirectToUserRequest;

0 commit comments

Comments
 (0)