FolkMQ v1.7.8

常用的角色与概念

1、业务角色

概念说明
消息(Message)最小数据传输单元
主题(Topic)相当于消息的分类(由字母和数字组成,使用"."做为间隔符)
队列(Queue)订阅时,主题会为每个“消费者分组”分配一个队列
生产者(Producer)构建与发布消息的实体
消费者(Consumer)订阅主题、并接收处理消息的实体(即一个连接会话)
消费者分组(ConsumerGroup)多个消费者的负载均衡分组(即一批相同名字的连接会话)。
订阅时,需加入一个“消费者分组”。
派发时,服务端会给消费者分组中的某一个消费者(即一个连接会话)派发

2、工件概念

概念说明
客户端(FolkMQ-Client)业务“生产者”与“消费者”的功能载体
服务端(FolkMQ-Broker)接收 “生产者” 的消息,并派发给 “消费者” 的中间人。
支持 tcp, udp, ws 传输协议(部署时选择一种)。
服务集群代理(FolkMQ-Proxy)提供集群连接与转发服务。
在集群时,作为 “服务端” 的代理与 “客户端” 打交道
支持 tcp, ws 传输协议(部署时同时可选)。

3、消费时的交互模式(只支持“推”)

概念说明
推(Push)是指服务端(即中间件),把消息推送给客户端(即消费者)。支持
拉(Pull)是指客户端(即消费者),从服务端(即中间件)拉取消息。不支持

4、消费时的分发模式

概念说明
集群模式(Cluster)提指一条消息只被同一个“消费者组”中的“一个”消费者消费(使用负载均衡策略)。
广播模式(Broadcast)提指一条消息会被同一个“消费者组”中的“所有”消费者消费。
  • 集群模式

  • 广播模式