生产者服务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";/*** 队列