c-amqp-start: rabbitmq开箱即用上司组织了一个openx组织，为这个组织写的rabbitmq开箱即用的springboot工程。还没提交，先上传到自己的空间

# c-amqp-start

===》RabbitMQ单机配置

1、重命名example.single.rabbitmq.properties为rabbitmq.properties

2、修改里面的配置

3、发送消息

注入
```
@Autowired
private RabbitTemplate rabbitTemplate
```
进行发送消息

4、监听队列

在需要监听队列的类上注解XContainerListener,在监听队列的方法上加注解XQueueHandler
```
@XContainerListener
public class NewListener {
    @XQueueHandler("cqy.queue.str")
    public void mm(String str) {
        System.out.println("receive:"+str);
    }
    @XQueueHandler("cqy.queue.obj")
    public void mm(Foo foo) {
        System.out.println("receive 2:"+foo);
    }
}
```

PS:
```
spring中注入ContainerListener的名字为listenerContainer
spring中注入ConnectionFactory的名字为connectionFactory
spring中注入RabbitTemplate的名字为rabbitTemplate
```

===》RabbitMQ多MQ

1、重命名example.multi.rabbitmq.properties为rabbitmq.properties

2、修改里面的配置

3、发送消息

注入
```
@Autowired
@Qualifier("rabbitTemplate0")
private RabbitTemplate rabbitTemplate
```

进行发送消息

4、监听队列

在需要监听队列的类上注解XContainerListener（注意containerListener="listenerContainer"+i，i为第i个MQ）,在监听队列的方法上加注解XQueueHandler
```
@XContainerListener(containerListener = "listenerContainer0")
public class NewListener {
    @XQueueHandler("cqy.queue.str")
    public void mm(String str) {
        System.out.println("receive:"+str);
    }
    @XQueueHandler("cqy.queue.obj")
    public void mm(Foo foo) {
        System.out.println("receive 2:"+foo);
    }
}
```

PS:
```
第i个MQ,i从0开始
spring中注入ContainerListener的名字为listenerContaineri
spring中注入ConnectionFactory的名字为connectionFactoryi
spring中注入RabbitTemplate的名字为rabbitTemplatei
```

=》扩展，自定义containerListener的值
```
修改spring.amqp.multi.rabbit[0].name=first
注解XContainerListener中的containerListener="firstListenerContainer"
spring中注入ConnectionFactory的名字为firstConnectionFactory
spring中注入RabbitTemplate的名字为firstRabbitTemplate
```

Jasper/c-amqp-start

简介

发行版

贡献者

近期动态

Jasper/c-amqp-start .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

Jasper/c-amqp-start