消息队列之-RabbitMq 学习
生产者服务A /消费者服务B
服务A和服务B配置:
依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
yaml
spring:
rabbitmq:
host: ${RABBITMQ_HOST:localhost}
port: ${RABBITMQ_PORT:5672}
username: ${RABBITMQ_USERNAME:guest}
password: ${RABBITMQ_PASSWORD:guest}
virtual-host: /
参数常量定义
/**
* @author yangjie
* @date 14/2/2025 上午 9:14
* @description
*/
public class BpmMqConstants {
/**
* 交换机
*/
public static final String BPM_EXCHANGE = "bpm.topic";
/**
* 队列