Apache RocketMQ – Trillion Messaging in Practice 周新宇(花名：尘央) © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p PROFILE MCS, has rich experience in distributed system design and performance Zhou, Email: yukon@apache.org © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p Part I © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p 2016 2007 2010 2011 2012 2015 Notify Notify v3.0 MetaQ v2.0 v3.0 RocketMQ v3.0 OS Apache RocketMQ © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p MetaQ RocketMQ Notify Aliware MQ Ordered messaging，Pull model Commercial

�IFG=I�A=��GIFG=I�A=����E=N��IFG=I�A=� �� GIFG=I�A=���=��IFG=I�P �GF��)FE�A������������������"�E�D=�=IM=I���I������ GIFG=I�A=���=��IFG=I�P �GF��)FE�A��)��������-����"��IF�G��������� GIFG=I�A=���=��IFG=I�P .)"��FGA;��� �F;B=����GF�� �GF�����E=N��F;B=����GF�� GIFG=I�A=��� ��GC=�F�=����=��GG=I D�GG=I���E=N�,A=C���D=(��=���GC=�F�=����=��GG=I �NFI��"��;F�E����� �FGA;�=C=;�FI �=C=;�FI���E=N��=���C��FGA;�=C=;�FI C=;�FI �FGA;��� �F;B=���(FC� AE�=I�(FC� ��E=N �F;B=���(FC� ���������������� �NA����GG=I D�GG=I����������������� �NA���=C=;�FI �=C=;�FI���������������� �NA���IFG=I�A=� GIFG=I�A=��� �����:����:��� �����

14:9876 autoCreateTopicEnable=true autoCreateSubscriptionGroup=true 五、启动 # 启动 docker-compose up -d #进入容器测试 docker exec -it rmqbroker bash // 生产消息 ./tools.sh org.apache.rocketmq.example.quickstart.Producer com/noteshare?id=41831bf1 b70d4662f852ab0c6b1a3dd&sub=6704265BC771455E8A835F8E7462D595](文档：docke 部署rocketmq服务.note 链接：http://note.youdao.com/noteshare?id=41831bf1db70d4662f85 ab0c6b1a3dd&sub=67042 65BC771455E8A835F8E7462D595) 原文链接：docker-compose 安装 rocketmq

setCode(ResponseCode.PULL_RETRY_IMMEDIATE LY); responseHeader.setSuggestWhichBrokerId(MixAll.MASTER_I D); } break; } if (this.brokerController.getBrokerConfig().isSlaveReadEnable()) { // @3 // consume tps = (sum * 1000.0d) / (last.getTimestamp() - first.getTimestamp()); // @4 long timesDiff = last.getTimes() - first.getTimes(); if (timesDiff > 0) { // @5 avgpt = (sum * 1.0d) / timesDiff; } } my_consumer_0 5 //克隆一个订阅了该 topic 的消费组消费进度 ./mqadmin cloneGroupOffset -n 127.0.0.1:9876 -s my_consumer_01 -d my_consume r_05 -t TopicTest //重置消费进度到当前队列的最大值 ./mqadmin resetOffsetByTime -n 127.0.0.1:9876 -g my_consumer_05

RocketMQ 节点所在的⼦网的 ID 。此⼦网需存在于所选 VPC 中。 5 Bastion Security Group ID BastionSecurityGroupI D 必填项 希望用于堡垒机的安 全组的 ID (例如 sg7f16e910)。此安全组 需 要存在于您选择的 VPC 中。 Security Configuration 命令建立和 Bastion Host 的 ssh 连接，下图中红⾊的部分参数需要换成 用户环境对应的参数 命令：ssh -qTfnN -D PORTNUMBER -i KEYPAIR USERNAME@HOSTNAME 样例：ssh -qTfnN -D 40011 -i "rocketMQ.pem" ec2-user@ec2-54-223- 36-247.cn-north-1.compute 6. 输⼊ Proxy Server 的信息，如下图，完成后点击左下方的 Apply changes，注意 Port 对应的值需要设置为您建立 ssh tunnel 的本地端⼝，见第一步的-D 参数后 面的那个数字，如下图： 7. 点击 SwitchyOmega 插件并选择刚刚创建的 RocketMQ profile，如下图 Page 16 of 18

RocketMQ 节点所在的⼦⽹的 ID。此⼦⽹需存在于所选 VPC 中。 5 Bastion Security Group ID BastionSecurityGroupI D 必填项 希望⽤于堡垒机的安 全组的 ID (例如 sg7f16e910)。此安全组 需要存在于您选择的 VPC 中。 Security Configuration 连接，下图中红色的部分参数需要 换成用户环境对应的参数 Page 17 of 21 命令：ssh -qTfnN -D PORTNUMBER -i KEYPAIR USERNAME@HOSTNAME 样例：ssh -qTfnN -D 40011 -i "rocketMQ.pem" ec2-user@ec2-54-223-36- 247.cn-north-1.compute 6. 输入 Proxy Server 的信息，如下图，完成后点击左下方的 Apply changes， 注意 Port 对应的值需要设置为您建立 ssh tunnel 的本地端口，见第一步的-D 参数后面的那个数字，如下图： 7. 点击 SwitchyOmega 插件并选择刚刚创建的 RocketMQ profile，如下图 Page 19 of 21

will be the first discarded. c) LifoOrder - The last event received will be the first discarded. d) PriorityOrder - Events should be discarded in priority order, such that lower priority 项目开源主页：https://github mqbroker -n 192.168.1.1:9876 -c $ROCKETMQ_HOME/conf/2m-2s-async/broker-a-s.properties & ### 在机器 D，启劢第二个 Slave nohup sh mqbroker -n 192.168.1.1:9876 -c $ROCKETMQ_HOME/conf/2m-2s-async/broker-b-s.properties mqbroker -n 192.168.1.1:9876 -c $ROCKETMQ_HOME/conf/2m-2s-sync/broker-a-s.properties & ### 在机器 D，启劢第二个 Slave nohup sh mqbroker -n 192.168.1.1:9876 -c $ROCKETMQ_HOME/conf/2m-2s-sync/broker-b-s.properties

存储架构全面升级，RAFT 存储开源 轻量级Pull con sum er 发布 Request-Rep ly 特性支持 IPv 6 支持 © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p 2019 2020 M eta Q v 2 .0 RocketM Q v 3 .0 Ap a che RocketM Q 4.x Lin ux

Mean time between failure. ????: Mean time to recover. ???? = 1 seconds ???????????? = >?∗>?∗AB C D >?∗>?∗AB = 99.999% 1.4万亿 双十一当天高可用标准 0 200 400 600 800 1000 1200 1400 1600 1 6 11 16

Mean time between failure. ????: Mean time to recover. ???? = 1 seconds ???????????? = >?∗>?∗AB C D >?∗>?∗AB = 99.999% 1.4万亿 双十一当天高可用标准 0 200 400 600 800 1000 1200 1400 1600 1 6 11 16