快速开始

约 49 个字 35 行代码 预计阅读时间 1 分钟

访问 RabbitMQ 的管理控制台

引入依赖

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

配置rabbitmq服务端信息

spring:
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    virtual-host: /hmall
    username: fmy
    password: 123456

利用RabbitTemplate 发送消息

@SpringBootTest
public class SpringAmqpTest {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Test
    void testSendMessage() {
        String queueName = "fmy";
        String msg = "hello world";
        rabbitTemplate.convertAndSend(queueName, msg);
    }
}

利用@RabbitListener注解声明要监听的队列，监听消息

@Slf4j
@Component
public class MqListeners {
    @RabbitListener(queues = "fmy")
    public void listenSimpleQueue(String msg){
        System.out.println("消费者收到了fmy的消息：[" + msg + "]" );

    }
}

颜色主题调整

red pink purple indigo blue cyan teal green lime orange brown grey black white

评论区~

有用的话请给我个赞和 star =>
快来跟我聊天~