简介
在点对点消息系统中,消息持久化到一个队列中。此时,将有一个或多个消费者消费队列中的数据。但是一条消息只能被消费一次。当一个消费者消费了队列中的某条数据之后,该条数据则从消息队列中删除。该模式即使有多个消费者同时消费数据,也能保证数据处理的顺序。这种架构描述示意图如下
总结:不管是用上面哪种模式,只要知道生产者生产数据,通过一些列配置连接中间的管道,然后消费者端也通过一系列配置连接到中间的管道,进行对管道的数据监听,一旦监听到数据,并且符合一定的暗号鉴权,就进行从管道里拿来该数据进行消费。
Kafka Tool
连接服务器
Topic
Partition
分析消息体
连接 Kafka 服务器
Cluster name:左侧服务器名称,随便填写
Kafka Cluster Version:选择 2.0 即可
Zookeeper Host:IP地址
Zookeeper Port:端口号,默认2181
chroot path:默认 / 即可
在填写完 Zookeeper Host,就可以点击旁边的【Ping】按钮测试下是否 IP 可以连通。
填写完后,可以点击下方的【Test】进行测试 Kafka 服务器是否能连通。
都 OK 后,可以点击下方的【Add】按钮进行添加该服务器到左边列表。