我有一个简单的Spring-Boot应用程序,只使用AMQP依赖项(仅为'org.springframework.boot:spring-boot-starter-amqp' - 例如没有Web依赖项,因此不包括在JAR中的应用程序服务器)。
我只想让应用程序运行并监听队列,在每次接收到消息时将一些信息记录到数据库中。然而,由于没有应用程序服务器,一旦它启动就会立即关闭(因为没有任何操作)。是否有最佳方法使此应用程序在接收消息时保持运行状态?
代码中没有令人惊讶的内容,只有标准应用程序配置,以及一个带有@RabbitListener注释的类。
我只想让应用程序运行并监听队列,在每次接收到消息时将一些信息记录到数据库中。然而,由于没有应用程序服务器,一旦它启动就会立即关闭(因为没有任何操作)。是否有最佳方法使此应用程序在接收消息时保持运行状态?
代码中没有令人惊讶的内容,只有标准应用程序配置,以及一个带有@RabbitListener注释的类。
@SpringBootApplication
class PersistenceSeriveApplication {
static void main(String[] args) {
SpringApplication.run PersistenceSeriveApplication, args
}
}
@Configuration
@EnableRabbit
class QueueConfiguration {
@Bean public Queue applicationPersistenceQueue( @Value( '${amqp.queues.persistence}' ) String queueName ) {
new Queue( queueName )
}
}
我考虑的一个选项是启动一个定时进程 - 只是一个心跳或其他类似的东西,这可能对监控也很有用 - 但是否还有其他更好/标准的方法?