Kafka 生产者-消费者
  IDYp5aKWcwEJ 2023年11月02日 28 0

消息系统通常都会由生产者,消费者,Broker三大部分组成,生产者会将消息写入到Broker,消费者会从Broker中读取出消息,不同的MQ实现的Broker实现会有所不同,不过Broker的本质都是要负责将消息落地到服务端的存储系统中。具体步骤如下:

  1. 生产者客户端应用程序产生消息:
  1. 客户端连接对象将消息包装到请求中发送到服务端
  2. 服务端的入口也有一个连接对象负责接收请求,并将消息以文件的形式存储起来
  3. 服务端返回响应结果给生产者客户端
  1. 消费者客户端应用程序消费消息:
  1. 客户端连接对象将消费信息也包装到请求中发送给服务端
  2. 服务端从文件存储系统中取出消息
  3. 服务端返回响应结果给消费者客户端
  4. 客户端将响应结果还原成消息并开始处理消息
【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

上一篇: linux安装DM数据库 下一篇: kafka使用场景
  1. 分享:
最后一次编辑于 2023年11月08日 0

暂无评论

推荐阅读
IDYp5aKWcwEJ