网络消息校验-网络消息校验文档介绍内容-阿里云

超大消息传输

当消息内容大于64 KB以至于无法直接存入MNS队列时，不做消息切片，使用消息服务MNS 和对象存储OSS 来传递大于64 KB的消息。背景信息消息服务MNS 的队列的消息大小最大限制是64 KB，这个限制基本能够满足在正常情况下消息作为控制流信息...

直播互动解决方案

同时，服务端也会添加禁言名单用于业务校验和消息过滤。老师的客户端需将消息发送至roomSend/command Topic，其中：roomSend为直播间所有客户端发送消息使用的父级Topic，需要在云消息队列 MQTT 版控制台创建。command为自定义二级Topic...

主题（Topic）

行为约束消息类型强制校验云消息队列 RocketMQ 版 5.x版本将消息类型拆分到主题中进行独立运维和处理，因此系统会对发送的消息类型和主题定的消息类型进行强制校验，若校验不通过，则消息发送请求会被拒绝，并返回类型不匹配异常。校验...

SendChatappMassMessage-批量发送ChatApp消息

说明取值范围 undelivered 消息不能发送到端时回落（在发送状态时模板、参数需要校验通过，模板被封、号码被封等不做校验）。参数值为空时默认使用此规则 sentFailed 消息在校验模板、模板变量等参数时，校验不通过也会回落。只会强校验 ...

SendChatappMessage-发送ChatApp消息

说明取值范围 undelivered 消息不能发送到端时回落（在发送状态时模板、参数需要校验通过，模板被封、号码被封等不做校验）。参数值为空时默认使用此规则 sentFailed 消息在校验模板、模板变量等参数时，校验不通过也会回落。只会强校验 ...

tenant_userid instance_id instance_name Counter kafka_server_brokertopicmetrics_invalidmagicnumberrecords_total 消息版本校验失败次数。tenant_userid instance_id instance_name Counter kafka_server_brokertopicmetrics_...

消息队列Kafka版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流入源为云消息队列 Kafka 版的消息流入任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已购买并部署云消息队列 Kafka...

云消息队列 Kafka 版

本文介绍如何在云消息队列 RabbitMQ 版控制台创建消息流入任务，将云消息队列 Kafka 版中的数据快速导入云消息队列 RabbitMQ 版。前提条件您已购买云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源...

创建Kafka Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将指定云消息队列 Kafka 版实例中的数据导出至其他的云消息队列 Kafka 版。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见...

创建Tablestore Sink Connector

put 网络配置专有网络：通过专有网络VPC将Kafka消息投递到Tablestore。公网：通过公网将Kafka消息投递到Tablestore。公网 VPC 选择VPC ID。仅当网络配置为专有网络时需配置此参数。vpc-bp17fapfdj0dwzjkd*交换机选择vSwitch ID。仅当...

计算巢校验数字签名说明

数字签名信息校验流程消息处理流程此处以调用 CheckoutLicense 的返回值为例，计算数字签名的值。调用 CheckoutLicense，获取返回值。curl-H"Content-Type:application/json"-XPOST ...

创建MNS Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将云消息队列 Kafka 版的数据导出至消息服务。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和部署实例。您...

创建Kafka Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务，将指定云消息队列 Kafka 版实例中的数据快速导入至另外的云消息队列 Kafka 版实例中。前提条件您已购买云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请...

云消息队列 Kafka 版

本文介绍如何在云消息队列 RocketMQ 版控制台创建消息流入任务，实现将云消息队列 Kafka 版中的数据快速导入至云消息队列 RocketMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见 ...

创建FC Sink Connector

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为函数计算的消息流出任务。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和部署实例。您已开通函数计算服务，...

创建RabbitMQ Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将云消息队列 Kafka 版的数据导出至云消息队列 RabbitMQ 版。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和...

创建RocketMQ Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将云消息队列 Kafka 版的数据导出至云消息队列 RocketMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已...

附录：消息格式

本文介绍DataWorks开放消息的消息结构、不同类型事件的消息格式及各字段含义，帮助您快速获取和感知事件消息的状态变更信息。注意事项 DataWorks发送的核心消息内容您可参照消息实体格式进行查看。通过EventBridge发送的消息，会在消息实体...

创建OSS Sink Connector（新版）

最新位点网络配置选择路由消息的网络类型。基础网络专有网络VPC 选择VPC ID。当网络配置设置为自建公网时需要设置此参数。vpc-bp17fapfdj0dwzjkd*交换机选择vSwitch ID。当网络配置设置为自建公网时需要设置此参数。vsw-bp1...

收发定时消息和延时消息

endChan()/长轮询消费消息，网络超时时间默认为35s。长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。mqConsumer.ConsumeMessage(respChan,errChan,3,/一次最多消费3条（最多可设置...

收发顺序消息

顺序消息（FIFO消息）是云消息队列 RocketMQ 版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Go SDK收发顺序消息的示例代码。背景信息顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...

收发普通消息

普通消息是指云消息队列 RocketMQ 版中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Go SDK收发普通消息的示例代码。前提条件您已完成以下操作：安装Go SDK。更多信息，请参见准备环境。...

收发事务消息

endChan()/长轮询消费消息，网络超时时间默认为35s。长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。mqConsumer.ConsumeMessage(respChan,errChan,3,/一次最多消费3条（最多可设置...

创建和管理基于便捷账号的办公网络

为保障办公网络内云电脑正常使用，选择云企业网实例ID之后，请单击校验，以校验所选云企业网实例的路由和办公网络 IPv4网段是否有冲突。若校验未通过，则单击查看冲突详情和推荐网段，并根据建议重新设置IPv4网段或云企业网实例。...

接入点对比

公网/VPC实例接入点对比网络类型端口接入点协议适用场景公网 9093 SSL接入点 SASL_SSL 消息传输过程需加密，消息收发需鉴权，支持以下两种机制验证身份：PLAIN SCRAM-SHA-256 专有网络VPC 9092 默认接入点 PLAINTEXT 消息传输过程...

实例运行健康自检指南

当客户端使用SDK无法收发消息或无法连接实例时，您可以使用Kafka的自检工具对实例的健康状态进行自检，检查网络是否连通、实例状态是否异常。若实例无异常，请检查网络是否连通、实例状态是否异常、客户端代码配置是否正确以排除您的客户端...

查看接入点

如需使用SDK接入云消息队列 Kafka 版收发消息，您需要根据实例的网络环境类型来配置接入点。本文介绍如何在云消息队列 Kafka 版控制台查看接入点。背景信息云消息队列 Kafka 版提供以下类型的接入点：默认接入点：适用于在VPC环境...

消费端从服务端拉取不到消息或拉取消息缓慢

可能的原因包括消息流量达到网络带宽、单个消息大小超过网络带宽或者Consumer每次拉取的消息量超过网络带宽。问题现象 Topic中有消息并且Consumer未消费到最新的位置，出现消费端从服务端拉取不到消息或拉取消息缓慢的情况（特别是公网消费...

SDK概述

相关链接根据接入云消息队列 Kafka 版网络类型，购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC接入和公网和VPC接入。创建收发消息使用的Topic和 Group。具体操作，请参见步骤三：创建资源。公网/VPC实例的默认SASL用户...

回调鉴权

Test123)=c72b60894140fa98920f1279219b*回调消息接收端校验规则回调消息接收端将设置的回调URL、X-ICE-TIMESTAMP和鉴权密钥字符串进行拼接，然后进行MD5值计算并得到加密串，再将加密串与X-ICE-SIGNATURE字段进行对比，如果不一致，则...

错误码

常见原因：网络波动或校验Token时phoneNum加密出错。中国联通错误码描述操作建议 100 成功。1101 公网IP无效。非有效数据流量访问，建议检查公网IP。1102 私网IP无效。无法通过私网IP获取相关信息，重启手机后重试。1105 参数信息错误。...

查看接入点

如需使用客户端连接云消息队列 Kafka 版收发消息，您需要根据客户端的网络环境类型及传输的安全需要来配置接入点。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；同时需要链路...

OnsMessageDetail-查询消息详细信息

1570761026630 BodyCRC integer 消息体 CRC 校验值。907060870 BornHost string 生成该消息的客户端实例。42.120.*.*:64646 BodyStr string 消息体内容。hello 示例正常返回示例 JSON 格式 {"RequestId":"EAE5BE23-37A1-4354-94D6-E44AE17...

购买流程

网络类型数据校验任务使用的网络类型，固定为专线。资源组选择校验任务所属的资源组，相关介绍，请参见什么是资源管理。购买量链路数量一次性购买数据校验任务的数量，默认为1，最大为99。单击立即购买，根据提示完成支付流程。下...

OnsMessageGetByMsgId-通过MsgId查询消息

1570761026630 BodyCRC integer 消息体 CRC 校验值。914112295 BornHost string 生成该消息的客户端实例。42.120.*.*:64646 示例正常返回示例 JSON 格式 {"RequestId":"A07E3902-B92E-44A6-B6C5-6AA111111*","Data":{"StoreSize":407,...

OnsDLQMessageGetById-根据Message ID查询死信消息

1570761026630 BodyCRC integer 消息体 CRC 校验值。914112295 BornHost string 生成该消息的生产者实例。42.120.*.*:64646 示例正常返回示例 JSON 格式 {"RequestId":"A07E3902-B92E-44A6-B6C5-6AA111111*","Data":{"StoreSize":407,...

OnsMessageGetByKey-根据Message Key查询消息

1570760999721 BodyCRC integer 消息体 CRC 校验值。914112295 BornHost string 生成该消息的客户端实例。42.120.*.*:59270 示例正常返回示例 JSON 格式 {"RequestId":"A07E3902-B92E-44A6-B6C5-6AA111111*","Data":{"OnsRestMessageDo":...

快速入门概述

生产环境建议使用VPC网络访问云消息队列 RocketMQ 版服务。公网访问：使用公网访问，需要手动开启公网访问功能。开启后，实例同时提供VPC接入点和公网接入点。公网访问需要额外收取公网下行流量费用，建议仅在测试环境或线下IDC场景下...

迁移上云操作

前提条件创建消息队列RocketMQ版5.0系列实例创建服务关联角色角色名称：AliyunServiceRoleForRMQMigration 权限策略：AliyunServiceRolePolicyForRMQMigration 权限说明：允许云消息队列 RocketMQ 版使用该角色获取访问专有网络VPC的...

OnsMessagePageQueryByTopic-查询Topic内所有消息

1570760999721 BodyCRC integer 消息体 CRC 校验值。914112295 BornHost string 生成该消息的客户端实例。42.120.*.*:59270 MaxPageCount long 查询结果最大页数。400 TaskId string 第一次新建查询时，返回的查询任务 ID，用于后续取消息...

网络消息校验

新品推荐