From b45189115b657dfa515301bf2ab3294ca80c1d9a Mon Sep 17 00:00:00 2001 From: jaysunxiao Date: Tue, 5 Jul 2022 21:11:10 +0800 Subject: [PATCH] =?UTF-8?q?ref[net]:=20=E9=87=8D=E5=91=BD=E5=90=8DJProtobu?= =?UTF-8?q?fTcpServer?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../{JProtobufTpcServer.java => JProtobufTcpServer.java} | 4 ++-- .../net/core/jprotobuf/server/JProtobufTcpServerTest.java | 4 ++-- .../java/com/zfoo/net/core/tcpAsync/client/TcpClientTest.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) rename net/src/main/java/com/zfoo/net/core/jprotobuf/{JProtobufTpcServer.java => JProtobufTcpServer.java} (94%) 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)); } );