kafka介绍 kafka 最开始是 Linkedin 用来处理海量的日志信息，后来 linkedin 于 2010 年贡献给了 Apache 基金会并成为了顶级项目。 后来开发 kafka 的一些人出来创立了一家公司 confluent，专门从事 kafka 的开发维护和在它之上提供各种服务。 现在 kafka 把它定义为一个分布式数据流处理平台。 ka...
环境准备 kafka依赖zookeeper，所以搭建kafka需要先配置zookeeper。网格信息如下： zookeeper 192.168.56.101:2181 kafka1 192.168.56.101:9092 kafka2 192.168.56.101:9093 kafka3 192.168.56.101:9094 开始搭建...
一：redis中发布订阅功能（http://www.redis.cn/commands.html#pubsub） PSUBSCRIBE pattern [pattern …]：订阅一个或者多个符合pattern格式的频道 PUBLISH channel message：发布消息到chanel中 PUBSUB subcommand [argument [a...
目录 消息模型 集群部署 NameServer producer消息队列选择器MessageQueueSeleetor 消息存储 commitLog数据存储文件 ConsumeQueue索引文件 IndexFile索引文件 消息查找 根据偏移量查询 根据消息id查询 根据消息key查询 实时更新消息消费队列与索引文件 消息队列与索引文件恢复 过期...
一，activeMq安装 1，下载activeMq，放置到电脑某个目录， 2，直接运行 /bin/activemq.bat脚本，即可启动activeMq 3，访问网址localhost:8161，即可查看activeMq网页界面 4，activeMq目录中有一些例子，可以参考； 二，springboot集成activeMQ 1,添加依赖 <!--...
依照<ROS-3 : Catkin工作空间和ROS功能包>，创建catkin工作空间，并在起src下创建功能包ros_demo_pkg，依赖项为roscpp、std_msgs、actionlib、actionlib_msgs，并构建该空功能包。ROS中节点间的基本通讯方式是topic，即publish/subscribe模式。以下介绍如何创...
要求及文件 用户可以添加新主题，添加新条目，以及编辑既有条目 forms.py urls.py views.py html new_topic.html new_entry.html edit_entry.html 添加新主题 new_topic.html topics.html 添加新条目 new_entry.ht...
一、基本结构 三台机器组成的Kafka集群，每台机器启动一个Kafka进程，即Broker 向broker发送消息的客户端是Producer，拉取消息的客户端是Consumer Producer和Consumer都是用户实现的 broker只负责数据存储，不保存任何Producer和Consumer的信息 Kfaka通过zookeeper管理集群 bro...
部署环境 服务 所属ip和占用的端口 zookeeper 192.169.1.71:2181 kafka1 192.169.1.71:9092 kafka2 192.169.1.70:9092 kafka3 192.169.1.21:9092 搭建zookeeper + kafka前需要安装jdk，jdk需1.8及以上 一、...
MQTT 是一种基于发布订阅模型的即时通讯协议，由于轻巧，开源，易用，耗能少，支持 QOS/遗言（WILL）等特性，正被广泛应用于物联网和移动互联网。消息队列 MQ 提供了对 MQTT 协议的支持，完全兼容 MQTT 标准协议，但是在使用 MQ MQTT 时，对比标准协议，需要注意两点：1. 父级 Topic 需要提前创建根据标准 MQTT 协议，Topi...