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

Merge branch 'master' into dev_2.2.0

Browse Source 
# Conflicts:
#	easy-retry-server/src/main/java/com/aizuda/easy/retry/server/EasyRetryServerApplication.java
#	pom.xml
This commit is contained in:
byteblogs168 2023-08-17 18:05:29 +08:00
commit d1aea178a9
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/EasyRetryServerApplication.java
View File

@ -1,6 +1,7 @@
package com.aizuda.easy.retry.server; package com.aizuda.easy.retry.server;
import com.aizuda.easy.retry.server.server.NettyHttpServer; import com.aizuda.easy.retry.server.server.NettyHttpServer;
import lombok.extern.slf4j.Slf4j;
import org.mybatis.spring.annotation.MapperScan; import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner; import org.springframework.boot.ApplicationRunner;
@ -18,6 +19,7 @@ import java.util.concurrent.TimeUnit;
@SpringBootApplication @SpringBootApplication
@EnableTransactionManagement(proxyTargetClass = true) @EnableTransactionManagement(proxyTargetClass = true)
@Slf4j
public class EasyRetryServerApplication { public class EasyRetryServerApplication {
@Bean @Bean
@ -39,11 +41,13 @@ public class EasyRetryServerApplication {
// 最长自旋10秒，保证nettyHttpServer启动完成 // 最长自旋10秒，保证nettyHttpServer启动完成
int waitCount = 0; int waitCount = 0;
while (!nettyHttpServer.isStarted() || waitCount > 100) { while (!nettyHttpServer.isStarted() || waitCount > 100) {
log.info("--------> easy-retry netty server is staring....");
TimeUnit.MILLISECONDS.sleep(100); TimeUnit.MILLISECONDS.sleep(100);
waitCount++; waitCount++;
} }
if (!nettyHttpServer.isStarted()) { if (!nettyHttpServer.isStarted()) {
log.error("--------> easy-retry netty server startup failure.");
// Netty启动失败，停止Web服务和Spring Boot应用程序 // Netty启动失败，停止Web服务和Spring Boot应用程序
serverFactory.getWebServer().stop(); serverFactory.getWebServer().stop();
SpringApplication.exit(SpringApplication.run(EasyRetryServerApplication.class)); SpringApplication.exit(SpringApplication.run(EasyRetryServerApplication.class));