diff --git a/net/src/main/java/com/zfoo/net/core/jprotobuf/JProtobufTpcServer.java b/net/src/main/java/com/zfoo/net/core/jprotobuf/JProtobufTcpServer.java similarity index 94% rename from net/src/main/java/com/zfoo/net/core/jprotobuf/JProtobufTpcServer.java rename to net/src/main/java/com/zfoo/net/core/jprotobuf/JProtobufTcpServer.java index d281ede8..dd324e64 100644 --- a/net/src/main/java/com/zfoo/net/core/jprotobuf/JProtobufTpcServer.java +++ b/net/src/main/java/com/zfoo/net/core/jprotobuf/JProtobufTcpServer.java @@ -26,9 +26,9 @@ import io.netty.handler.timeout.IdleStateHandler; * @author jaysunxiao * @version 3.0 */ -public class JProtobufTpcServer extends AbstractServer { +public class JProtobufTcpServer extends AbstractServer { - public JProtobufTpcServer(HostAndPort host) { + public JProtobufTcpServer(HostAndPort host) { super(host); } diff --git a/net/src/test/java/com/zfoo/net/core/jprotobuf/server/JProtobufTcpServerTest.java b/net/src/test/java/com/zfoo/net/core/jprotobuf/server/JProtobufTcpServerTest.java index 9d98d456..08588203 100644 --- a/net/src/test/java/com/zfoo/net/core/jprotobuf/server/JProtobufTcpServerTest.java +++ b/net/src/test/java/com/zfoo/net/core/jprotobuf/server/JProtobufTcpServerTest.java @@ -13,7 +13,7 @@ package com.zfoo.net.core.jprotobuf.server; -import com.zfoo.net.core.jprotobuf.JProtobufTpcServer; +import com.zfoo.net.core.jprotobuf.JProtobufTcpServer; import com.zfoo.util.ThreadUtils; import com.zfoo.util.net.HostAndPort; import org.junit.Ignore; @@ -31,7 +31,7 @@ public class JProtobufTcpServerTest { public void startServer() { var context = new ClassPathXmlApplicationContext("config.xml"); - var server = new JProtobufTpcServer(HostAndPort.valueOf("127.0.0.1:9000")); + var server = new JProtobufTcpServer(HostAndPort.valueOf("127.0.0.1:9000")); server.start(); ThreadUtils.sleep(Long.MAX_VALUE); diff --git a/net/src/test/java/com/zfoo/net/core/tcpAsync/client/TcpClientTest.java b/net/src/test/java/com/zfoo/net/core/tcpAsync/client/TcpClientTest.java index 082dd056..19db30cd 100644 --- a/net/src/test/java/com/zfoo/net/core/tcpAsync/client/TcpClientTest.java +++ b/net/src/test/java/com/zfoo/net/core/tcpAsync/client/TcpClientTest.java @@ -48,7 +48,7 @@ public class TcpClientTest { NetContext.getRouter().asyncAsk(session, ask, AsyncMessAnswer.class, null) .whenComplete(answer -> { - logger.info("同步请求收到结果[{}]", JsonUtils.object2String(answer)); + logger.info("异步请求收到结果[{}]", JsonUtils.object2String(answer)); } );