Skip to content

bug-emperor/springboot-message

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

3 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

springboot-amqp

##1、RabbitMQ自定义配置

###(1)、配置文件application.properties中进行自定义属性的配置

    spring:
      rabbitmq:
        username: rabbitAdmin
        password: 123456789
    #    支持发布确认
        publisher-confirms: true
    #    支持发布返回
        publisher-returns: true
        listener:
          simple:
    #      采用手动应答
            acknowledge-mode: manual
    #        当前监听容器数
            concurrency: 1
    #        最大数
            max-concurrency: 1
    #        是否支持重试
            retry:
              enabled: true

###(2)、自定义CachingConnectionFactory,设置连接的相关属性

    @Bean
    @ConfigurationProperties(prefix = "spring.rabbitmq")
    public CachingConnectionFactory connection(){
        CachingConnectionFactory connectionFactory=new CachingConnectionFactory();
        connectionFactory.setHost("127.0.0.1");
        connectionFactory.setPort(5672);
        connectionFactory.setVirtualHost("/vhost_mmr");
        connectionFactory.setUsername("user_mmr");
        connectionFactory.setPassword("123");
        return connectionFactory;
    }

###(3)、自定义RabbitTemplate模板

About

别人码云上springboot和rabbitmq整合的代码

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

 
 
 

Contributors

Languages