为了学习和方便测试，总是要启动一个单机版的。下载 http://rocketmq.apache.org/dowloading/releases/ 1. 要先配置环境变量 2. 然后进入bin目录启动NameServer 3. 启动Broker 启动 可能会出现一个错误: 找不到或无法加载主类 Fil ...
分类：
其他好文 时间：
2019-06-14 16:26:28
阅读次数：
290
Celery是什么? celey是芹菜 celery是基于Python实现的模块,用于执行异步延时周期任务的 其结构组成是由 1.用户任务 app 2.管道任务broker用于存储任务 官方推荐redis rabbitMQ /backend 用于存储任务执行结果的 3.员工 worker Celer ...
分类：
其他好文 时间：
2019-06-12 16:38:30
阅读次数：
176
ZooKeeper+ActiveMQ可以实现主从模式和集群模式 一、主从模式 Master-Slave主从模式是一种高可用解决方案，在Zookeeper中注册若干ActiveMQ Broker，其中只有一个Broker提供对外服务（Master），其他Broker处于待机状态（Slave）。当Mas ...
分类：
其他好文 时间：
2019-06-10 18:36:46
阅读次数：
119
1) Modify the ActiveMQ configuration file to clear out the messages queues. Note that after the broker restart, the parameter should be set back to ‘f ...
分类：
其他好文 时间：
2019-06-10 18:27:40
阅读次数：
98
Controller机制 1 前言 Controller 是从Kafka集群中选取一个的broker，负责管理topic分区和副本的状态的变化，以及执行重分配分区之类的管理任务。 第一个启动的broker会成为一个controller，它会在Zookeeper上创建一个临时节点(ephemeral) ...
分类：
其他好文 时间：
2019-06-09 18:22:57
阅读次数：
106
Kafka partition 副本迁移与broker上下线 1 前言 Controller 在初始化时，会利用 ZK 的 watch 机制注册很多不同类型的监听器，当监听的事件被触发时，Controller 就会触发相应的操作。 Controller 在初始化时，会注册多种类型的监听器，主要有以下 ...
分类：
其他好文 时间：
2019-06-09 18:12:10
阅读次数：
116
副本和分区状态机 1 前言 Controller 是从Kafka集群中选取一个的broker，负责管理topic分区和副本的状态的变化，通过上篇我们知道了controller的启动流程，这篇我们学习一下分区和副本状态机。 分区状态机记录着当前集群所有 Partition 的状态信息以及如何对 Par ...
分类：
其他好文 时间：
2019-06-09 18:09:35
阅读次数：
84
replica副本同步机制 1 前言 Kafka的流行归功于它设计和操作简单、存储系统高效、充分利用磁盘顺序读写等特性、非常适合在线日志收集等高吞吐场景。 Kafka特性之一是它的复制协议。复制协议是保障kafka高可靠性的关键。对于单个集群中每个Broker不同工作负载情况下，如何自动调优Kafk ...
分类：
其他好文 时间：
2019-06-09 18:08:58
阅读次数：
117
+ 曾经有个哥们提了一个这方面的requests，但是最终没有合入的celery中去，所以目前celery没有这个功能，祥见： 1. https://github.com/celery/kombu/pull/912 2. https://github.com/celery/kombu/issues/ ...
分类：
其他好文 时间：
2019-06-09 12:39:25
阅读次数：
93
一、问题答案 是不可以的 而且后注册的会替换前注册的，MqConsumer2会替换MqConsumer，并且只结束tag-2的消息 二、为什么呢？ 我们从源码的角度来分析下 1.订阅消息的方法 public void subscribe(String topic, String subExpress ...
分类：
其他好文 时间：
2019-06-08 01:07:33
阅读次数：
2837
