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

perf[net]: 简化代码

Browse Source
This commit is contained in:
jaysunxiao
2021-08-12 17:28:31 +08:00
parent 0acab58e36
commit 6984444fc3
4 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/test/java/com/zfoo/net/core/csharp/ServerTest.java
+2 -3
View File
@@ -13,7 +13,6 @@
package com.zfoo.net.core.csharp;
import com.zfoo.net.NetContext;
import com.zfoo.net.core.tcp.TcpServer;
import com.zfoo.net.session.SessionUtils;
import com.zfoo.util.ThreadUtils;
@@ -36,8 +35,8 @@ public class ServerTest {
SessionUtils.printSessionInfo();
// startClient1();
var server0 = new TcpServer(HostAndPort.valueOf(NetContext.getConfigManager().getLocalConfig().getHostConfig().getAddressMap().get("server0")));
server0.start();
var server = new TcpServer(HostAndPort.valueOf("127.0.0.1:9000"));
server.start();
ThreadUtils.sleep(Long.MAX_VALUE);
}
net/src/test/java/com/zfoo/net/core/gateway/GatewayTest.java
+2 -2
View File
@@ -67,7 +67,7 @@ public class GatewayTest {
public void startGateway() {
var context = new ClassPathXmlApplicationContext("gateway/gateway_consistent_session_config.xml");
SessionUtils.printSessionInfo();
var gatewayServer = new GatewayServer(HostAndPort.valueOf(NetContext.getConfigManager().getLocalConfig().getHostConfig().getAddressMap().get("server0")), null);
var gatewayServer = new GatewayServer(HostAndPort.valueOf("127.0.0.1:9000"), null);
gatewayServer.start();
ThreadUtils.sleep(Long.MAX_VALUE);
}
@@ -77,7 +77,7 @@ public class GatewayTest {
var context = new ClassPathXmlApplicationContext("gateway/gateway_client_config.xml");
SessionUtils.printSessionInfo();
var client = new TcpClient(HostAndPort.valueOf(NetContext.getConfigManager().getLocalConfig().getHostConfig().getAddressMap().get("server0")));
var client = new TcpClient(HostAndPort.valueOf("127.0.0.1:9000"));
var session = client.start();
var executorSize = Runtime.getRuntime().availableProcessors() * 2;
net/src/test/java/com/zfoo/net/core/udp/client/UdpClientTest.java
+1 -1
View File
@@ -32,7 +32,7 @@ public class UdpClientTest {
@Test
public void startClientTest() {
var context = new ClassPathXmlApplicationContext("config.xml");
var hostAndPort = HostAndPort.valueOf(NetContext.getConfigManager().getLocalConfig().getHostConfig().getAddressMap().get("server0"));
var hostAndPort = HostAndPort.valueOf("127.0.0.1:9000");
var client = new UdpClient(hostAndPort);
var session = client.start();
net/src/test/java/com/zfoo/net/core/udp/server/UdpServerTest.java
+1 -2
View File
@@ -12,7 +12,6 @@
package com.zfoo.net.core.udp.server;
import com.zfoo.net.NetContext;
import com.zfoo.net.core.udp.UdpServer;
import com.zfoo.util.ThreadUtils;
import com.zfoo.util.net.HostAndPort;
@@ -30,7 +29,7 @@ public class UdpServerTest {
@Test
public void startServerTest() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("config.xml");
var server = new UdpServer(HostAndPort.valueOf(NetContext.getConfigManager().getLocalConfig().getHostConfig().getAddressMap().get("server0")));
var server = new UdpServer(HostAndPort.valueOf("127.0.0.1:9000"));
server.start();
ThreadUtils.sleep(Long.MAX_VALUE);
}