gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(sj_1.3.0-beta1): 调整grpc/netty server获取port的方法

Browse Source
This commit is contained in:
srzou 2024-12-05 20:59:41 +08:00
parent c2c4ca1ef7
commit 10451db5f3
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/server/SnailGrpcServer.java
View File

@ -5,6 +5,7 @@ import com.aizuda.snailjob.client.common.config.SnailJobProperties;
import com.aizuda.snailjob.client.common.config.SnailJobProperties.RpcServerProperties; import com.aizuda.snailjob.client.common.config.SnailJobProperties.RpcServerProperties;
import com.aizuda.snailjob.client.common.config.SnailJobProperties.ThreadPoolConfig; import com.aizuda.snailjob.client.common.config.SnailJobProperties.ThreadPoolConfig;
import com.aizuda.snailjob.client.common.exception.SnailJobClientException; import com.aizuda.snailjob.client.common.exception.SnailJobClientException;
import com.aizuda.snailjob.client.common.rpc.client.GrpcChannel;
import com.aizuda.snailjob.client.common.rpc.supports.handler.SnailDispatcherRequestHandler; import com.aizuda.snailjob.client.common.rpc.supports.handler.SnailDispatcherRequestHandler;
import com.aizuda.snailjob.client.common.rpc.supports.handler.UnaryRequestHandler; import com.aizuda.snailjob.client.common.rpc.supports.handler.UnaryRequestHandler;
import com.aizuda.snailjob.common.core.constant.GrpcServerConstants; import com.aizuda.snailjob.common.core.constant.GrpcServerConstants;
@ -63,7 +64,7 @@ public class SnailGrpcServer implements Lifecycle {
final MutableHandlerRegistry handlerRegistry = new MutableHandlerRegistry(); final MutableHandlerRegistry handlerRegistry = new MutableHandlerRegistry();
addServices(handlerRegistry, new GrpcInterceptor()); addServices(handlerRegistry, new GrpcInterceptor());
NettyServerBuilder builder = NettyServerBuilder.forPort(snailJobProperties.getPort()) NettyServerBuilder builder = NettyServerBuilder.forPort(GrpcChannel.getClientPort())
.executor(createGrpcExecutor(grpc.getDispatcherTp())); .executor(createGrpcExecutor(grpc.getDispatcherTp()));
Duration keepAliveTime = grpc.getKeepAliveTime(); Duration keepAliveTime = grpc.getKeepAliveTime();

5
snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/server/SnailNettyHttpServer.java
View File

@ -4,6 +4,7 @@ import com.aizuda.snailjob.client.common.Lifecycle;
import com.aizuda.snailjob.client.common.config.SnailJobProperties; import com.aizuda.snailjob.client.common.config.SnailJobProperties;
import com.aizuda.snailjob.client.common.event.SnailServerStartFailedEvent; import com.aizuda.snailjob.client.common.event.SnailServerStartFailedEvent;
import com.aizuda.snailjob.client.common.exception.SnailJobClientException; import com.aizuda.snailjob.client.common.exception.SnailJobClientException;
import com.aizuda.snailjob.client.common.rpc.client.NettyChannel;
import com.aizuda.snailjob.client.common.rpc.supports.handler.NettyHttpServerHandler; import com.aizuda.snailjob.client.common.rpc.supports.handler.NettyHttpServerHandler;
import com.aizuda.snailjob.client.common.rpc.supports.handler.SnailDispatcherRequestHandler; import com.aizuda.snailjob.client.common.rpc.supports.handler.SnailDispatcherRequestHandler;
import com.aizuda.snailjob.common.core.context.SnailSpringContext; import com.aizuda.snailjob.common.core.context.SnailSpringContext;
@ -32,7 +33,7 @@ import org.springframework.stereotype.Component;
* @date : 2024-04-12 23:03 * @date : 2024-04-12 23:03
* @since 3.3.0 * @since 3.3.0
*/ */
//@Component @Component
@Order(Ordered.HIGHEST_PRECEDENCE) @Order(Ordered.HIGHEST_PRECEDENCE)
@RequiredArgsConstructor @RequiredArgsConstructor
@Getter @Getter
@ -70,7 +71,7 @@ public class SnailNettyHttpServer implements Runnable, Lifecycle {
}); });
// 在特定端口绑定并启动服务器 默认是1789 // 在特定端口绑定并启动服务器 默认是1789
ChannelFuture future = bootstrap.bind(snailJobProperties.getPort()).sync(); ChannelFuture future = bootstrap.bind(NettyChannel.getClientPort()).sync();
SnailJobLog.LOCAL.info("------> snail-job client remoting server start success, nettype = {}, port = {}", SnailJobLog.LOCAL.info("------> snail-job client remoting server start success, nettype = {}, port = {}",
SnailNettyHttpServer.class.getName(), snailJobProperties.getPort()); SnailNettyHttpServer.class.getName(), snailJobProperties.getPort());