(2020 02 05 10:30) 我们提到过 Broker 需要知道 Client 是否非正常地断开了和它的连接，以发送遗愿消息。实际上 Client 也需要能够很快地检测到它失去了和 Broker 的连接，以便重新连接。 MQTT 协议是基于 TCP 的一个应用层协议，理论上 TCP 协议在丢 ...
分类：
其他好文 时间：
2020-02-05 11:37:19
阅读次数：
283
背景：因为公司收集终端盒子数据的kafka服务偶尔会倒，所以考虑使用kafka的分布式，增加broker节点，来提高系统的可用性。当然，zookeeper服务节点也是可以增加的，但不在本文范围内。 具体步骤如下： 1. 新加kafka服务，并启动 如果是同一服务器，则可以拷贝新建server.pro ...
分类：
其他好文 时间：
2020-02-05 09:33:24
阅读次数：
108
一、参考文档 1、emqtt - 开源Erlang MQTT Broker/Client项目介绍 2、Emqtt -- 01 -- 服务搭建 3、http://emqtt.io/docs/v2/install.html#installing-from-source 4、MQTTBox(mqtt cl ...
分类：
其他好文 时间：
2020-02-04 23:58:44
阅读次数：
130
项目中经常有需求不是消费kafka队列全部的数据，取区间数据 查询kafka最大的offset: ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.1.4:9092 --topic zhangyi --time ...
分类：
其他好文 时间：
2020-02-03 20:50:51
阅读次数：
99
什么是Clelery Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统。专注于实时处理的异步任务队列。同时也支持任务调度。 Celery的架构由三部分组成，消息中间件（message broker），任务执行单元（worker）和任务执行结果存储（task result store）组 ...
分类：
其他好文 时间：
2020-01-31 23:01:41
阅读次数：
86
点击 Manage ActiveMQ broker 无法显示admin界面 解决方法：修改activemq.xml 和 jetty.xml文件 把所有0.0.0.0修改为127.0.0.1 成功： 账户密码都是admin ...
分类：
其他好文 时间：
2020-01-30 17:24:45
阅读次数：
61
producer 在发送消息的时候，会生成一个 "唯一" 的 msgId，broker 会为这个 msgId 创建哈希索引 UNIQ_KEY 由客户端生成 org.apache.rocketmq.common.message.MessageClientIDSetter#createUniqID ms ...
分类：
其他好文 时间：
2020-01-30 14:40:40
阅读次数：
103
zookeeper是作为一个数据管道存储kafka消息队列，上一篇已经解决怎样部署一个zookeeper集群，基于zookeeper集群基础上，本篇介绍怎样部署kafka集群。 mv kafka_2.13-2.4.0.tgz /usr/local tar -zxvf kafka_2.11-2.4.0 ...
分类：
其他好文 时间：
2020-01-30 11:20:41
阅读次数：
140
不管是DefaultMQProducer还是DefaultMQPushConsumer，本质都是封装类，发起请求的实际上是RemotingClient， 它的start方法调用之后，启动了一个netty的客户端bootstrap，每次需要与nameService或者broker进行连接的时候，调用 ...
分类：
其他好文 时间：
2020-01-28 19:20:32
阅读次数：
134
#include <iostream> using namespace std; #define INFINITY 65536//无穷大 #define MAX_VERTEX_NUM 10//最大顶点个数 typedef enum{DG,DN,UDG,UDN}GraphKind;//有向图，有向网， ...
分类：
其他好文 时间：
2020-01-28 17:22:56
阅读次数：
177
