【RabbitMQ】spring整合rabbitmq 文件配置、demo完整示例

桃扇骨 2022-04-18 02:59 274阅读 0赞

1、创建工厂连接

<rabbit:connection-factory id="connectionFactory"
                                   host="127.0.0.1"
                                   port="5672"
                                   username="guest"
                                   password="guest"/>`

2、通过指定admin信息，当前生产的exchange和queue信息会在admin自动生成

<rabbit:admin connection-factory="connectionFactory"/>

3、创建队列

<rabbit:queue name="scorpio_queue" auto-delete="false" durable="true" exclusive="false"/>

4、设置转换器类型，并与队列进行绑定

<rabbit:topic-exchange name="test_scorpio" durable="true" auto-delete="false">
            <rabbit:bindings>
                <rabbit:binding pattern="scorpio" queue="scorpio_queue"/>
            </rabbit:bindings>
        </rabbit:topic-exchange>

5、定义消息模板，用于消息的接收和发送

<rabbit:template id="amqpTemplate"
                         connection-factory="connectionFactory"
                         exchange="test_scorpio"    ---转换器名称，不是routingKey
       receive-timeout="10000"/>

至此，生产者配置完毕了。

下面是生产者的实现代码：

package com.gao.scorpio.service.mq;
    /**
     * @description
     * @author: gaobh
     * @date: 2018/4/26 14:23
     * @version: v1.0
     */
    public interface MqProviderService {
        /**
         * 生产者发送消息
         * @param key
         * @param obj
         */
        void sendData(String key,Object obj);
    }

package com.gao.scorpio.service.mq.impl;
    import com.gao.scorpio.service.mq.MqProviderService;
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    /**
     * @description 生产者实现类
     * @author: gaobh
     * @date: 2018/4/26 14:25
     * @version: v1.0
     */
    @Service
    public class MqProviderImplService implements MqProviderService {
        @Autowired
        private AmqpTemplate amqpTemplate;
        /**
         * 生产者发送消息
         *
         * @param key
         * @param obj
         */
        @Override
        public void sendData(String key, Object obj) {
            amqpTemplate.convertAndSend(key, obj);
        }
    }

6、消费者配置

上面的参数中有一个acknowledge=“manual”，是对应答机制的配置，手动应答。自动应答是auto

package com.gao.scorpio.service.mq;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.core.MessageListener;
    /**
     * @description
     * @author: gaobh
     * @date: 2018/4/27 16:16
     * @version: v1.0
     */
    public class MqConsumer1Service implements MessageListener {
        @Override
        public void onMessage(Message message) {
            System.out.println("消费者消费："+message.toString());
        }
    }

测试Controller

package com.gao.scorpio.controller.mq;
    import com.gao.scorpio.service.mq.MqProviderService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    /**
     * @description
     * @author: gaobh
     * @date: 2018/4/27 10:07
     * @version: v1.0
     */
    @Controller
    @RequestMapping("/abc")
    public class MqTestController {
        @Autowired
        private MqProviderService mqProviderService;
        /**
         * @return
         */
        @ResponseBody
        @RequestMapping("/sendQueue")
        public String testQueue() {
            try {
                mqProviderService.sendData("scorpio", "hello rabbitmq");
            } catch (Exception e) {
                e.printStackTrace();
            }
            return "发送完毕";
        }
    }

完整xml配置

<?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.xsd
                               http://www.springframework.org/schema/rabbit
                               http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">
     
        
        <rabbit:connection-factory id="connectionFactory"
                                   host="127.0.0.1"
                                   port="5672"
                                   username="gaobh"
                                   password="123456"/>
     
        
        <rabbit:admin connection-factory="connectionFactory"/>
     
        
        <rabbit:template id="amqpTemplate"
                         connection-factory="connectionFactory"
                         exchange="test_scorpio"
                         receive-timeout="10000"/>
     
        
        <rabbit:queue name="scorpio_queue" auto-delete="false" durable="true" exclusive="false"/>
     
        
        <rabbit:topic-exchange name="test_scorpio" durable="true" auto-delete="false">
            <rabbit:bindings>
                <rabbit:binding pattern="scorpio" queue="scorpio_queue"/>
            </rabbit:bindings>
        </rabbit:topic-exchange>
        
        <bean id="mqConsumer1Service" class="com.gao.scorpio.service.mq.MqConsumer1Service"/>
        <rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual">
            <rabbit:listener ref="mqConsumer1Service" method="onMessage" queue-names="scorpio_queue"/>
        </rabbit:listener-container>
    </beans>

转发来自：[https://blog.csdn.net/gao763024185/article/details/80110640][https_blog.csdn.net_gao763024185_article_details_80110640]

[https_blog.csdn.net_gao763024185_article_details_80110640]: https://blog.csdn.net/gao763024185/article/details/80110640