RocketMQ服务搭建 下载RocketMQ源码: http://mirror.bit.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-source-release.zip 执行以下命令： unzip rocketmq-all-4.4.0-sourc ...
分类：
其他好文 时间：
2019-12-30 11:11:10
阅读次数：
77
使用RocketMQ发送消息抛出异常，异常如下： 原因： Broker 禁止自动创建Topic，且用户没有通过手动创建此Topic，或者broker 和 Nameserver网络不同； 解决方案： 1. 修改broker.properties配置，自动创建topic，添加如下： autoCreate ...
分类：
Web程序 时间：
2019-12-29 16:41:22
阅读次数：
632
1、背景 公司一个 RocketMQ 集群由4主4从组成，突然其中3台服务器“竟然”在同一时间下线，其监控显示如下： 依次查看三台机器的监控图形，时间戳几乎完美“吻合”，不可思议吧。 2、故障分析 出现问题，先二话不说，马上重启各服务器，尽快恢复集群，降低对业务的影响，接下来开始对日志进行分析。 J ...
分类：
系统相关 时间：
2019-12-29 16:37:18
阅读次数：
106
问题：关于消息队列的事物问题 spring的@Transactional标签只有当整个方法执行完成后才commit，这样如果因为网络问题即使整个方法执行成功，方法中消息队列发送成功，但是commit时失败了，减库存的rocketmq无法回滚。 解决方法1：spring @Transactional提 ...
分类：
其他好文 时间：
2019-12-24 23:43:56
阅读次数：
113
# 架构设计 1 技术架构 RocketMQ架构上主要分为四部分，如上图所示: Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递，投递的过程支持快速失败并且低延迟。 Consumer：消息消费的角色，支持分布式 ...
分类：
其他好文 时间：
2019-12-24 14:04:48
阅读次数：
75
# 运维管理 ### 1 集群搭建#### 1.1 单Master模式这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。##### 1）启动 NameServer```bash### 首先启动Name Server$ nohup sh mq ...
分类：
其他好文 时间：
2019-12-24 13:56:26
阅读次数：
80
# 特性(features) 1 订阅与发布 消息的发布是指某个生产者向某个topic发送消息；消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。 2 消息顺序 消息有序指的是一类消息消费时，能按照发送的顺序来消费。例如：一个订单产生了三条消息分别是订单 ...
分类：
其他好文 时间：
2019-12-24 13:45:00
阅读次数：
95
最佳实践 1 生产者 1.1 发送消息注意事项 1 Tags的使用 一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags("T ...
分类：
其他好文 时间：
2019-12-24 13:31:38
阅读次数：
76
# 基本概念 ## 1 消息模型（Message Model）RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Br ...
分类：
其他好文 时间：
2019-12-24 13:23:29
阅读次数：
53
RcoketMQ：【 1.低延时：在高压下，1毫秒内超过99.6%的反应延迟。 2.面向金融：具有跟踪和审计功能的高可用性。 3.行业可持续发展：保证了万亿级的消息容量。 4.厂商中立：一个新的开放的分布式消息和流媒体标准自最新的4.1版本。 5.BigData友好：批量转移与多功能集成的洪水吞吐量 ...
分类：
其他好文 时间：
2019-12-24 12:04:42
阅读次数：
104
