RabbitMQ配置生产者和消费者

Bertha 。 2023-02-19 07:27 25阅读 0赞

**默认已经安装好RabbitMQ服务,且在RabbitMQ管理端页面（默认port:15672）上需创建exchange、queue及exchange与queue绑定关系等**

下面进行项目中生产者和消费者的配置

## **一、添加依赖** ##

在项目文件pom.xml中添加依赖

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

## **二、生产者** ##

**1.配置**

**2.代码-生产者生产消息**

package com.api;
    
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.core.MessageProperties;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    //其他 import
    
    public class ConsumerHandlerClass 
    { 
        @Autowired  
        private RabbitTemplate rabbitProviderName; //rabbitProviderName 需要和配置中template的id对应
    
        public void sendMessage(){ 
            Message message = new Message(("{\"key\":1}").getBytes(), new MessageProperties());
            rabbitProviderName.send(message);
        }
    }

## **三、消费者** ##

**1.配置**

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
           xmlns:rabbit="http://www.springframework.org/schema/rabbit"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
            http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/rabbit
            http://www.springframework.org/schema/rabbit/spring-rabbit-2.2.xsd">
        
    
        
    
        
        <rabbit:connection-factory id="connectionFactory"
                                    username="guest"
                                    password="guest"
                                    host="192.168.8.130"
                                    port="5672"
                                    channel-cache-size="50"
                                    publisher-returns="true"
                                    publisher-confirms="true"
                                    connection-timeout="5000"
                                    />
    
        
        <rabbit:admin connection-factory="connectionFactory"/>
    
        
        <bean id="jsonMessageConverter"  class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter"/>
    
        
        <rabbit:template id="consumerTemplate" connection-factory="connectionFactory" exchange="exchange-name" message-converter="jsonMessageConverter"/>
    
        
        <rabbit:topic-exchange name="exchange-name" durable="true" auto-delete="false">
            <rabbit:bindings>
                <rabbit:binding queue="queue-id" pattern="queues-name.*"/>
            </rabbit:bindings>
        </rabbit:topic-exchange>
    
        
        <bean id="consumerHandler" class="com.api.ConsumerHandlerClass"/>
    
        
        <bean id="receiveListenerAdapter" class="org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter">
            <constructor-arg ref="consumerHandler" />
            <property name="defaultListenerMethod" value="handlerFunc"></property> 
            <property name="messageConverter" ref="jsonMessageConverter"></property>
        </bean>
    
        
        <rabbit:listener-container connection-factory="connectionFactory">
            <rabbit:listener queues="queue-id" ref="receiveListenerAdapter"/>
            
        </rabbit:listener-container>
    
    </beans>

**2.代码-消费者处理消息**

package com.api;
    
    //其他 import
    
    public class ConsumerHandlerClass 
    { 
        public void handlerFunc(HashMap arguments) { 
            //arguments 是生产者产生的消息
        }
    }