公共参数
Date 是 请求的构造时间，目前只支持GMT格式，如果和 云消息队列 RocketMQ 版 的服务器时间前后差异超过15分钟将返回本次请求非法。Host 是 即在控制台 实例详情 页面查看到的HTTP接入点。x-mq-version 是 调用 云消息队列 RocketMQ 版 的...
发送消息（多线程）
您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高消息发送或接收TPS。重要 请避免为每个线程创建一个客户端实例。顺序消息不建议使用多线程发送。云...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
名词解释
如需实现消息幂等，即如果消息重试多次，消费端对该重复消息消费多次与消费一次的结果是相同的，并且多次消费没有对系统产生副作用，在为每条消息设置唯一Message ID的基础上，您还需要在 云消息队列 RabbitMQ 版 的Consumer客户端对消息...
收发定时消息
Message msg(/Message Topic factoryInfo.getPublishTopics(),/Message Tag，可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤"TagA",/Message Body，不能为空，消息队列RocketMQ版不...
HTTP SDK错误码列表
详细信息，请参见对应的API文档：发送消息API 订阅消息API 确认消息API MessageNotExist Message not exist.404 Topic中无可用的消息。The receipt handle you provided has expired.404 消费消息过慢导致消息重新回到队列生成新的 ...
收发定时消息
Topic",/Message Tag可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。tag",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容C++ 1.x/2.x SDK客户端接入，您可以使用1.x/2.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x/2.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK...
收发事务消息
Message msg(/Message Topic factoryInfo.getPublishTopics(),/Message Tag，可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。TagA",/Message Body，不能为空，消息队列RocketMQ版...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见...
调用TCP协议的SDK收发普通消息
在控制台创建完所有资源之后，您可以调用 云消息队列 RocketMQ 版 的TCP协议的SDK收发普通消息。前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务...
什么是服务端订阅
服务端可以直接订阅产品下多种类型的消息，例如设备上报消息、设备状态变化通知、设备生命周期变更、网关发现子设备上报、设备拓扑关系变更等。配置服务端订阅后，物联网平台会将产品下所有设备中已订阅类型的消息，转发至您的服务器。使用...
使用Spring Cloud框架收发消息
Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 ...
什么是MX解析？
MX Mail Exchanger的缩写是邮件交换记录，它指向一个邮件服务器，用于电子邮件系统发邮件时根据收信人的地址后缀来定位邮件服务器。优先级的意义 MX优先级在只存在一条MX记录的时候没有意义。当您的域名解析记录中存在多条MX记录的时候，...
如何提高Nginx Web服务器的安全性
本文介绍如何提高Nginx Web服务器的安全性的操作步骤。背景信息 Nginx是一个轻量级的，高性能的Web服务器以及反向代理和邮箱（IMAP或POP3）代理服务器。它运行在UNIX、GNU、linux、BSD、Mac OS X、Solaris和Windows各种版本。根据调查统计...
使用限制
客户端与每个Broker连接数量 建议不超过1000个 云消息队列 Kafka 版 的客户端发送消息和订阅消息都需要与Broker建立Socket连接。当客户端与每个Broker连接数量过多时，Broker会消耗大量性能来维持连接，Broker稳定性将受到严重影响,因此...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Node.js SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Node.js SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Node.js SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Node.js SDK。更多信息，请参见 ...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
Token应用服务器接口
本文介绍 云消息队列 MQTT 版 提供的应用服务器Token OpenAPI接口。API 描述 ApplyToken 调用 ApplyToken 申请临时访问的Token。QueryToken 调用 QueryToken 校验Token的有效性。RevokeToken 调用 RevokeToken 吊销Token。
Token应用服务器接口
本文介绍 云消息队列 MQTT 版 提供的应用服务器Token OpenAPI接口。OpenAPI 描述 ApplyToken 调用ApplyToken申请临时访问的Token。QueryToken 调用QueryToken校验Token的有效性。RevokeToken 调用RevokeToken吊销Token。
如何确保在MNS中存储的数据的可靠性？
本文介绍阿里云如何确保 消息服务MNS 中数据可靠性。...所有消息冗余地存储在多台服务器上，当某台服务器出现问题时，冗余数据将会被自动拷贝至其他服务器；这意味着单台服务器不可用或网络故障都不会对队列中消息的可靠性造成任何影响。
开源RabbitMQ迁移上云
云消息队列 RabbitMQ 版 采用了独创的架构设计，有效避免了因消息积压导致的内存泄漏和服务器故障等稳定性问题，并成功解决了分布式系统中的脑裂难题。此外，它还提供了高度的可伸缩性和灵活的按量计费模式，进一步增强了服务的弹性、降低...
Android端HTTPS（含SNI）业务场景"IP直连"方案说明
}@Override public Socket createSocket(Socket plainSocket,String host,int port,boolean autoClose)throws IOException { String peerHost=this.conn.getRequestProperty("Host");if(peerHost=null{ peerHost=host;} Log.i(TAG,...
使用 SMTP 发送邮件
阿里云邮件推送的邮件服务器为 smtpd，所以需要进行用户认证（要求认证用户名和发件人必须一致），认证用户名（就是发件人）和密码可以通过控制台进行设置。程序中调用 SMTP 发送邮件可以使用各种语言的 SMTP Library。详细参考，请见 SMTP...
服务器证书管理
服务器证书用于客户端认证服务端，服务器证书需要由您自行购买或自行签发并托管至阿里云数字证书管理服务。本文为您介绍如何生成并使用服务器证书。服务器证书使用流程 使用限制 仅铂金版实例和专业版实例支持服务器证书管理功能。前提条件...
SSH服务的相关介绍
我能读懂发过来的密文，我拥有服务器的控制权，请让我登录。目标服务器对客户端返回的信息进行比对。如果比对成功，则表示认证成功，客户端可以登录。如果对比失败，则表示认证失败，则会继续尝试密码验证等其它方式进行登录校验。自动登录...
实现跨屏联动
在 socket服务地址 区域，输入和主屏幕相同的地址，添加一个 接收消息，并将 消息名 命名为 下一个。重要 主屏幕和副屏幕的分组要一致，因为副屏幕是接收端，所以配置接收消息即可。单击两个屏幕页面右上角的 图标，预览展示结果。无法正常...
什么是RRPC
物联网平台收到服务器端RRPC调用请求，向设备下发一条RRPC请求消息。消息体为用户传入的数据，Topic为物联网平台定义的Topic，且携带RRPC消息ID。设备收到下行消息后，按照指定Topic格式（包含之前物联网平台下发的唯一RRPC消息ID），回复...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
基本概念
消息可以是网站的页面访问、服务器的日志，也可以是和CPU、内存相关的系统资源信息，但对于 云消息队列 Kafka 版，消息就是一个字节数组。消息保留时长 在磁盘容量充足的情况下，消息的最长保留时间。磁盘容量不足（即磁盘水位达到85%）时...
NLB压力测试的方法
后端服务器数量较少 关闭服务器组的客户端地址保持功能，NLB会使用自身地址与后端服务器建立连接，默认情况下一个后端服务器支持12万并发连接，如果后端服务器数量较少，也会限制并发连接的压测性能。解决方法：如果是TCP或UDP监听，建议...
通过密码认证登录Linux实例
说明 为了防止PuTTY超时退出，建议您将 Connection>Seconds between keepalives(0 to turn off)由默认值0修改为60，表示服务器每1分钟向客户端发送一个消息，用于保持连接。单击 Open。首次连接时会出现 PuTTY Security Alert 警告，表示...
ALB压力测试的方法
后端服务器依赖的应用成为瓶颈 请求经过负载均衡到达后端服务器后，后端服务器本身负载正常，但由于所有后端服务器上的应用又依赖其他应用，例如数据库，当数据库成为瓶颈时，也会引起性能降低。解决方法：根据实际情况清理后端服务器上不...
CLB压力测试的方法
后端服务器依赖的应用成为瓶颈 请求经过负载均衡到达后端服务器后，后端服务器本身负载正常，但由于所有后端服务器上的应用又依赖其他应用，例如数据库，当数据库成为瓶颈时，也会引起性能降低。解决方法：根据实际情况清理后端服务器上不...
专有宿主机DDH
您还可以获得这台物理服务器的物理属性信息，包括CPU数量（Socket数）、物理CPU核数和内存大小，并根据宿主机规格创建指定规格族的ECS实例，以实现自主规划物理资源、满足安全合规要求并降低部署成本。更多DDH信息，请参见 什么是专有宿...
订阅者最佳实践
消费失败 云消息队列 Kafka 版 是按分区逐条消息顺序向前推进消费的，如果消费端拿到某条消息后执行消费逻辑失败，例如应用服务器出现了脏数据，导致某条消息处理失败，等待人工干预，那么有以下两种处理方式：失败后一直尝试再次执行消费...
- 产品推荐
- 这些文档可能帮助您