前言
前面学习了消息队列RocketMQ的基本理论,现在来动手实操一下。
注意:
RocketMQ和微服务有强相关的联系,在下载之前一定要核对一下版本
JDK
Spring Cloud/Spring cloud Alibaba
RocketMQ
由于只是测试,我只用SpringBoot简单搭建一下。
环境
JDK 17.0.12
RocketMQ 5.3.0
SpringBoot 3.3.4
查看RocketMQ所支持的Spring Cloud版本:https://github.com/alibaba/spring-cloud-alibaba/wiki/版本说明...
什么是消息队列?
消息队列可以理解为一个盛放消息的“碗”,充当了一个容器的作用。举个例子,当我们手机关机时,接收不到微信的消息,但一旦打开手机。微信便会弹出消息通知,那么这些在我们手机关机时所发送的消息所存放的容器就叫做消息队列
由此,我们可以得到一个消息队列的大概消息模型模型
它具备三个部分
消息的“生产者”-Producer
存放消息的队列的容器,专业的术语叫做“消息主题”-Topic
消息的“消费者”-Consumer
可扩展的消息模型
有了上面的基础模型之后,消息队列便可以扩展为两个生产者-Producer、两组消费者-Consumer和两个消息主题-Top...