我的Spring Boot应用不是Web服务器，但它是一个使用自定义协议的服务器（在这种情况下使用Camel）。
但是Spring Boot启动后立即停止（优雅地）。我该如何防止这种情况发生？
我希望在按下Ctrl+C或以编程方式停止应用时才停止。
@CompileStatic
@Configuration
class CamelConfig {
@Bean
CamelContextFactoryBean camelContext() {
final camelContextFactory = new CamelContextFactoryBean()
camelContextFactory.id = 'camelContext'
camelContextFactory
}
}
我找到了解决方案，使用org.springframework.boot.CommandLineRunner + Thread.currentThread().join()，例如：
（注意：下面的代码是 Groovy，而不是 Java）
package id.ac.itb.lumen.social
import org.slf4j.LoggerFactory
import org.springframework.boot.CommandLineRunner
import org.springframework.boot.SpringApplication
import org.springframework.boot.autoconfigure.SpringBootApplication
@SpringBootApplication
class LumenSocialApplication implements CommandLineRunner {
private static final log = LoggerFactory.getLogger(LumenSocialApplication.class)
static void main(String[] args) {
SpringApplication.run LumenSocialApplication, args
}
@Override
void run(String... args) throws Exception {
log.info('Joining thread, you can press Ctrl+C to shutdown application')
Thread.currentThread().join()
}
}
SpringBootTest注解的集成测试。 - christopher您还需要以下依赖项：为了让主线程保持阻塞状态，使Camel保持运行，请在应用程序属性或应用程序.yml文件中包含spring-boot-starter-web依赖项，或添加camel.springboot.main-run-controller=true。
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
<version>2.17.0</version>
</dependency>
<version>2.17.0</version>或使用camel BOM导入依赖项管理信息以保持一致性。使用CountDownLatch的示例实现：
@Bean
public CountDownLatch closeLatch() {
return new CountDownLatch(1);
}
public static void main(String... args) throws InterruptedException {
ApplicationContext ctx = SpringApplication.run(MyApp.class, args);
final CountDownLatch closeLatch = ctx.getBean(CountDownLatch.class);
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
closeLatch.countDown();
}
});
closeLatch.await();
}
现在要停止您的应用程序，您可以查找进程 ID 并从控制台发出 kill 命令：
现在，您可以通过查找进程 ID 并在控制台中使用 kill 命令来停止应用程序：
返回结果：现在，您可以通过查找进程 ID 并在控制台中使用 kill 命令来停止应用程序：
kill <PID>
所有线程都已完成，程序将自动关闭。
因此，在@Scheduled中注册一个空任务将创建一个循环线程以防止关闭。
文件 application.yml
spring:
main:
web-application-type: none
文件 DemoApplication.java
@SpringBootApplication
@EnableScheduling
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
}
文件 KeepAlive.java
@Component
public class KeepAlive {
private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
@Scheduled(fixedRate = 1 * 1000 * 60) // 1 minute
public void reportCurrentTime() {
log.info("Keepalive at time {}", dateFormat.format(new Date()));
}
}
现在这变得更加简单了。
只需在您的 application.properties 文件中添加 camel.springboot.main-run-controller=true
我的项目是非Web Spirng Boot。 我的优雅解决方案是通过CommandLineRunner创建一个守护线程。 这样，应用程序不会立即关闭。
@Bean
public CommandLineRunner deQueue() {
return args -> {
Thread daemonThread;
consumer.connect(3);
daemonThread = new Thread(() -> {
try {
consumer.work();
} catch (InterruptedException e) {
logger.info("daemon thread is interrupted", e);
}
});
daemonThread.setDaemon(true);
daemonThread.start();
};
}
如果不部署Web应用程序，要保持Java进程的活动状态，请将webEnvironment属性设置为false，如下所示：
SpringApplication sa = new SpringApplication();
sa.setWebEnvironment(false); //important
ApplicationContext ctx = sa.run(ApplicationMain.class, args);
为了让SpringBoot应用程序持续运行，它必须在容器中运行，否则它就像任何Java应用程序一样，所有线程都完成并结束。
您可以添加
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
如果它可以转换成Web应用程序，那么它会自动完成，否则您需要在实现中保持其运行。