035 RabbitMQ五种工作模式

文章目录

• 简单模式
• • rabbit-provider
  • rabbit-consumer
• 工作队列模式
• • rabbit-provider
  • rabbit-consumer
• 发布与订阅模式(fanout)
• • rabbit-provider
  • rabbit-consumer
• 路由模式(direct)
• • rabbit-provider
  • rabbit-consumer
• 通配符模式(topic)
• • rabbit-provider
  • rabbit-consumer

简单模式

rabbit-provider

Demo01TestSimpleQueue.java

package com.cubemall.test;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class Demo01TestSimpleQueue {
    //目标:编写生产者发送消息到消息队列
    //实现过程:导入Rabbit模板对象,调用api接口
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMsg(){
        /**
         * 参数1: 队列名称
         * 参数2: 消息内容
         */
        rabbitTemplate.convertAndSend("simple_queue","hello 小兔子");
    }
}

rabbit-consumer

SimpleListener.java

package com.cubemall.listeners.simpleQueue;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "simple_queue")
public class SimpleListener {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("接收消息 == " + msg);
    }
}

RabbitMQConsumerApplication.java

package com.cubemall;


import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class RabbitMQConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(RabbitMQConsumerApplication.class,args);
    }
}

工作队列模式

rabbit-provider

Demo02TestWorkQueue.java

package com.cubemall.test;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class Demo02TestWorkQueue {
    //目标:编写生产者发送消息到消息队列
    //实现过程:导入Rabbit模板对象,调用api接口
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMsg(){
        /**
         * 参数1: 队列名称
         * 参数2: 消息内容
         */
        for (int i = 0; i < 10000; i++){
            rabbitTemplate.convertAndSend("work_queue","hello 小兔子");
        }

    }
}

rabbit-consumer

WorkListener01.java

package com.cubemall.listeners.workQueue;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "work_queue")
public class WorkListener01 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("work_queue 01 接收消息 == " + msg);
    }
}

WorkListener02.java

package com.cubemall.listeners.workQueue;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "work_queue")
public class WorkListener02 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("work_queue 02 接收消息 == " + msg);
    }
}

发布与订阅模式(fanout)

rabbit-provider

Demo03TestFanoutExchange.java

package com.cubemall.test;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class Demo03TestFanoutExchange {
    //目标: 通过发布订阅模式，发送消息到交换机
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMsg(){
        /**
         * 参数1: 交换机
         * 参数2: 路由键
         * 参数3: 消息内容
         */
        for (int i = 0; i < 100; i++){
            rabbitTemplate.convertAndSend("fanout_exchange","","hello 小兔子");
        }



    }
}

rabbit-consumer

FanoutListener01.java

package com.cubemall.listeners.fanoutExchange;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "fanout_queue1")
public class FanoutListener01 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("fanoutqueue1 接收消息 == " + msg);
    }
}

FanoutListener02.java

package com.cubemall.listeners.fanoutExchange;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "fanout_queue2")
public class FanoutListener02 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("fanoutqueue2 接收消息 == " + msg);
    }
}

路由模式(direct)

rabbit-provider

Demo04TestRoutingExchange.java

package com.cubemall.test;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class Demo04TestRoutingExchange {
    //目标: 通过发布订阅模式，发送消息到交换机
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMsg(){
        /**
         * 参数1: 交换机
         * 参数2: 路由键
         * 参数3: 消息内容
         */
        for (int i = 0; i < 100; i++){

            if (i % 2 == 0) {
                rabbitTemplate.convertAndSend("routing_exchange","info","hello 小兔子 ["+i+"] +info");
            } else {
                rabbitTemplate.convertAndSend("routing_exchange","error","hello 小兔子 ["+i+"] +error");
            }



        }



    }
}

rabbit-consumer

RoutingListener1.java

package com.cubemall.listeners.routingQueue;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "routing_queue1")
public class RoutingListener1 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("routingqueue1 接收消息 == " + msg);
    }
}

RoutingListener2.java

package com.cubemall.listeners.routingQueue;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "routing_queue2")
public class RoutingListener2 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("routing_queue2 接收消息 == " + msg);
    }
}

通配符模式(topic)

rabbit-provider

Demo05TestTopicExchange.java

package com.cubemall.test;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class Demo05TestTopicExchange {
    //目标: 通过发布订阅模式，发送消息到交换机
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMsg(){
        /**
         * 参数1: 交换机
         * 参数2: 路由键
         * 参数3: 消息内容
         */

        rabbitTemplate.convertAndSend("topic_exchange","item.insert","hello 小兔子 [item.insert]");

        rabbitTemplate.convertAndSend("topic_exchange","item.insert.abc","hello 小兔子 [item.insert.abc]");







    }
}

rabbit-consumer

TopicListener1.java

package com.cubemall.listeners.topicQueue;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "topic_queue1")
public class TopicListener1 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("topic_queue1 接收消息 == " + msg);
    }
}

TopicListener2.java

package com.cubemall.listeners.topicQueue;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/*
消费者消息队列监听器
 */
@Component
@RabbitListener(queues = "topic_queue2")
public class TopicListener2 {
    //处理消息方法
    @RabbitHandler
    public void simpleHandler(String msg){
        System.out.println("topic_queue2 接收消息 == " + msg);
    }
}