考虑转发任务未成功执行，此时消息服务器Broker宕机，导致commitlog，consumeQueue，IndexFile文件数据不一致。 看一下mq关于存储文件的加载流程： public boolean load() { boolean result = true; try { boolean ...
分类：
其他好文 时间：
2020-01-27 09:42:08
阅读次数：
85
目录 简介 Kafka架构 Kafka存储策略 Kafka删除策略 Kafka broker Kafka Design The Producer The Consumer 复制（Replication） 日志压缩（Log Compaction） Distribution Zookeeper协调控制 ...
分类：
其他好文 时间：
2020-01-26 19:24:21
阅读次数：
67
分布式系统中，如何在各个应用之间高效的进行通信，是系统设计中的一个关键。 使用 消息代理（message broker） 是一个优雅的解决方案。 RabbitMQ 就是一个被广泛应用的消息代理，遵循 AMQP协议 。 接下来我们就了解一下： Message Broker 概念 AMQP 协议的核心构 ...
分类：
其他好文 时间：
2020-01-22 10:52:09
阅读次数：
78
Celery - 一个懂得 异步任务 , 定时任务 , 周期任务 的芹菜 1.什么是Celery?Celery 是芹菜Celery 是基于Python实现的模块, 用于执行异步定时周期任务的其结构的组成是由 1.用户任务 app 2.管道 broker 用于存储任务 官方推荐 redis rabbi ...
分类：
其他好文 时间：
2020-01-21 15:59:09
阅读次数：
62
启动broker之后我们可以看到下面这些文件 1.config包含了运行期间一些配置信息，主要包括下列信息。 consumerFilter.json：主体消息过滤信息 consumerOffset.json：集群消费模式消息消费进度 delayOffset.json：延时消息队列拉取进度 subsc ...
分类：
其他好文 时间：
2020-01-21 15:57:22
阅读次数：
110
一、创建项目并导入依赖 org.springframework.boot spring-boot-starter-security org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boo... ...
分类：
编程语言 时间：
2020-01-18 14:54:19
阅读次数：
97
同步发送，最多发送 3 次 这里指的是发送成功，等待 broker 的响应时发生超时，客户端有理由认为是网络不好，数据没有到达 broker，因此重复发送消息，也就是这种情况会导致 broker 存在重复消息。当发生 RemotingException 或 MQClientException 时，会 ...
分类：
其他好文 时间：
2020-01-17 19:01:33
阅读次数：
195
MQ产品常用的三种协议： 1:JMS rocketMQ，activeMQ 2.AMQP RabbitMq 3.MQTT activeMQ RabbitMQ是AMQP的一种实现。 AMQP是什么？ 基本概念 broker：消息代理 producer: 消息的生产者 consumer: 消息的消费者 e ...
分类：
其他好文 时间：
2020-01-16 22:25:32
阅读次数：
93
路由发现：缓存中的路由信息什么时候更新呢？ 由QueueData转topicPublishInfo的List<QueueMessage>： 选择消息队列： sendLatencyFaultEnable=false，默认不启动Broker故障延迟机制， sendLatenFaultEnable=tru ...
分类：
其他好文 时间：
2020-01-16 00:50:47
阅读次数：
93
kafka 相关的知识进入 /usr/local/kafka 目录下查看端口 vim zookeeper.properties #文件中dataDir=/tmp/zookeeper代表zookeeper数据存储路径，clientPort=2182代表zookeeper的端口号为：2182，消费者需要 ...
分类：
其他好文 时间：
2020-01-13 20:22:45
阅读次数：
124
