网络负面消息-网络负面消息文档介绍内容-阿里云

超大消息传输

当消息内容大于64 KB以至于无法直接存入MNS队列时，不做消息切片，使用消息服务MNS 和对象存储OSS 来传递大于64 KB的消息。背景信息消息服务MNS 的队列的...大消息网络传输时间较长，受网络波动影响的概率更大，建议在上层做必要的重试。

消息队列Kafka版

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

云消息队列 Kafka 版

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

创建Tablestore Sink Connector

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

创建Kafka Sink Connector

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

创建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 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已...

创建OSS Sink Connector（新版）

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

网络问题

网络延迟不同引起的性能差异 Ping延迟1毫秒，1000条插入耗时4000毫秒。Ping延迟0.1毫秒，1000条插入耗时500毫秒。在插入数据时进行网络抓包，网络包示例如下。在网络包中搜索 tcpdump-i eth0 port 3433-s 0-w t.cap。B代表bind（绑定）；D...

收发定时消息和延时消息

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

收发顺序消息

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

收发普通消息

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

收发事务消息

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

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

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

快速入门概述

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

接入点对比

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

消息幂等

在消息领域，幂等是指Consumer重复消费某条消息时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响。例如，在支付场景下，Consumer消费扣款消息，对一笔订单执行扣款操作，扣款金额为100 元。如果因...

网络访问与安全设置

本文介绍如何进行云消息队列 Confluent 版集群的网络访问与安全设置。网络访问类型云消息队列 Confluent 版集群提供阿里云VPC访问和公网访问方式。阿里云VPC访问 VPC访问是指您在云消息队列 Confluent 版集群所在网络VPC内或者其它...

实例规格配置和管理

您可以按照业务需求调整流量规格、网络类型、消息保留时长、最大消息大小和消费位点保留时间。前提条件您已购买云消息队列 Kafka 版 V3系列Serverless实例，且实例处于服务中状态。规格配置说明配置项含义变更方式流量规格发送...

步骤二：创建资源

前提条件创建专有网络和交换机创建安全组背景信息云消息队列 RocketMQ 版支持通过控制台和OpenAPI创建资源，本文以控制台操作为例，介绍如何在云消息队列 RocketMQ 版控制台创建资源。使用OpenAPI创建资源，请参见以下文档。...

使用云消息队列 Kafka 版时客户端的报错及解决方案

报错信息客户端语言类型报错原因解决方案 TimeoutException Java 网络问题客户端鉴权（sasl.mechanisms）失败说明该报错仅出现在云消息队列 Kafka 版的公网实例中。确保servers配置正确。通过 telnet 命令排除网络问题。如果网络...

TCP协议客户端大版本发布

网络限制 Java SDK V2.x.x.Final：仅支持通过VPC网络访问云消息队列 RocketMQ 版，不支持经典网络访问。重要若您使用存量云消息队列 RocketMQ 版实例并通过经典网络访问，请勿将Java SDK升级到V2.x.x.Final版本，否则将无法访问云消息...

功能特性

基于身份的策略运维监控功能集功能功能描述参考文档集群配置实例规格配置和管理按照业务需求调整流量规格、网络类型、消息保留时长、最大消息大小和消费位点保留时间。实例规格配置和管理链路监控云监控监控您账户下创建的资源...

消费幂等

什么是消息幂等当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的处理过程就是幂等的。例如，在支付场景下，消费者消费扣款消息，对一笔...

全球消息路由

鉴于消息同步的消息量以及网络带宽瓶颈，消息同步可能会产生一定的时间延迟。前提条件云消息队列 RabbitMQ 版源实例、源Vhost、源Exchange、源Queue以及目标实例、目标Vhost、目标Exchange、目标Queue已创建并可用。具体操作，请参见：...

全球消息路由

全球消息路由功能可用于跨地域间的消息同步，通过路由规则将消息从源实例的Topic中同步到目标实例的Topic，并支持过滤规则，按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下，您可以创建全球消息路由任务，确保跨地域间...

版本说明

若您使用存量云消息队列 RocketMQ 版实例并通过经典网络访问，请勿将Java SDK升级到V2.x.x.Final版本，否则将无法访问云消息队列 RocketMQ 版实例。Java SDK 2.x.x.Final仅支持有命名空间的实例，若您使用的实例无命名空间，请勿将客户...

消息幂等

什么是消息幂等当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这整个过程就实现了消息幂等。例如，在支付场景下，消费者消费扣款消息，对一笔订单...

MQTT和RocketMQ进行数据互通（客户端上下线通知）

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的云消息队列 RocketMQ 版数据互通...

MQTT和RocketMQ进行数据互通（跨产品数据流出）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 MQTT 版 ...

MQTT和RocketMQ进行数据互通（跨产品数据流入）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 RocketMQ...

模板管理

如果持续收到特定消息模板的负面反馈，该模板可能会被禁用，禁用后将不能再使用此模板发送消息给客户，请确保您的模板不包含违规信息。接口文档 CreateChatappTemplate-创建ChatApp模板示例正常返回示例（JSON格式）：{"RequestId":"90E...

实例运行健康自检指南

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

配置消息监控告警实现风险预警

背景信息云消息队列 RocketMQ 版提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储、网络吞吐等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注...

如何确保在MNS中存储的数据的可靠性？

消息服务MNS 将所有队列和消息存储在阿里云高可靠、高可用的数据中心组成的网络中。所有消息冗余地存储在多台服务器上，当某台服务器出现问题时，冗余数据将会被自动拷贝至其他服务器；这意味着单台服务器不可用或网络故障都不会对队列中...

Connection和Channel

应用与云消息队列 RabbitMQ 版完成Connection建立大约需要15个TCP报文交互，因而会消耗大量的网络资源和云消息队列 RabbitMQ 版资源。大量的Connection会对云消息队列 RabbitMQ 版造成巨大压力，甚至触发云消息队列 RabbitMQ 版 SYN...

网络负面消息

新品推荐