Spring Boot集成RabbitMQ

1、定义消息通道，之后消费方和发送方通过消息通道发送和接收消息，可以放在公共包里面，通过pom方式引入到消费者和生产者

package com.zz.commons.enums;


public interface MqQueueConstant {
    
    String TEST_QUERY_NAME = "test";
    
}

消费者和生产者都引入RabbitMQ的包

    org.springframework.boot
    spring-boot-starter-amqp

2、消费者服务配置和消息处理

#消息消费者配置
server:
  port: 7002

spring:
  rabbitmq:
  	#RabbitMQ客户端ip
    host: 
    #RabbitMQ端口
    port: 
    #RabbitMQ账号
    username: 
    #RabbitMQ密码
    password: 

消息处理

package com.zz.consumer.message;

import com.zz.commons.enums.MqQueueConstant;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;


@Component
public class TestMessageConsumer {
    @RabbitListener(queues = MqQueueConstant.TEST_QUERY_NAME)//这里指定通道
    public void receive(String content){
        //这里写处理消息的逻辑代码
    }
}

2、生产者服务配置和消息发送

#消息消费者配置
server:
  port: 7002

spring:
  rabbitmq:
  	#RabbitMQ客户端ip
    host: 
    #RabbitMQ端口
    port: 
    #RabbitMQ账号
    username: 
    #RabbitMQ密码
    password: 

发送消息

package com.zz.provider.message;

import com.zz.commons.enums.MqQueueConstant;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;


@RestController
@RequestMapping("/rabbit")
public class TestMessageProvider {
    @Resource
    private RabbitTemplate rabbitTemplate;

    @PostMapping("/sendMessage")
    public String sendMessage(){
        //指定MqQueueConstant.TEST_QUERY_NAME通道发送消息
        rabbitTemplate.convertAndSend(MqQueueConstant.TEST_QUERY_NAME,"这里填写消息内容");
        return "消息发送成功";
    }
}