参考文档:
写在最前:
MQ(消息队列)是用于诸如异步实现、异构系统通信等常见的技术方案之一。
在日常技术方案中,从测试工程师的视角出发,主要需要知道以下几点:
- MQ本身不具备幂等性。 在实际业务中,因为网络异常,很容易导致消息重发,又或者可能因为MQ宕机重启后,重复消费等。所以往往基于业务所需,当有写操作时,消费者服务的设计者需要自行保证业务的幂等。
- 在分布式服务中,需要考虑MQ消息是否能使事务达成最终一致性;如果MQ宕机或网络等问题导致消息无法被消费,是否需要增加补偿机制。
- MQ的日志查看。
关于MQ
MQ即Message Queue的意思。其是异步通信系统,是分布式架构的常用解决方案之一。
在当下主流MQ中,主要包括了 Kafka (这不仅仅是消息中间件),RocketMQ,RabbitMQ等。在Java技术栈领域中,基本都是选用RocketMQ作为消息中间件。RocketMQ架构
RocketMQ 主要包括了: NameServer 、Broker 、Producer 和 Consumer
NameServer: 提供轻量级的服务发现和路由。 每个 NameServer 记录完整的路由信息,提供等效的读写服务,并支持快速存储扩展。
Broker: 通过提供轻量级的 Topic 和 Queue 机制来处理消息存储,同时支持推(push)和拉(pull)模式以及主从结构的容错机制。
Producer:生产者,产生消息的实例,拥有相同 Producer Group 的 Producer 组成一个集群。
Consumer:消费者,接收消息进行消费的实例,拥有相同 Consumer Group 的
Consumer 组成一个集群。