。

以其高吞吐量、低延迟、高可用性等特点而广受欢迎。

支持Java#xff0c;C,

Python,

异步解耦#xff1a;可以实现上游和下游业务系统的松耦合设计#xff0c;使得服务部…RocketMQ

是一款由阿里巴巴集团开发并开源给Apache软件基金会的分布式消息及流处理平台。

以其高吞吐量、低延迟、高可用性等特点而广受欢迎。

支持JavaC,

Python,

异步解耦可以实现上游和下游业务系统的松耦合设计使得服务部分节点异常不会影响到核心交易系统的正常运转。

在电商、金融等分布式系统中这种解耦设计尤为重要。

削峰填谷在如秒杀、大促等大型活动中系统会面临巨大的流量冲击。

RocketMQ利用其高性能的消息处理能力可以有效地应对这种流量冲击保证系统的稳定运行。

顺序消息支持顺序消息分区有序可以确保消息的先进先出。

这在交易系统中的订单创建、支付、退款等流程中尤为重要因为这些流程对消息的顺序有严格要求。

分布式事务消息支持分布式事务消息可以保证分布式事务的强一致性。

这在涉及多个服务的分布式系统中非常有用可以确保数据的一致性和完整性。

RocketMQ优点

高吞吐量和低延迟能够处理大规模消息流并提供低延迟的消息传递。

这使得它非常适合处理高并发的应用场景如电子商务和金融交易系统。

可靠性具有高度可靠的消息传递机制。

它支持消息持久化和复制确保消息不会丢失并能够在故障发生时进行自动恢复。

分布式扩展支持水平扩展可以方便地添加新的消息生产者和消费者来应对负载增加的情况。

RocketMQ架构

发布订阅模型中定义的独立的消费身份分组用于统一管理多个消费者。

消费者Consumer

AUTO_CREATE_SUBSCRIPTION_GROUPtrue

10911:10911

JAVA_OPTS-Drocketmq.namesrv.addrnamesrv:9876

styletang/rocketmq-console-ng总结

RocketMQ

JAVA_OPTS-Drocketmq.namesrv.addrnamesrv:9876

styletang/rocketmq-console-ng如果是外网环境

run

/usr/data/rocketMQ/data/broker/logs

mkdir

/usr/data/rocketMQ/data/broker/store

mkdir

/usr/data/rocketMQ/data/broker/conf/broket.conf

brokerClusterName

autoCreateTopicEnabletruedocker

run

/usr/data/rocketMQ/data/broker/logs:/root/logs

/usr/data/rocketMQ/data/broker/store:/root/store

/usr/data/rocketMQ/data/broker/conf/broker.conf:/opt/rocketmq/conf/broker.conf

--name

/opt/rocketmq/conf/broker.conf.NET

RocketMQ

ex){Console.WriteLine($Exception:

{ex.Message});}finally{producer.Stop();}Consumer

var

XTrace.Log,};consumer.OnConsume

OnConsume;consumer.Configure(MqSetting.Current);consumer.Start();_consumer

consumer;