在非@主服务器上自动创建队列
在非@主服务器上自动创建队列
提问于 2022-08-26 05:27:29
我正在使用spring开发RabbitMQ。
我有两个不同的虚拟主机，一个叫做d和p。
在d代码中，它有@注释。
在p代码中，我使用QueueBuilder自动创建队列。在启动spring应用程序时，我注意到newQueue是在d虚拟主机整数中创建的。如何使newQueue (自动创建队列)在p虚拟主机中创建？
下面是d配置
package com.example.config;
import lombok.Data;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
@Data
@Configuration
@ConfigurationProperties(prefix="d.spring.rabbitmq")
public class RabbitMQConfig {
private String addresses;
private String username;
private String password;
private int port;
private String virtualHost;
@Bean(name="dRabbitConnectionFactory")
@Primary
public ConnectionFactory rabbitConnectionFactory(){
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setAddresses(addresses);
connectionFactory.setPort(port);
connectionFactory.setUsername(username);
connectionFactory.setPassword(password);
connectionFactory.setVirtualHost(virtualHost);
return connectionFactory;
}
@Bean(name="dRabbitMessageConverter")
public MessageConverter jsonMessageConverter(){
return new Jackson2JsonMessageConverter();
}
@Bean(name="dRabbitTemplate")
public RabbitTemplate rabbitTemplate(@Qualifier("dRabbitConnectionFactory") ConnectionFactory connectionFactory){
final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(jsonMessageConverter());
return rabbitTemplate;
}
@Bean(name="dRabbitListenerContainerFactory")
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, @Qualifier("dRabbitConnectionFactory") ConnectionFactory connectionFactory){
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
configurer.configure(factory, connectionFactory);
factory.setMessageConverter(jsonMessageConverter());
return factory;
}
}下面是p配置
package com.example.config;
import lombok.Data;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
@Data
@Configuration
@ConfigurationProperties(prefix="p.spring.rabbitmq")
public class RabbitMQPConfig {
private String addresses;
private String username;
private String password;
private int port;
private String virtualHost;
@Bean(name="pRabbitConnectionFactory")
public ConnectionFactory rabbitConnectionFactory(){
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setAddresses(addresses);
connectionFactory.setPort(port);
connectionFactory.setUsername(username);
connectionFactory.setPassword(password);
connectionFactory.setVirtualHost(virtualHost);
return connectionFactory;
}
@Bean(name="pRabbitMessageConverter")
public MessageConverter jsonMessageConverter(){
return new Jackson2JsonMessageConverter();
}
@Bean(name="pRabbitTemplate")
public RabbitTemplate rabbitTemplate(@Qualifier("pRabbitConnectionFactory") ConnectionFactory connectionFactory){
final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(jsonMessageConverter());
return rabbitTemplate;
}
@Bean(name="pRabbitListenerContainerFactory")
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, @Qualifier("pRabbitConnectionFactory") ConnectionFactory connectionFactory){
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
configurer.configure(factory, connectionFactory);
factory.setMessageConverter(jsonMessageConverter());
return factory;
}
@Value("${p.new-queue}")
private String newQueue;
@Bean //**this is the issue**
Queue createNewQueue(){
return QueueBuilder.durable(newQueue).quorum().build();
}
}这是application.properties
d.spring.rabbitmq.addresses=localhost
d.spring.rabbitmq.password=
d.spring.rabbitmq.port=5672
d.spring.rabbitmq.username=
d.spring.rabbitmq.virtual-host=d
p.spring.rabbitmq.addresses=localhost
p.spring.rabbitmq.password=
p.spring.rabbitmq.port=5672
p.spring.rabbitmq.username=
p.spring.rabbitmq.virtual-host=p
p.new-queue=p-new-queue回答 1
Stack Overflow用户
发布于 2022-08-29 13:00:29
您需要添加一个使用另一个连接工厂的RabbitAdmin，并配置队列，使其只由管理员声明，而不是由自动配置的amqpAdmin声明。
@Bean
AmqpAdmin otherAdmin(ConnectionFactory pRabbitConnectionFactory) {
return new RabbitAdmin(pRabbitConnectionFactory);
}
@Bean
Queue createNewQueue(RabbitAdmin otherAdmin) {
Queue q = QueueBuilder.durable(newQueue).quorum().build();
q.setAdminsThatShouldDeclare(otherAdmin);
return q;
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/73496425
复制相关文章
相似问题
腾讯云开发者
