RabbitMQ教程_5 整合SpringBoot

阳光穿透心脏的1/2处 2023-01-03 14:08 195阅读 0赞

https://gitee.com/fakerlove/rabbitmq

### 文章目录 ###

*  5. 整合SpringBoot
 *   *  5.1 helloword 模型
     *   *  引入依赖
         *  创建生产者
         *  创建消费者
         *  目录结构
     *  5.2 workquene 模型
     *   *  修改work 类
         *  创建消费者
         *  创建确认机制
     *  5.3 广播模式
     *   *  创建生产者
         *  创建消费者
         *  测试
     *  5.4 直连模式
     *   *  创建生产者
         *  创建消费者
         *  检查
     *  5.5 Topic 模式
     *   *  创建生产者
         *  消费者
         *  测试

# 5. 整合SpringBoot #

## 5.1 helloword 模型 ##

### 引入依赖 ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.4.1</version>
            <relativePath/> 
        </parent>
        <groupId>org.example</groupId>
        <artifactId>demo1</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <properties>
            <java.version>11</java.version>
        </properties>
        <dependencies>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
    
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.amqp</groupId>
                <artifactId>spring-rabbit-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

### 创建生产者 ###

package com.ak.demo;
    
    import org.junit.jupiter.api.Test;
    
    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;
    
    @SpringBootTest(classes = RabbitmqSpringApplication.class)
    public class MyTest { 
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        @Test
        public  void test(){ 
            rabbitTemplate.convertAndSend("hello","hello world");
        }
    }

### 创建消费者 ###

package com.ak.demo.hello;
    
    import org.springframework.amqp.rabbit.annotation.Queue;
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    /** * 默认持久化队列 */
    @Component
    @RabbitListener(queuesToDeclare =@Queue("hello"))
    public class HelloCustomer { 
    
        @RabbitHandler
        public void kk(String message){ 
            System.out.println(message);
        }
    }

### 目录结构 ###

![0dd1c510884b9d45f483fd7d3d4a2ea5.png][]

## 5.2 workquene 模型 ##

### 修改work 类 ###

@Test
        public  void test2(){ 
            for(int i=0;i<10;i++){ 
                rabbitTemplate.convertAndSend("work","work 模型");
            }
        }

### 创建消费者 ###

package com.ak.demo.work;
    
    import org.springframework.amqp.rabbit.annotation.Queue;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class WorkConsumer { 
    
        @RabbitListener(queuesToDeclare =@Queue("work"))
        public void receive(String messaage){ 
            System.out.println("消费者1---"+messaage);
        }
    
        @RabbitListener(queuesToDeclare =@Queue("work"))
        public void receive2(String messaage){ 
            System.out.println("消费者2--"+messaage);
        }
    }

![4d62f3eb21bffd965411c33a6bcda2bf.png][]

### 创建确认机制 ###

## 5.3 广播模式 ##

### 创建生产者 ###

/** * 广播形式的发布信息 */
        @Test
        public  void test3(){ 
    
            for(int i=0;i<10;i++){ 
                rabbitTemplate.convertAndSend("kk","","广播信息");
            }
        }

### 创建消费者 ###

package com.ak.demo.fanout;
    
    import org.springframework.amqp.rabbit.annotation.Exchange;
    import org.springframework.amqp.rabbit.annotation.Queue;
    import org.springframework.amqp.rabbit.annotation.QueueBinding;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class FanOutConsumer { 
    
        @RabbitListener(bindings = { 
                @QueueBinding(
                        value =@Queue,
                        exchange = @Exchange(value = "kk",type = "fanout")
                )
        })
        public void receive(String message){ 
            System.out.println("----");
            System.out.println("广播信息1"+message);
        }
    
        @RabbitListener(bindings = { 
                @QueueBinding(
                        value =@Queue,
                        exchange = @Exchange(value = "kk",type = "fanout")
                )
        })
        public void receive2(String message){ 
            System.out.println("----");
            System.out.println("广播信息2"+message);
        }
    }

### 测试 ###

![af7779aa0506f6dbd220c7eeddf862d7.png][]

## 5.4 直连模式 ##

### 创建生产者 ###

/** * 测试路由模型 */
        @Test
        public void testDirect(){ 
            String []routeKey={ "error","info","waring","debug"};
            for(int i=0;i<10;i++){ 
                int temp=new Random().nextInt(100)%4;
                rabbitTemplate.convertAndSend("directs",routeKey[temp],routeKey[temp]+"的日志信息");
            }
    
        }

### 创建消费者 ###

package com.ak.demo.router;
    
    import org.springframework.amqp.rabbit.annotation.Exchange;
    import org.springframework.amqp.rabbit.annotation.Queue;
    import org.springframework.amqp.rabbit.annotation.QueueBinding;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class DirectConsumer { 
    
        String []routeKey={ "error","info","waring","debug"};
        @RabbitListener(bindings = { 
                @QueueBinding(
                        value = @Queue,// 临时队列
                        exchange = @Exchange(value = "directs",type = "direct"),
                        key={ "error","info","waring","debug"}
                )
        })
        public void receive(String message){ 
            System.out.println("接受全部信息--"+message);
        }
    
    
        @RabbitListener(bindings = { 
                @QueueBinding(
                        value = @Queue,// 临时队列
                        exchange = @Exchange(value = "directs",type = "direct"),
                        key={ "error"}
                )
        })
        public void receive2(String message){ 
            System.out.println("只接受error--"+message);
        }
    }

### 检查 ###

![5dde3add2a3ad97945800dcaa1df5f9a.png][]

## 5.5 Topic 模式 ##

### 创建生产者 ###

@Test
        public void testFive(){ 
            String []routeKey={ "user.save","user.add","admin.add","admin.save"};
            for(int i=0;i<10;i++){ 
                int temp=new Random().nextInt(100)%4;
                rabbitTemplate.convertAndSend("topics",routeKey[temp],routeKey[temp]+"信息");
            }
        }

### 消费者 ###

package com.ak.demo.topic;
    
    import org.springframework.amqp.rabbit.annotation.Exchange;
    import org.springframework.amqp.rabbit.annotation.Queue;
    import org.springframework.amqp.rabbit.annotation.QueueBinding;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class TopicConsumer { 
    
        @RabbitListener(bindings = { 
                @QueueBinding(
                        value = @Queue,
                        exchange = @Exchange(name = "topics",type = "topic"),
                        key={ "user.*"}
                )
        })
        public void receive(String message){ 
            System.out.println("user类---"+message);
        }
    
        @RabbitListener(bindings = { 
                @QueueBinding(
                        value = @Queue,
                        exchange = @Exchange(name = "topics",type = "topic"),
                        key={ "admin.*"}
                )
        })
        public void receive2(String message){ 
            System.out.println("admin 类--"+message);
        }
    }

### 测试 ###

![1838339285f3848a5edb9b8d68865e48.png][]

[0dd1c510884b9d45f483fd7d3d4a2ea5.png]: /images/20221119/d4beeb1f5fce4ebf89a985cecd899831.png
[4d62f3eb21bffd965411c33a6bcda2bf.png]: /images/20221119/73efd695565a4ca1897f47796243cd81.png
[af7779aa0506f6dbd220c7eeddf862d7.png]: /images/20221119/f25b387247c3458383359c6ea59cfd08.png
[5dde3add2a3ad97945800dcaa1df5f9a.png]: /images/20221119/40294b97627b4eb9b510dac416f70f26.png
[1838339285f3848a5edb9b8d68865e48.png]: /images/20221119/ef44d977f9fb4d9eb7ce446a3bf50a70.png