一次登录时需修改密码。 使用Oozie客户端 以客户端安装用户，登录安装客户端的节点。 执行以下命令，切换到客户端安装目录，该操作的客户端目录只是举例，请根据实际安装目录修改。 cd /opt/client 执行以下命令配置环境变量。 source bigdata_env 判断集群认证模式。

查看更多 →

Java客户端使用说明 操作场景 本文介绍Java版本的Kafka客户端连接指导，并完成客户端连接以及消息生产与消费的相关示例。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Java开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1

查看更多 →

Go客户端使用说明 操作场景 本文以Linux CentOS环境为例，介绍Go版本的Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 引入Kafka客户端

查看更多 →

一次登录时需修改密码。 使用Oozie客户端 以客户端安装用户，登录安装客户端的节点。 执行以下命令，切换到客户端安装目录，该操作的客户端目录只是举例，请根据实际安装目录修改。 cd /opt/client 执行以下命令配置环境变量。 source bigdata_env 判断集群认证模式。

查看更多 →

RL的 服务器 。 使用HTTP/HTTPS转发 AMQP推送消息队列 客户可以通过数据转发界面，订阅指定的AMQP通道，将订阅的数据源信息推送到指定AMQP通道，用户可通过AMQP的客户端与IoT平台建立链接，接收数据。 使用AMQP转发 MQTT推送消息队列 客户可以通过数据转发界面，订阅指定的MQTT

查看更多 →

下发的属性，设备属性为应用服务器提供向设备下发属性的功能。 AMQP队列管理 AMQP队列管理为客户创建、删除、查看队列。AMQP队列可通过规则订阅后通过AMQP客户端接收消息数据。 接入凭证管理 接入凭证是用于AMQP、MQ TTS 等协议建立长链接时认证使用。 数据转发、设备联动

查看更多 →

其他语言客户端使用说明 MQS完全兼容Kafka开源客户端，如果您使用其他语言，也可以从Kafka官网获取客户端，按照Kafka官网提供的连接说明，与MQS对接。 父主题： MQS连接开发（开源客户端）

查看更多 →

C#客户端使用说明 操作场景 本文介绍C#版本的Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和C#开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1

查看更多 →

。 以下示例演示在Java客户端对消息本身单独设置TTL。 byte[] messageBodyBytes = "Hello, world!".getBytes(); AMQP.BasicProperties properties = new AMQP.BasicProperties

查看更多 →

objects 接入客户端信息列表。 total Integer 接入客户端信息总数。 表5 AccessClientInfo 参数 参数类型 描述 id String 客户端ID。 name String 客户端名称。 access_mode String 接入模式：YSTEM、CUSTOM、AUTO。

查看更多 →

客户端对外连接访问说明 场景1：访问华为云会议相关地址，进行基本业务交互，包括注册、激活、管理平台、隐私声明、用户协议等 场景2：访问华为云相关地址，包括华为云官网、客户端下载地址、套餐 定价 、IdeaHub投屏帮助、 WeLink 套餐订购、帮助中心、体验改进计划等 场景3：客户端用于探测与互联网网络连接是否正常

查看更多 →

可调用此接口查询物联网平台中指定队列的详细信息。 删除AMQP队列 可调用此接口在物联网平台上删除指定AMQP队列。 接入凭证管理 API 说明 生成接入凭证 接入码是用于客户端使用AMQP等协议与平台建链的一个认证凭据，调用该接口将会生成一对新的接入码。 数据流转规则管理 API 说明 查询规则条件列表 可调

查看更多 →

资源空间管理 接入凭证是用于AMQP、MQTTS等协议建立长链接时认证使用。 查询资源空间列表 创建资源空间 查询资源空间 删除资源空间 更新资源空间 父主题： API

查看更多 →

本章节以Java中使用的RabbitMQ客户端amqp-client为例介绍节点重启后消费者如何重连。 amqp-client自带重连机制，但是自带的重连机制只会重试一次，一次连不上后就不会再执行了，这时如果消费者没有做额外的重试机制，那么这个消费者就彻底丧失的消费能力。 amqp-client在节点

查看更多 →

集群实例的负载均衡 LVS对客户端连接设置了心跳超时时间，默认为90秒。如果客户端在90秒内没有向LVS发送心跳（AMQP心跳帧或消息收发），LVS会主动断开与客户端的连接，此时客户端需要重新连接。 如果存在消息收发时间间隔大于90秒的场景，请在客户端开启心跳并设置小于90秒的心跳超时时间。

查看更多 →

当前服务端版本为3.8.35和AMQP-0-9-1 兼容AMQP 0-9-1协议的客户端版本。 连接数 RabbitMQ单机和集群实例，不同实例规格的连接数上限不一致，具体限制，请参考产品规格。 - 通道数 RabbitMQ 3.8.35版本：<= 2047 RabbitMQ AMQP-0-9-1版本：<=

查看更多 →

连接RabbitMQ网络要求 客户端可以通过公网连接RabbitMQ实例，也可以通过内网连接RabbitMQ实例。使用内网连接时，注意以下几点： 如果客户端和RabbitMQ实例部署在同一个VPC内，网络默认互通。 如果客户端和RabbitMQ实例部署在不同VPC中，由于VPC之间逻辑隔离，客户端和Ra

查看更多 →

iotda_south_messageUp_failedCount AMQP流转次数 iotda_amqp_forwarding_totalCount AMQP流转成功次数 iotda_amqp_forwarding_successCount AMQP流转失败次数 iotda_amqp_forwarding_failedCount

查看更多 →

开启RabbitMQ ACL访问 RabbitMQ实例版本为AMQP-0-9-1时，支持在控制台配置ACL访问控制功能。当您需要对生产消息和消费消息进行权限管理时，可以开启ACL访问控制功能。 前提条件 已购买RabbitMQ AMQP-0-9-1版本的实例。 开启ACL访问控制 登录管理控制台。

查看更多 →

php-amqplib C rabbitmq-c Go amqp091-go 推荐使用最新Release版本的SDK。 客户端网络环境说明 客户端可以通过以下方式访问RabbitMQ实例： VPC内子网地址访问 如果客户端是云上E CS ，与RabbitMQ实例处于同region同V

查看更多 →

API 产品管理 设备管理 设备消息 设备命令 设备属性 AMQP队列管理 接入凭证管理 数据流转规则管理 流转数据 设备联动规则 设备影子 设备组管理 标签管理 资源空间管理 批量任务 设备CA证书管理 OTA升级包管理 广播消息 设备隧道管理 数据流转积压策略管理 数据流转流控策略管理

查看更多 →