问题导读 Apache Kafka在全球各个领域各大公司获得广泛使用，得益于它强大的功能和不断完善的生态。其中Kafka动态配置是一个比较高频好用的功能，下面我们就来一探究竟。 动态配置是如何设计的？ 动态配置优先级是怎样的？ Broker初始化是如何读取配置的？ 动态配置支持哪些特性功能？ 动态配 ...
分类：
其他好文 时间：
2020-02-08 00:05:05
阅读次数：
80
1. celery 介绍 1. celery 应用举例 2. celery 有什么优点？ 3. celer 基本工作流程图 user : 用户程序，用于告知celery去执行一个任务 broker : 存放任务 （依赖RabbitMQ 或 Redis, 进行存储） worker : 执行任务 4. ...
分类：
其他好文 时间：
2020-02-07 17:00:30
阅读次数：
60
大家知道，期货CTP接口是由上期技术公司提供的，它提供的源码和范例都是用C++语言写的，这在应用上有一定局限性。比如实盘中需要数据库、程序化、K线图，需要这样那样的功能，下单之前要做许多判断和准备……用C++来写会很麻烦的。但是C#不怕做这些麻烦事，C#就是用来干脏活累活的，你把界面、应用逻辑啥的都 ...
分类：
编程语言 时间：
2020-02-06 22:58:20
阅读次数：
125
1.1. 控制台使用 RocketMQ 提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker 等信息的管理； 登录控制台 首先进入RocketMQ 工程，进入/RocketMQ/bin 在该目录下有个mqadmin 脚本 查看帮助 在mqadmin 下可以查看有哪些命令 sh mqa ...
分类：
其他好文 时间：
2020-02-06 14:53:01
阅读次数：
103
(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
