消息队列之-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";
    /**
     * 队列