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

查看更多 →

Python客户端使用说明 本文以Linux CentOS环境为例，介绍Python版本的RabbitMQ客户端连接指导，包括RabbitMQ客户端安装，以及生产、消费消息。 使用前请参考收集连接信息收集RabbitMQ所需的连接信息。 本文的连接示例对于RabbitMQ 3.x

查看更多 →

HDFS客户端常见命令说明 操作场景 您可以使用HDFS Shell命令对HDFS文件系统进行操作，例如读文件、写文件等操作。 执行HDFS Shell命令 安装客户端，具体请参考使用 MRS 客户端章节。 以客户端安装用户，登录安装客户端的节点。 执行以下命令，切换到客户端安装目录

查看更多 →

Flink客户端常见命令说明 在使用Flink的Shell脚本前，首先需要执行以下操作，详细使用场景可参考Flink客户端使用实践运行wordcount作业： 安装Flink客户端，例如安装目录为“/opt/client”。 初始化环境变量。 source /opt/client/bigdata_env

查看更多 →

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

查看更多 →

Flink客户端常见命令说明 本章节适用于MRS 3.x及之后版本。 在使用Flink的Shell脚本前，首先需要执行以下操作，详细使用场景可参考Flink客户端使用实践运行wordcount作业： 安装Flink客户端，例如安装目录为“/opt/client”。 初始化环境变量。

查看更多 →

使用HTTP/HTTPS转发 AMQP推送消息队列 客户可以通过数据转发界面，订阅指定的AMQP通道，将订阅的数据源信息推送到指定AMQP通道，用户可通过AMQP的客户端与IoT平台建立链接，接收数据。 使用限制：支持基础版、标准版、企业版。 使用AMQP转发 MQTT推送消息队列

查看更多 →

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 判断集群认证模式。

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

ObsForwarding object 参数说明：转发OBS服务消息内容。当channel为OBS_FORWARDING时，必填。 amqp_forwarding AmqpForwarding object 参数说明：转发AMQP服务消息内容。当channel为AMQP_FORWARDING时，必填。

查看更多 →

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

查看更多 →

当前服务端版本为3.8.35和AMQP-0-9-1。 连接数 RabbitMQ单机和集群实例，不同实例规格的连接数上限不一致，具体限制，请参考产品规格。 通道数 单条连接可以建立的通道数如下： RabbitMQ 3.8.35版本：<= 2047 RabbitMQ AMQP-0-9-1版本：<=

查看更多 →

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

查看更多 →

ObsForwarding object 参数说明：转发OBS服务消息内容。当channel为OBS_FORWARDING时，必填。 amqp_forwarding AmqpForwarding object 参数说明：转发AMQP服务消息内容。当channel为AMQP_FORWARDING时，必填。

查看更多 →

ObsForwarding object 参数说明：转发OBS服务消息内容。当channel为OBS_FORWARDING时，必填。 amqp_forwarding AmqpForwarding object 参数说明：转发AMQP服务消息内容。当channel为AMQP_FORWARDING时，必填。

查看更多 →

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

查看更多 →