rabbitmq入门（五）rabbitmq整合springboot（Routing、Topics）

柔光的暖阳◎ 2023-06-16 02:20 61阅读 0赞

### 文章目录 ###

*   *  构建生产者springboot
     *   *  1.创建啊springboot项目
         *  2. 引入依赖
         *  3. 修改配置文件application.yml
         *  4.创建配置类 FanoutConfig
         *  5. 编写生产者FanoutProducer
         *  6. 编写MemberProducerController
         *  7.编写启动类AppMemberProducer
     *  构建消费者springboot
     *   *  1. 创建springboot项目，修改配置文件 都和上面一致
         *  2.编写邮件消费者和短信消费者
     *  测试

## 构建生产者springboot ##

### 1.创建啊springboot项目 ###

项目结构如下  
![在这里插入图片描述][2019112319450711.png]

### 2. 引入依赖 ###

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>

### 3. 修改配置文件application.yml ###

server:
      port: 9008
    spring:
      application:
        name: shopping-rabbitmq
      rabbitmq:
        ## 连接地址
        host: 192.168.150.105
        ## 端口号
        port: 5672
        ##账号
        username: admin
        ##密码
        password: admin
        virtual-host: /admin_host
        ##dynamic: true

### 4.创建配置类 FanoutConfig ###

@Component
    public class FanoutConfig { 
        //邮件队列
        private static final String EMAIL_QUEUE = "email_fanout";
        private static final String SMS_QUEUE = "msm_fanout";
        private static final String DESTINATION_NAME = "fanout_destination";
    
        //1.定义邮件队列
        @Bean
        public Queue fanouEmailQueue() { 
            return new Queue(EMAIL_QUEUE);
        }
    
        //短信队列
        @Bean
        public Queue fanoutSmsQueue() { 
            return new Queue(SMS_QUEUE);
        }
        //2. 定义交换机 这里交换机使用FanoutExchange 如果想使用其他模式只需要修改就交换机比如TopicExchange
        @Bean
        public FanoutExchange fanoutExchange() { 
            return new FanoutExchange(DESTINATION_NAME);
        }
    
        //3. 队列和交换机进行绑定
        //这里参数的名字一定要和定义队列的名字一致
        @Bean
        Binding bindingExchangEamil(Queue fanouEmailQueue, FanoutExchange fanoutExchange) { 
            return BindingBuilder.bind(fanouEmailQueue).to(fanoutExchange);
            //如果要加routing kye.
        }
    
        //主题模式 TopicExchange
        /*@Bean public TopicExchange topicExchange() { return new TopicExchange(DESTINATION_NAME); }*/
       /* @Bean Binding bindingExchangEamil (Queue fanouEmailQueue, TopicExchange fanoutExchange){ return BindingBuilder.bind(fanoutExchange).to(fanoutExchange).with("topic.#"); }*/
        @Bean
        Binding bindingExchangSms(Queue fanoutSmsQueue, FanoutExchange fanoutExchange) { 
            return BindingBuilder.bind(fanoutSmsQueue).to(fanoutExchange);
        }
    
    }

说明 注释掉的代码即为Topics模式

### 5. 编写生产者FanoutProducer ###

@Component
    public class FanoutProducer { 
        @Autowired
        private AmqpTemplate amqpTemplate;
    
        public void send(String queueName) { 
            System.out.println("queueName" + queueName);
            String msg = "msg:" + new Date();
            //发送消息 如果使用routing key 只需要在中间加入参数即可
            //主题模式
    // amqpTemplate.convertAndSend(queueName, "topic.msm", msg);
            amqpTemplate.convertAndSend(queueName, msg);
        }
    }

### 6. 编写MemberProducerController ###

@RestController
    public class MemberProducerController { 
        @Autowired
        private FanoutProducer producer;
    
        @GetMapping("/sendMsg")
        public String send(String queueName) { 
            producer.send(queueName);
    
            return "success";
        }
    }

### 7.编写启动类AppMemberProducer ###

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

## 构建消费者springboot ##

项目目录结构如下  
![在这里插入图片描述][20191123195120766.png]

### 1. 创建springboot项目，修改配置文件 都和上面一致 ###

### 2.编写邮件消费者和短信消费者 ###

SmsConsumer

@Component
    @RabbitListener(queues = "msm_fanout")
    public class SmsConsumer { 
    
        @RabbitHandler
        public void process(String msg) { 
            System.out.println("短信队列接受到的消息为" + msg);
    
        }
    }

EmailConsumer

@Component
    @RabbitListener(queues = "email_fanout")
    public class EmailConsumer { 
    
        @RabbitHandler
        public void process(String msg) { 
            System.out.println("邮件队列接受到的消息为" + msg);
    
        }
    }

## 测试 ##

访问如下路径  
http://localhost:9008/sendMsg?queueName=email\_fanout  
看消费者控制台打印出消费信息  
![在这里插入图片描述][20191123195842509.png]

[2019112319450711.png]: https://img-blog.csdnimg.cn/2019112319450711.png
[20191123195120766.png]: https://img-blog.csdnimg.cn/20191123195120766.png
[20191123195842509.png]: https://img-blog.csdnimg.cn/20191123195842509.png