一般我们在用到这种消息中件的时候，肯定会考虑要怎样才能保证数据不丢失，在面试中也会问到相关的问题。但凡遇到这种问题，是指3个方面的数据不丢失，即：producer consumer 端数据不丢失 broker端数据不丢失下面我们分别从这三个方面来学习，kafka是如何保证数据不丢失的 一.produ ...
分类：
其他好文 时间：
2021-01-18 10:53:52
阅读次数：
0
RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。如果不熟悉AMQP，直接看RabbitMQ的文档会比较困难。不过它也只有几个关键概念，这里简单介绍。 RabbitMQ的结构图如下： 几个概念说明： Broker：简单来说就是 ...
分类：
编程语言 时间：
2021-01-05 10:41:54
阅读次数：
0
1.MappedFile类属性说明 dubbo的核心是spi，看懂了spi那么duboo基本上也懂了，对于rmq来说，它的核心是broker，而broker的核心是commitlog、consumequeue、indexfile，而这些文件对应的最终都是MappedFile，那么搞明白了这个类，那么 ...
分类：
移动开发 时间：
2020-12-25 11:51:42
阅读次数：
0
在rocketmq中，nameserver充当了一个配置管理者的角色，看起来好似不太重要。然而它是一个不或缺的角色，没有了它的存在，各个broker就是一盘散沙，各自为战。 所以，实际上，在rocketmq中，nameserver也是一个领导者的角色。它可以决定哪个消息存储到哪里，哪个broker干 ...
分类：
其他好文 时间：
2020-12-18 12:41:19
阅读次数：
2
参考：https://www.cnblogs.com/xiaonq/p/14097376.html 1、创建tasks.py文件进行验证 from celery import Celery import time #测试 app = Celery('TASK', broker='redis://lo ...
分类：
其他好文 时间：
2020-12-14 13:33:33
阅读次数：
4
故障症状有一个Centreon单节点监控系统（不含分布式），隔三差五的挂掉，幸好我们安排人手，时不时访问web管理后台，才没出现大的纰漏。其主要症状是Poller失效，但系统其它进程比如Apache、PHP、Centreon-engine等运行正常。在CentreonWeb管理界面重载（reload）或者重启（restart）cbd服务，无效；登录系统，执行指令systemctlstartcbd,
分类：
其他好文 时间：
2020-12-09 11:37:51
阅读次数：
8
消息丢失的场景如果KafkaProducer使用“发后即忘”的方式发送消息，即调用producer.send(msg)方法来发送消息，方法会立即返回，但此时并不能说明消息已经发送成功。消息发送方式详见初次邂逅Kafka生产者。如果在消息过程中发生了网络抖动，那么消息就会丢失；或发送的消息本身不符合要求，如大小超过Broker端的承受能力等（消息太大的情况在生产中实际遇到过，最后通过在发送前将消息分
分类：
其他好文 时间：
2020-12-08 12:53:00
阅读次数：
5
现象最近收到很多RocketMQ使用者反馈在消息发送过程中偶尔会出现如下4个错误信息之一：[REJECTREQUEST]systembusy,startflowcontrolforawhiletoomanyrequestsandsystemthreadpoolbusy,RejectedExecutionException[PC_SYNCHRONIZED]brokerbusy,startflowco
分类：
其他好文 时间：
2020-12-08 12:21:48
阅读次数：
4
温馨提示：本文基于Kafka2.2.1版本。如果觉得源码阅读比较枯燥，本文的中间有Sender线程的工作流程图。上文《源码分析Kafka消息发送流程》已经详细介绍了KafkaProducersend方法的流程，该方法只是将消息追加到KafKaProducer的缓存中，并未真正的向broker发送消息，本文将来探讨Kafka的Sender线程。在KafkaProducer中会启动一个单独的线程，其名
分类：
编程语言 时间：
2020-12-08 12:00:53
阅读次数：
6
本文将在RocketMQ消息发送systembusy、brokerbusy原因分析与解决方案的基础上，结合生产上的日志尝试再次理解brokerbusy以及探讨解决方案。首先，brokerbusy相关的日志关键字如下：[REJECTREQUEST]systembusytoomanyrequestsandsystemthreadpoolbusy[PC_SYNCHRONIZED]brokerbusy[P
分类：
其他好文 时间：
2020-12-07 12:48:48
阅读次数：
17
