当前位置：首页 > article >正文

【RabbitMQ】02-Spring AMQP

article 2024/11/5 13:45:28

1. 使用

依赖

<!--AMQP依赖，包含RabbitMQ-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

配置

spring:
  rabbitmq:
    host: 192.168.150.101 # 你的虚拟机IP
    port: 5672 # 端口
    virtual-host: /hmall # 虚拟主机
    username: hmall # 用户名
    password: 123 # 密码

生产者

@SpringBootTest
public class SpringAmqpTest {
    @Autowired
    public RabbitTemplate rabbitTemplate;

    @Test
    void testSimple() {
        rabbitTemplate.convertAndSend("simple.queue", "hello, w");
    }
}

消费者
注册为Bean，交给SpringBoot进行管理。

@Component
@Slf4j
public class SpringAmqbListener {
    @Autowired
    RabbitTemplate rabbitTemplate;

    @RabbitListener(queues = "simple.queue")
    public void Lister(String msg) {
        log.info(msg);
    }
}

能者多劳
处理完了，才能获取下一条消息。

spring:
  rabbitmq:
    host: nuaamvp.cn # 你的虚拟机IP
    port: 5672 # 端口
    virtual-host: /hmall # 虚拟主机
    username: hmall # 用户名
    password: "@Mvplab123" # 密码
    listener:
      simple:
        prefetch: 1