1.大纲
Kafka控制节点用的是什么？
消费者、生产者是如何理解的？
2.Kafka控制节点用的是什么？
基于zookeeper协调的分布式消息系统
3.消费者、生产者是如何理解的？
消息系统通常都会由生产者，消费者，Broker三大部分组成，生产者会将消息写入到Broker，消费者会从Broker中读取出消息，不同的MQ实现的Broker实现会有所不同，不过Broker的本质都是要负责将消息落地到服务端的存储系统中。具体步骤如下：-
生产者客户端应用程序产生消息：
- 客户端连接对象将消息包装到请求中发送到服务端
- 服务端的入口也有一个连接对象负责接收请求，并将消息以文件的形式存储起来
- 服务端返回响应结果给生产者客户端
-
消费者客户端应用程序消费消息：
- 客户端连接对象将消费信息也包装到请求中发送给服务端
- 服务端从文件存储系统中取出消息
- 服务端返回响应结果给消费者客户端
- 客户端将响应结果还原成消息并开始处理消息
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。