作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。...如需查看完整的消息内容，请下载相应的消息。下载的消息最大为10 MB。如果消息超过10 MB，则只下载10 MB的内容。
发送消息
选择 定时发送，设置消息定时发送的时间。选择 立即发送，即可立即发送消息。回落策略 暂不支持。导入方式 接收消息的号码支持 号码组导入 和 Excel上传 两种方式，您可以选择任意一种方式设置接收号码。号码组导入 单击 添加发送对象，请...
QueryMqttTraceMessagePublish-查询消息发送轨迹
查询指定消息的发送轨迹。当消息的收发不符合预期时，您可以通过该接口查看消息的发布时间、发布客户端等详细信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessagePublish 接口，都会计算为一次消息 TPS，从而...
设备收到的消息并不是按推送的顺序到达
问题详述 推送消息给设备,在推送记录中查看到的消息的发送顺序和测试的时候发送的顺序是一致的，但为什么设备收到的消息并不是先发送的先到达，后发送的后到达，没有按照测试的时候的顺序展示呢？问题解答 推送系统在实现上为了尽可能提升...
生产者负载均衡
策略原理：Hash算法 MessageGroupHash模式下，生产者发送消息时，以消息组为粒度，按照内置的Hash算法，将相同消息组的消息分配到同一队列中，保证同一消息组的消息按照发送的先后顺序存储。说明 Hash算法的具体原理，请参见 SipHash算法。...
MNS是否提供对消息的先入先出（FIFO）访问？
消息服务MNS 消费消息时尽量做到先进先出，正是因为分布式消息队列的一些特性并不能保证您能按照消息的发送顺序消费消息，如果您的业务必须先进先出，建议在消息中加入序号信息以便消费消息后进行重新排序，详情请参见 严格保序队列。
定时DING如何发送？
概述 定时DING消息的发送及撤回操作指引。详细信息 如果需要发送定时DING消息，在编写钉消息的时候，发送时间选择【在指定时间发送】并设置好，DING消息会在你设定的时间点进行发送。如果你需要撤回这条DING消息，只要还没有到设定的时间，...
为什么查询到的消息创建时间与设置的消息查询时间点...
可能原因 设置的查询时间点小于当前分区最小位点的消息发送时间，或者超出当前分区最大位点的消息发送时间，此时会触发重置消费位点机制，查询到的 消息创建时间 为当前分区最新位点消息的发送时间。如果查询到的 消息创建时间 为空值，...
主题（Topic）
校验原则如下：消息类型必须一致 发送的消息的类型，必须和目标主题定义的消息类型一致。主题类型必须单一 每个主题只支持一种消息类型，不允许将多种类型的消息发送到同一个主题中。常见错误使用场景 发送的消息类型不匹配 例如，创建主题...
接口和参数说明
消息发送接口 消息发送参数 参数名 参数说明 SEND_MSG_TIMEOUT_MILLIS 设置消息发送的超时时间，单位：毫秒。默认值为 3000。shardingKey（顺序消息）顺序消息中用来计算不同分区的值。消息发送返回值 同步消息 SendResult 结构体参数名 ...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
常见问题
通过设置 Webhook参数 向用户回调接收到的消息及发送消息的状态信息。通过MNS消息队列消费模式或HTTP批量推送模式来接收短信发送状态的结果和用户回复的短信内容。更多信息，请参见 回执消息简介与配置流程。创建WABA时，无法完成Meta企业...
创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息发送到 Topic，而消息消费者则通过订阅该 Topic 来获取和消费消息。创建 Topic 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic...
Account
生产者 向MNS的消息队列发送消息的角色。消费者 从MNS的消息队列获取消息的角色。主题模型 主题所有者 开通MNS服务的Account通过 CreateTopic 接口创建出一个主题，这个Account就是该主题的所有者，主题所有者拥有该主题的所有操作权限。...
消息类型
TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息 定时和延时消息 定时消息：Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 ...
下行消息
消息下发操作步骤 进入CMNS-下行消息页面 点击“消息发送”按钮 在“应用”下拉框选择您需要发送消息的客户端应用 在“类型”单选框选择您需要发送消息的类型 透传消息是消息直接发送至客户端应用，由客户端应用决定消息处理 通知消息是指...
更新记录
消息发送支持发送带有地址信息的消息模板。消息发送支持自定义回落时间。新增消息工作台功能。2023年3月更新记录 时间 特性 内容描述 2023.03.02 新增 Viber模板设计：新增文字图片类消息类型。Viber模板设计：文本图片类消息支持图片变量...
如何进行发送消息的测试？
您可以直接在 云消息队列 Kafka 版 控制台进行发送消息的测试。您可以在控制台的 Topic管理 页面，单击目标Topic右侧的 发送消息，进行消息发送测试，以验证集群是否运转正常。
参数说明
SendMsgTimeoutMillis 设置消息发送的超时时间，单位：毫秒，默认值：3000。shardingKey（顺序消息）顺序消息中用来计算不同分区的值。消息订阅参数 参数名 参数说明 ConsumerId 您在 云消息队列 RocketMQ 版 控制台上创建Group ID的更多...
参数说明
SendMsgTimeoutMillis 设置消息发送的超时时间，单位：毫秒，默认值：3000。shardingKey（顺序消息）顺序消息中用来计算不同分区的值。消息订阅参数 参数名 参数说明 ConsumerId 您在 云消息队列 RocketMQ 版 控制台 上创建的Group ID，更...
产品架构
发送的消息可以是网站的页面访问、服务器日志，也可以是CPU和内存相关的系统资源信息。Kafka Broker 用于存储消息的服务器。Kafka Broker支持水平扩展。Kafka Broker节点的数量越多，云消息队列 Kafka 版 集群的吞吐率越高。Group 通过pull...
应用场景
同时，由于使用了消息队列，只要保证消息格式不变，消息的发送方和接收方并不需要彼此联系，也不需要受对方的影响，即解耦和。分布式事务的数据一致性 支付的流程中，用户入口在支付中心完成，账单、权益、通知系统在其他系统完成，多个...
轨迹查询
查询消息轨迹支持以下三种方式：组合查询 根据Client ID、Message ID和时间范围，查询某条消息的发送轨迹和投递轨迹。单击 组合查询，单击 Client ID 文本框，选择或输入您的Client ID（Client ID的拼接格式为<groupid>@），单击 Message ...
回执消息简介与配置流程
当您使用 ChatApp 消息服务 API接口发送消息后，可以通过MNS消息队列消费模式或HTTP批量推送模式来接收消息发送状态的结果和用户回复的消息内容。背景信息 如果出现网络异常、响应超时等情况，可能会导致回执消息推送重复、回执消息获取...
配置渠道设置
渠道设置用于管控消息的发送渠道，本文为您介绍如何配置渠道设置。使用说明 消息发送渠道可在全局（实例级）进行设置，也可以在每个租户级别进行设置，您可以根据您所在的组织的要求进行不同的配置。消息渠道关闭后，相关消息将无法发送到...
2024-01-22
消息上下行回放功能上线 日志服务下新增消息回放功能，可回放设备上行到平台和平台下行到设备的消息，可用于设备端或服务端异常恢复后的消息补发。批量消息发送支持MQTT 5.0 批量消息发送的BatchPub API入参支持MQTT 5.0相关参数，如用户...
生产者（Producer）
生产者通常被集成在业务系统中，将业务消息按照要求封装成 云消息队列 RocketMQ 版 的 消息（Message）并发送至服务端。在消息生产者中，可以定义如下传输行为：发送方式：生产者可通过API接口设置消息发送的方式。云消息队列 RocketMQ 版 ...
RocketMQ全链路追踪解决方案
云消息队列 RocketMQ 版 涉及的span如下：span 说明 send 消息的发送过程。span以一次发送行为开始，以发送成功、失败或抛异常结束。消息发送的内部重试会被记录成多条span。receive 消费者接收消息的长轮询过程，与长轮询的生命周期保持...
Serverless实例计费说明
普通消息发送指的是生产者发送的 普通消息，高级消息发送指生产者发送的 定时/延时消息、顺序消息 或 事务消息。云消息队列 RocketMQ 版 中消息投递可分为并发投递和顺序投递，您可以在创建Group时选择投递方式，不同投递方式费用单价不同...
消息优先级为1，就一定优先吗？
消息服务MNS 发送消息时，可以指定消息的优先级权值（取值范围1~16，1为最高优先级，默认优先级为8）。优先级越高的消息，越容易更早被消费。如果顺序发送100条消息，第50条消息的优先级置为1（其余消息优先级默认为8）。CloudQueue queue=...
【已恢复】WhatsApp 消息发送异常公告
2024 年 4 月 4 日【更新】针对影响消息发送的故障的修复程序已部署完毕，截至新加坡标准时间 2024 年 4 月 4 日上午 4:45此问题已得到缓解。感谢您的耐心等待。WhatsApp Message Delivery Disruption Notice Due to an unexpected ...
消息轨迹查询
当消息的收发不符合预期时，您可以使用消息轨迹查询功能...您可以在查询结果列表中单击 操作 列的 消息轨迹 查看指定消息的消息轨迹。相关文档 如果需要查询设备的状态，请参见 设备状态查询。如果需要查询设备的轨迹，请参见 设备轨迹查询。
消息队列
任务发送的消息会暂存在消息队列中，当接收任务来读时，将暂存的数据传递给接收任务；若接收任务在接收数据时，消息队列中无可读数据，则任务会阻塞，直到有消息到来解除阻塞而进入就绪状态。超时时间 消息接收可设置超时时间，如果任务在...
消息优先级为1，就一定优先吗？
优先级为1的消息就一定比优先级为2的消息更早被消费吗？本文关于该问题进行介绍。消息服务MNS 发送消息时，可以指定消息的优先级权值（取值范围1~16，1为最高优先级，默认优先级为8）。优先级越高的消息，越容易更早被消费。如果顺序发送...
消息查询
您可以通过消息查询验证消息是否发送成功、验证消息发送的内容是否正确、以及进一步查看消息的轨迹信息。查询方式说明 由于消息在 云消息队列 RocketMQ 版 中存储的时间默认为3天（不建议修改），即只能查询从当前查询时间算起3天内的消息...
配置消息日志
当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件 创建 云消息队列 RabbitMQ 版 实例。具体操作，请参见 实例管理。开通日志服务并创建Project和Logstore。具体操作，请参见 资源管理...
直播互动消息常见问题
参数 说明 是否审核 表示是否需要对该消息进行安全审核，如果审核不通过，服务端会阻止消息的发送，并返回客户端发送失败。建议对于系统类消息，设置不需要审核。是否存储 表示消息是否要保存到数据库，供后续查询。建议仅对弹幕、评论等非...
应用场景
下文先以用户注册为场景说明 云消息队列 RocketMQ 版 如何实现以下功能：异步解耦 分布式事务的数据一致性 消息的顺序收发 最后，再以电商的秒杀场景和价格同步场景分别说明 云消息队列 RocketMQ 版 所实现的削峰填谷和大规模机器的缓存...
消息查询
如遇消息消费有问题，则可通过查询具体发送的消息内容来排查问题。SOFAStack 消息队列提供了三种消息查询的方式，分别是按 Message ID、Message Key 以及 Topic 查询。操作步骤 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列...
消息收发常见问题
您的消息发送TPS过大，超过上限值。您可以适当调整实例规格，提高消息收发TPS上限。本地测试先发送消息，再订阅接收不到消息，设置离线消息后还是接收不到。您需要先启动消费者，再启动生产者生产消息。若先启动生产者发送消息，如果Topic...
- 产品推荐
- 这些文档可能帮助您