diff --git a/hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/IdentifyUtil.java b/hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/IdentifyUtil.java index 00a67f26..bb36b712 100644 --- a/hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/IdentifyUtil.java +++ b/hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/IdentifyUtil.java @@ -72,7 +72,7 @@ public class IdentifyUtil { port = customerNetwork[1]; } else { ip = inetUtil.findFirstNonLoopBackHostInfo().getIpAddress(); - port = environment.getProperty("server.port", "8080"); + port = environment.getProperty("spring.dynamic.thread-pool.local-server-port", "16691"); } String identify = ip + ":" diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyServerConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyServerConfiguration.java index d66ee807..21365293 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyServerConfiguration.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyServerConfiguration.java @@ -26,12 +26,14 @@ import cn.hippo4j.rpc.handler.NettyServerTakeHandler; import cn.hippo4j.rpc.server.NettyServerConnection; import cn.hippo4j.rpc.server.Server; import cn.hippo4j.rpc.support.NettyServerSupport; +import lombok.extern.slf4j.Slf4j; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.context.EnvironmentAware; import org.springframework.core.env.Environment; import org.springframework.stereotype.Component; +@Slf4j @Component public class NettyServerConfiguration implements ApplicationRunner, EnvironmentAware { @@ -51,6 +53,9 @@ public class NettyServerConfiguration implements ApplicationRunner, EnvironmentA try ( NettyServerConnection connection = new NettyServerConnection(handler); Server server = new NettyServerSupport(serverPort, connection, classes)) { + if (log.isInfoEnabled()) { + log.info("Netty server started, binding to port {}", serverPort.getPort()); + } server.bind(); } }