我想用rocketMq大家主要是用它的事务，所以拿着官方的代码体验一下 环境 用docker安装rocketMq #需要创建文件夹 /docker/namesrv/logs /docker/namesrv/store /docker/rocketmq/logs /docker/rocketmq/st ...
分类：
其他好文 时间：
2021-04-20 14:35:27
阅读次数：
0
市场上常见的消息队列有如下： ActiveMQ：基于JMS ZeroMQ：基于C语言开发 RabbitMQ：基于AMQP协议，erlang语言开发，稳定性好 RocketMQ：基于JMS，阿里巴巴产品 Kafka：类似MQ的产品；分布式消息系统，高吞吐量 用rabbitmq比较多 ...
分类：
其他好文 时间：
2021-04-19 15:27:26
阅读次数：
0
核心概念 Topic：消息主题，一级消息类型，通过Topic对消息进行分类。 Tag：消息标签，二级消息类型，用来进一步区分某个Topic下的消息分类。 Message ID：消息的全局唯一标识，由消息队列RocketMQ版系统自动生成，唯一标识某条消息。 Message Key：消息的业务标识，由 ...
分类：
其他好文 时间：
2021-04-19 14:11:21
阅读次数：
0
由于对RocketMq的MessageQueue一直不理解，其实就是可以理解成consumeQueue 有原文为证 CommitLog：是消息主体以及元数据的存储主体，对CommitLog建立一个ConsumeQueue，每个ConsumeQueue对应一个（概念模型中的）MessageQueue， ...
分类：
其他好文 时间：
2021-04-13 12:55:31
阅读次数：
0
问题-RocketMQ顺序消息收不到或者只能收到一部分消息分析-集群消费模式下有两个同名 Tag 在同一 Topic 消费组下，所以被 RocketMQ 负载均衡了 ...
分类：
编程语言 时间：
2021-04-13 12:44:52
阅读次数：
0
1、rocketmq集群特点: NameServer是一个几乎无状态节点，可集群部署，节点之间无任何信息同步。 Broker部署相对复杂，Broker分为Master与Slave，一个Master可以对应多个Slave，但是一个Slave只能对应一个Master，Master与Slave的对应关系通 ...
分类：
其他好文 时间：
2021-04-12 12:37:16
阅读次数：
0
在看书梳理代码的时候发现了一个变量：compressMsgBodyOverHowmuch （在DefaultMQProducer.java中）字面意思就是：消息体超过该值则启用压缩， 默认4K。 以前看过一点压缩算法的一些东西，想看看rocket mq中是如何进行压缩的。 在DefaultMQPro ...
分类：
其他好文 时间：
2021-04-05 11:53:45
阅读次数：
0
Half Message： 预处理消息，当broker收到此类消息后，会存储到RMQ_SYS_TRANS_HALF_TOPIC的消息消费队列中 检查事务状态： Broker会开启一个定时任务，消费RMQ_SYS_TRANS_HALF_TOPIC队列中的消息， 每次执行任务会向消息发送者确认事务执行状 ...
分类：
编程语言 时间：
2021-03-31 12:18:34
阅读次数：
0
producer： **默认超时时间** /*** Timeout for sending messages.*/private int sendMsgTimeout = 3000; // 异步发送时 重试次数，默认 2 producer.setRetryTimesWhenSendAsyncFail ...
分类：
编程语言 时间：
2021-03-31 12:15:32
阅读次数：
0
RocketMQ高级:RocketMQ集群,RocketMQ控制台,RocketMQ高级特性:主从数据复制，负载均衡，消息重试，死信队列，消息重复消费与消息幂等 ...
分类：
其他好文 时间：
2021-03-30 13:24:54
阅读次数：
0
