【RabbitMQ】02-Spring AMQP

1. 使用

1. 依赖

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

2. 配置

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

3. 生产者

@SpringBootTest
public class SpringAmqpTest {@Autowiredpublic RabbitTemplate rabbitTemplate;@Testvoid testSimple() {rabbitTemplate.convertAndSend("simple.queue", "hello, w");}
}

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

@Component
@Slf4j
public class SpringAmqbListener {@AutowiredRabbitTemplate rabbitTemplate;@RabbitListener(queues = "simple.queue")public void Lister(String msg) {log.info(msg);}
}

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

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