alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-16 10:25:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

【fix】init route ip

Browse Source
This commit is contained in:
wujiawei
2025-05-08 12:34:55 +08:00
parent 466faacb93
commit a3c88ffa9f
1 changed files with 85 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

85
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerProxySocket.java Normal file
View File

@ -0,0 +1,85 @@
package org.framework.lazy.cloud.network.heartbeat.server.init;
import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.protocol.route.ClientProxyRoute;
import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteContext;
import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteType;
import org.framework.lazy.cloud.network.heartbeat.protocol.route.ServerProxyRoute;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyClientVirtualRouteApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyServerVirtualRouteApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyServerPermeateServerMappingApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.virtual.route.LazyNettyClientVirtualRouteQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.virtual.route.LazyNettyServerVirtualRouteQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientVirtualRouteDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVirtualRouteDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.virtual.route.LazyNettyClientVirtualRoute;
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.annotation.Configuration;
import java.util.List;
@Slf4j
@Configuration
public class InitServerProxySocket implements CommandLineRunner {
private final LazyNettyServerVirtualRouteApplication lazyNettyServerVirtualRouteApplication;
private final LazyNettyClientVirtualRouteApplication lazyNettyClientVirtualRouteApplication;
public InitServerProxySocket(LazyNettyServerVirtualRouteApplication lazyNettyServerVirtualRouteApplication, LazyNettyClientVirtualRouteApplication lazyNettyClientVirtualRouteApplication) {
this.lazyNettyServerVirtualRouteApplication = lazyNettyServerVirtualRouteApplication;
this.lazyNettyClientVirtualRouteApplication = lazyNettyClientVirtualRouteApplication;
}
@Override
public void run(String... args) throws Exception {
try {
//初始化 服务端虚拟路由
LazyNettyServerVirtualRouteQueryListCommand lazyNettyServerVirtualRouteQueryListCommand = new LazyNettyServerVirtualRouteQueryListCommand();
lazyNettyServerVirtualRouteQueryListCommand.setIsDeleted(false);
lazyNettyServerVirtualRouteApplication.findList(lazyNettyServerVirtualRouteQueryListCommand)
.accept(lazyNettyServerVirtualRouteDTOS -> {
for (LazyNettyServerVirtualRouteDTO lazyNettyServerVirtualRouteDTO : lazyNettyServerVirtualRouteDTOS) {
String virtualIp = lazyNettyServerVirtualRouteDTO.getVirtualIp();
String virtualPort = lazyNettyServerVirtualRouteDTO.getVirtualPort();
String targetIp = lazyNettyServerVirtualRouteDTO.getTargetIp();
String targetPort = lazyNettyServerVirtualRouteDTO.getTargetPort();
ServerProxyRoute serverProxyRoute = new ServerProxyRoute();
serverProxyRoute.setServerIp("default");
serverProxyRoute.setVirtualIp(virtualIp);
serverProxyRoute.setVirtualPort(virtualPort);
serverProxyRoute.setTargetIp(targetIp);
serverProxyRoute.setTargetPort(targetPort);
serverProxyRoute.setRouteType(RouteType.LOCAL);
RouteContext.setRoute(serverProxyRoute);
}
});
// 初始化 客户端虚拟路由
LazyNettyClientVirtualRouteQueryListCommand lazyNettyClientVirtualRouteQueryListCommand = new LazyNettyClientVirtualRouteQueryListCommand();
lazyNettyClientVirtualRouteQueryListCommand.setIsDeleted(false);
lazyNettyClientVirtualRouteApplication.findList(lazyNettyClientVirtualRouteQueryListCommand)
.accept(lazyNettyClientVirtualRouteDTOS -> {
for (LazyNettyClientVirtualRouteDTO lazyNettyClientVirtualRouteDTO : lazyNettyClientVirtualRouteDTOS) {
String virtualIp = lazyNettyClientVirtualRouteDTO.getVirtualIp();
String virtualPort = lazyNettyClientVirtualRouteDTO.getVirtualPort();
String targetIp = lazyNettyClientVirtualRouteDTO.getTargetIp();
String targetPort = lazyNettyClientVirtualRouteDTO.getTargetPort();
String targetClientId = lazyNettyClientVirtualRouteDTO.getTargetClientId();
ClientProxyRoute serverProxyClientRoute = new ClientProxyRoute();
serverProxyClientRoute.setVirtualIp(virtualIp);
serverProxyClientRoute.setVirtualPort(virtualPort);
serverProxyClientRoute.setTargetClientId(targetClientId);
serverProxyClientRoute.setTargetIp(targetIp);
serverProxyClientRoute.setTargetPort(targetPort);
serverProxyClientRoute.setRouteType(RouteType.SERVER_PROXY_CLIENT);
RouteContext.setRoute(serverProxyClientRoute);
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
}