Skip to content

消息传递模块总览 - Overview

本分类做什么

两套模型:Pub/Sub(发布订阅)MessageQueue(消息队列)。侧栏含 使用指南 与类型枚举页;API 以 PubSub*MessageQueue* 为前缀,适合 进程内/插件支持的跨进程 解耦通信。与 远程调用同步 RPC 不同:本分类偏 异步消息


一、入门文档

文档内容
PubSub使用指南主题、订阅、发布、连接状态。
MessageQueue使用指南声明、发布、消费、确认、拉取。

建议先读指南,再查具体 API 参数。


二、Pub/Sub:PubSub*

接口差异
PubSubNewPubSubFree实例 生命周期。
PubSubSubPubSubUnsubPubSubUnsubAll订阅/退订 主题。
PubSubPubTextPubSubPubBytes发布 文本二进制
PubSubGetMyTopicsPubSubGetTopicSubCount查询订阅关系。
PubSubGetNetStatus连接/网络状态。

与 MQ 差异多对多广播、无内置 持久化(以版本为准);适合 事件通知


三、消息队列:MessageQueue*

接口环节
MessageQueueDeclare声明 队列(名称、持久等,见详情页)。
MessageQueueClose关闭 发布端(或某句柄,见详情页)。
MessageQueuePublishTextMessageQueuePublishBytes生产 消息。
MessageQueueConsume消费者 启动(回调驱动)。
MessageQueueCancel取消消费。
MessageQueueAckMessageQueueNack确认/拒绝(可靠性)。
MessageQueuePull主动拉取(与 Consume 推送对比)。

与 Pub/Sub 差异队列 语义:通常 点对点、可 重试Ack/Nack 保证投递。


四、类型与回调

文档/接口用途
PubSub角色类型 - OLAPubSubType发布者/订阅者等 角色枚举
PubSub连接类型 - OLAPubSubConnectType连接方式(内存/管道/TCP 等以详情为准)。
MessageQueueCallback - MessageQueueCallback消费 回调签名

五、快速选型

需求建议
多模块广播「配置已更新」Pub/Sub
任务队列、失败重试MessageQueue + Ack
与远程进程确认 传输层 是否需配合 远程调用网络

六、注意

  • 消息大小阻塞线程安全 以详情页为准。
  • 持久化队列 是否落盘见版本说明。