rabbitMQ与spring集成在项目中使用

比眉伴天荒 2022-07-13 05:48 185阅读 0赞

rabbitMQ与spring集成  
1、引入spring-rabbit依赖

<dependency>
                    <groupId>org.springframework.amqp</groupId>
                    <artifactId>spring-rabbit</artifactId>
                      <version>1.5.1.RELEASE</version>
                  </dependency>

2、对应spring的版本4.2.8.RELEASE  
3、配置sping-mq.xml配置文件

<rabbit:connection-factory id="connectionFactory" host="${mq.host}" port="${mq.port}" username="${mq.username}" password="${mq.password}" />
    
    <rabbit:admin connection-factory="connectionFactory" />
    
        
        
    <rabbit:template id="test-template" connection-factory="connectionFactory" exchange="test.exchange" />
    
        
    
        
        <rabbit:queue name="test.a.queue" />
    
        <rabbit:queue name="test.b.queue" />
        
    
        
        <rabbit:fanout-exchange name="test.exchange">
            <rabbit:bindings>
                <rabbit:binding queue="test.a.queue" />
            </rabbit:bindings>
        </rabbit:fanout-exchange>
     <rabbit:listener-container connection-factory="connectionFactory" concurrency="10" prefetch="5">
             <rabbit:listener queue-names="test.a.queue" method="listen" ref="testListener" />
        </rabbit:listener-container>
    
        
        <bean id="testListener" class="org.t.TestListener"/>

此时可以使用test-template向exchange中推送消息，exchange接收到消息后向其绑定的队列进行消息投递。  
exchange有两种类型：  
a. fanout类型的exchange，该类型的exchange会对其绑定的队列进行广播（即当前exchange绑定的所有队列都会被投递）  
b. direct类型的exchange，改类型的exchange会根据key投递到不同的队列（key可以使用通配符，具体参考文档）

使用rabbitMQ时候遇到的问题  
1 监听b队列，向a队列推送消息，结果监听器也可以监听到消息

原因：要通过rabbitMQ提供的网页管理工具检查该exchange绑定到哪些queue上去了，要保证该exchange只向a队列投递，而不是既绑定了a队列又绑定了b队列。