SpringBoot2整合了Rabbitmq以后，有些情景不需要初始化和连接Rabbitmq，所以需要怎么处理呢？

本文介绍: 问题提出，最近有个需求，有的场合项目需要连接Rabbitmq，有些场合项目就不需要连接，再不需要连接的时候，还必须的安装Rabbimq服务，徒增时间消耗，所以需要处理一下。这样通过配置yml中的spring.rabbitmq.enable属性即可，如果设置成true是启用，如果设置成false是禁用。# 配置rabbitMq启用开关。

问题提出，最近有个需求，有的场合项目需要连接Rabbitmq，有些场合项目就不需要连接，再不需要连接的时候，还必须的安装Rabbimq服务，徒增时间消耗，所以需要处理一下。

在yml中配置如下：

启动类中配置如下，禁用springboot的自动配置：

@SpringBootApplication(exclude = {RabbitAutoConfiguration.class})

读取配置的配置类:

@Data
@Component
@ConfigurationProperties(prefix = "spring.rabbitmq")
public class MyRabbitMqConfig {
    /**
     * 服务是否启用
     * true是启用
     * false是禁用
     */
    private boolean enable;
    /**
     * 主机ip
     */
    private String host;
    /**
     * 服务端ip
     */
    private int port;
    /**
     * 用户名
     */
    private String username;
    /**
     * 密码
     */
    private String password;
    /**
     * 虚拟主机
     */
    private String virtualHost;

}

RabbitTemplate和ConnectionFactory配置:

@Configuration
public class RabbitMqConfig {

    @Resource
    private MyRabbitMqConfig rabbitMqConfig;

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate=new RabbitTemplate();
        rabbitTemplate.setConnectionFactory(connectionFactory);
        return rabbitTemplate;
    }

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(rabbitMqConfig.getHost());
        connectionFactory.setPort(rabbitMqConfig.getPort());
        connectionFactory.setUsername(rabbitMqConfig.getUsername());
        connectionFactory.setPassword(rabbitMqConfig.getPassword());
        connectionFactory.setVirtualHost(rabbitMqConfig.getVirtualHost());
        return connectionFactory;
    }

}

这样通过配置yml中的spring.rabbitmq.enable属性即可，如果设置成true是启用，如果设置成false是禁用。

显示所有内容

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。