RabbitMQ拓展学习 自定义配置RabbitMQ连接属性

public class RabbitmqConfig {


    @Bean
    public ConnectionFactory connectionFactory() throws Exception {
            //创建工厂类
            CachingConnectionFactory cachingConnectionFactory=new CachingConnectionFactory();
            //用户名
            cachingConnectionFactory.setUsername("gust");
            //密码
            cachingConnectionFactory.setPassword("gust");
            //rabbitMQ地址
            cachingConnectionFactory.setHost("127.0.0.1");
             //rabbitMQ端口
            cachingConnectionFactory.setPort(Integer.parseInt(5672));
            cachingConnectionFactory.setCacheMode(CachingConnectionFactory.CacheMode.CHANNEL);
            return  cachingConnectionFactory;
 
    }

    /**
     * 将配置好的信息放入
     * @param connectionFactory
     * @return
     */
    @Bean
    public RabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory){
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        return  factory;
    }



    /**
     * 自动声明队列
     * @param connectionFactory
     * @return
     */
    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){
        RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
        rabbitAdmin.setAutoStartup(true);
        return  rabbitAdmin;
    }
}