消息队列 go-queue 之 kq（kafka） 1.1 Config 1.2 go-zero 中使用 go-queue 生产者 pusher 1.3 go-zero 中使用 go-queue 消费者 consumer 消息队列 go-queue 之 kq（kafka） 消息队列对于大型微服务系统是必不可少的，主要是用来解决削峰、降低服务之...

消息过滤 应用场景 功能概述 订阅关系一致性 Tag标签过滤 SQL属性过滤 使用建议 消息过滤 消费者订阅了某个主题后，Apache RocketMQ 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 Apache RocketMQ 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的消息。...

普通消息 应用场景 功能原理 使用限制 使用示例 使用建议 普通消息 普通消息为 Apache RocketMQ 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。 应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等场景，这些场景大多数要求数据传输通道...

消息（Message） 定义 模型关系 消息内部属性 行为约束 使用建议 消息（Message） 本文介绍 Apache RocketMQ 中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。 定义 消息是 Apache RocketMQ 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 Apac...

消息群发 文本消息 图文消息 图片消息 语音消息 视频消息 卡劵消息 发送预览群发消息给指定的 openId 用户 发送预览群发消息给指定的微信号用户 删除群发消息 查询群发消息发送状态 使用示例 消息群发 文本消息 message := "hello, broadcasting test..." Offi...

消息解密 初始化实例 处理微信Token验证请求 接收消息推送 消息类型 使用示例 消息解密 初始化实例 在使用小程序消息解密之前，请先参考微信消息推送 ，你需要配置好URL(服务器地址) 、Token(令牌) 、 EncodingAESKey(消息加密密钥) 。 // 回调配置 func CallbackVerify ( c ...

消息协议 Discovery Transaction Synchronization Consensus 消息协议 节点之间通过消息来进行交互，所有消息都由下面的数据结构来实现。 message Message { enum Type { UNDEFINED = 0 ; ...

保留消息 简介 配置 保留消息 简介 服务端收到 Retain 标志为 1 的 PUBLISH 报文时，会将该报文视为保留消息，除了被正常转发以外，保留消息会被存储在服务端，每个主题下只能存在一份保留消息，因此如果已经存在相同主题的保留消息，则该保留消息被替换。 当客户端建立订阅时，如果服务端存在主题匹配的保留消息，则这些保留消息将被立即发送给...

消息重传 基础配置 协议规范与设计 重传的对象 QoS 1 QoS 2 飞行窗口与最大接收值 消息顺序 相关配置 消息重传 消息重传 (Message Retransmission) 是属于 MQTT 协议标准规范的一部分。 协议中规定了作为通信的双方 服务端 和 客户端 对于自己发送到对端的 PUBLISH 消息都应满足其 服务...

站内消息 1 功能概述 2 所有消息 3 未读消息 4 已读消息 5 接收管理 站内消息 1 功能概述 通过接收配置，后台自动推送消息给用户，用户登录后可第一时间查阅消息、及时响应。 2 所有消息 保留后台自动推送的所有消息，可通过类型筛选，查阅对应消息。比如，点击【数据集同步】类型的任务，自动跳转至定时任务，查看该任务的执行情况。 ...