启动broker之后我们可以看到下面这些文件 1.config包含了运行期间一些配置信息，主要包括下列信息。 consumerFilter.json：主体消息过滤信息 consumerOffset.json：集群消费模式消息消费进度 delayOffset.json：延时消息队列拉取进度 subsc ...
分类：
其他好文 时间：
2020-01-21 15:57:22
阅读次数：
110
总得来说 有些像页告诉缓存那样，为了避免页面被换出到交换区，mq申请了一块内存，并且用指定这些页面不能被操作系统换出，然后将这些内存分配给业务使用： ...
分类：
其他好文 时间：
2020-01-21 14:42:34
阅读次数：
79
引入java包： 本项目中仅引入了四个java包：amqp-client-5.7.3.jar，spring-rabbit-2.2.2.RELEASE.jar，spring-retry-1.2.4.RELEASE.jar，spring-amqp-2.2.2.RELEASE.jar spring-rab ...
分类：
编程语言 时间：
2020-01-21 13:23:55
阅读次数：
139
使用背景 在实际工作过程中，因网络波动、服务并发限制等原因造成接口服务调用失败，MQ发送消息失败等，可以采取重试手段，重试机制是常见的一种处理问题的手段。 重试方式有很多，如可以自己通过代码逻辑实现，但不是很优雅。 而spring-retry可以以优雅的方式实现重试： Retry重试框架，支持AOP ...
分类：
编程语言 时间：
2020-01-20 20:34:51
阅读次数：
128
MappedFileQueue的封装 MappedFileQueue是MappedFile的管理容器，MappedFileQueue是对存储目录的封装。 查找MappedFile： 1.根据时间戳来查找MappedFile： 2.根据消息偏移量offset查找MappedFile mq采用定时删除策 ...
分类：
其他好文 时间：
2020-01-18 16:39:50
阅读次数：
69
MappedFile#appendMessagesInner ...
分类：
其他好文 时间：
2020-01-18 14:51:14
阅读次数：
49
ActiveMQ 基本定义 什么是消息中间件？ 消息中间件顾名思义实现的就是在两个系统或两个客户端之间进行消息传送。 什么是ActiveMQ？ ActiveMQ 是一种开源的基于JMS（Java Message Servie）规范的一种消息中间件的实现，ActiveMQ的设计目标是提供标准的，面向消 ...
分类：
其他好文 时间：
2020-01-18 01:34:18
阅读次数：
96
1、队列、栈 2、双链表 3、MQ 4、分区锁-correntHashMap 实现 5、分布式锁 6、job-分块执行 7、redis、DB一致性分析 ...
分类：
其他好文 时间：
2020-01-17 11:47:12
阅读次数：
54
前言消息中间件的可靠性消息传递，是消息中间件领域非常重要的方案落实问题（在这之前的MQ理论，MQ选型是抽象层次更高的问题，这里不谈）。并且这个问题与日常开发是存在较大的关联的。可以这么说，凡是使用了MQ的，机会都要考虑这个问题。当然也有一些原始数据采集，日志数据收集等应用场景对此没有过高要求。但是大多数的业务场景，对此还是有着较高要求的。比如订单系统，支付系统，消息系统等，你弄丢一条消息，嘿嘿。网
分类：
其他好文 时间：
2020-01-17 09:21:18
阅读次数：
66
comitlog文件 ConsumerQueue文件 IndexFile文件 RocketMQ将所有主题的消息存储在同一个文件中，确保消息发送时顺序写文件。 为了提高消息消费的效率RocketMQ引入了ConsumeQueue消息队列文件，每个消息主题包含一个多个消息消费队列，每一个消费队列有一个消 ...
分类：
其他好文 时间：
2020-01-17 09:16:40
阅读次数：
110
