所以我的问题如下:
我正在使用spring AMQP连接到使用SSL的rabbitMQ实例。不幸的是,spring AMQP目前不支持全长amqps URI,并且在优先级列表中添加支持不高(请参阅问题:https://github.com/spring-projects/spring-boot/issues/6401)。他们需要分开。
我的application.yml中需要以下字段才能连接:
spring:
rabbitmq:
host: hostname
port: portnumber
username: username
password: password
virtual-host: virtualhost
ssl:
enabled: true
我的rabbitMQ实例的VCAP_Services环境仅以下列格式提供virtualhost和全长uri:amqps://username:password@hostname:portnumber/virtualhost
将这些值复制并粘贴到我的application.yml中是好的,但从长远来看是不可行的。他们需要来自vcap_services。
我的@SpringBootApplication有@Beans在启动时初始化与rabbitMQ实例的连接,所以我正在寻找一种方法来解析各个值并在应用程序启动之前设置它们。
如果您只想在初始化Spring Boot应用程序之前阅读属性,则可以在调用YamlPropertiesFactoryBean
之前使用Spring的SpringApplication.run
解析yaml文件。例如,
@SpringBootApplication
public class Application {
public static void main(String[] args) {
YamlPropertiesFactoryBean yamlFactory = new YamlPropertiesFactoryBean();
yamlFactory.setResources(new ClassPathResource("application.yml"));
Properties props = yamlFactory.getObject();
String hostname = props.getProperty("spring.rabbitmq.hostname");
...
SpringApplication.run(Application.class, args);
}
}
只需覆盖Boot的自动配置连接工厂......
@SpringBootApplication
public class So46937522Application {
public static void main(String[] args) {
SpringApplication.run(So46937522Application.class, args);
}
@Bean
public CachingConnectionFactory rabbitConnectionFactory(RabbitProperties config)
throws Exception {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.getRabbitConnectionFactory()
.setUri("amqps://guest:[email protected]:5671/virtualhost");
return connectionFactory;
}
@RabbitListener(queues = "si.test.queue")
public void listen(Message in) {
System.out.println(in);
}
}