tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-21 08:27:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename[net]: rename TcpCodecHandler

Browse Source
This commit is contained in:
jaysunxiao
2021-07-01 11:28:49 +08:00
parent cdd2579377
commit 7bbb79f140
5 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/core/gateway/GatewayServer.java
+2 -2
View File
@@ -15,7 +15,7 @@ package com.zfoo.net.core.gateway;
import com.zfoo.net.core.AbstractServer;
import com.zfoo.net.handler.GatewayDispatcherHandler;
import com.zfoo.net.handler.codec.tcp.TcpPacketCodecHandler;
import com.zfoo.net.handler.codec.tcp.TcpCodecHandler;
import com.zfoo.net.handler.idle.ServerIdleHandler;
import com.zfoo.net.session.model.Session;
import com.zfoo.protocol.IPacket;
@@ -58,7 +58,7 @@ public class GatewayServer extends AbstractServer {
protected void initChannel(SocketChannel channel) {
channel.pipeline().addLast(new IdleStateHandler(0, 0, 180));
channel.pipeline().addLast(new ServerIdleHandler());
channel.pipeline().addLast(new TcpPacketCodecHandler());
channel.pipeline().addLast(new TcpCodecHandler());
channel.pipeline().addLast(new GatewayDispatcherHandler(packetFilter));
}
}
net/src/main/java/com/zfoo/net/core/tcp/TcpClient.java
+2 -2
View File
@@ -15,7 +15,7 @@ package com.zfoo.net.core.tcp;
import com.zfoo.net.core.AbstractClient;
import com.zfoo.net.handler.ClientDispatcherHandler;
import com.zfoo.net.handler.codec.tcp.TcpPacketCodecHandler;
import com.zfoo.net.handler.codec.tcp.TcpCodecHandler;
import com.zfoo.net.handler.idle.ClientIdleHandler;
import com.zfoo.util.net.HostAndPort;
import io.netty.channel.Channel;
@@ -44,7 +44,7 @@ public class TcpClient extends AbstractClient {
protected void initChannel(SocketChannel channel) {
channel.pipeline().addLast(new IdleStateHandler(0, 0, 60));
channel.pipeline().addLast(new ClientIdleHandler());
channel.pipeline().addLast(new TcpPacketCodecHandler());
channel.pipeline().addLast(new TcpCodecHandler());
channel.pipeline().addLast(new ClientDispatcherHandler());
}
}
net/src/main/java/com/zfoo/net/core/tcp/TcpServer.java
+2 -2
View File
@@ -15,7 +15,7 @@ package com.zfoo.net.core.tcp;
import com.zfoo.net.core.AbstractServer;
import com.zfoo.net.handler.ServerDispatcherHandler;
import com.zfoo.net.handler.codec.tcp.TcpPacketCodecHandler;
import com.zfoo.net.handler.codec.tcp.TcpCodecHandler;
import com.zfoo.net.handler.idle.ServerIdleHandler;
import com.zfoo.util.net.HostAndPort;
import io.netty.channel.ChannelInitializer;
@@ -43,7 +43,7 @@ public class TcpServer extends AbstractServer {
protected void initChannel(SocketChannel channel) {
channel.pipeline().addLast(new IdleStateHandler(0, 0, 180));
channel.pipeline().addLast(new ServerIdleHandler());
channel.pipeline().addLast(new TcpPacketCodecHandler());
channel.pipeline().addLast(new TcpCodecHandler());
channel.pipeline().addLast(new ServerDispatcherHandler());
}
}
net/src/main/java/com/zfoo/net/handler/codec/tcp/TcpPacketCodecHandler.java → net/src/main/java/com/zfoo/net/handler/codec/tcp/TcpCodecHandler.java
+2 -2
View File
@@ -35,9 +35,9 @@ import java.util.List;
* @author jaysunxiao
* @version 3.0
*/
public class TcpPacketCodecHandler extends ByteToMessageCodec<EncodedPacketInfo> {
public class TcpCodecHandler extends ByteToMessageCodec<EncodedPacketInfo> {
private static final Logger logger = LoggerFactory.getLogger(TcpPacketCodecHandler.class);
private static final Logger logger = LoggerFactory.getLogger(TcpCodecHandler.class);
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {
net/src/main/java/com/zfoo/net/handler/codec/websocket/WebSocketCodecHandler.java
+1 -2
View File
@@ -14,7 +14,6 @@
package com.zfoo.net.handler.codec.websocket;
import com.zfoo.net.NetContext;
import com.zfoo.net.handler.codec.tcp.TcpPacketCodecHandler;
import com.zfoo.net.packet.model.DecodedPacketInfo;
import com.zfoo.net.packet.model.EncodedPacketInfo;
import com.zfoo.net.packet.service.PacketService;
@@ -42,7 +41,7 @@ import java.util.List;
*/
public class WebSocketCodecHandler extends MessageToMessageCodec<WebSocketFrame, EncodedPacketInfo> {
private static final Logger logger = LoggerFactory.getLogger(TcpPacketCodecHandler.class);
private static final Logger logger = LoggerFactory.getLogger(WebSocketCodecHandler.class);
@Override
protected void decode(ChannelHandlerContext channelHandlerContext, WebSocketFrame webSocketFrame, List<Object> list) {