登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 概览 区域右上角的 续费。在 续费 面板，选择购买时长，并选中 消息队列 Kafka（包年包月）服务...
os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET'])#消息所属的Topic，在消息队列RocketMQ版控制台创建。topic_name="${TOPIC}"#Topic所属的实例ID，在消息队列RocketMQ版控制台创建。若实例有命名空间，则实例ID必须传入；若实例无命名空间...
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
设置TCP接入域名，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。factoryInfo.setFactoryProperty(ONSFactoryProperty:NAMESRV_ADDR,"XXX");您在消息队列RocketMQ版控制台创建的Topic。factoryInfo.setFactoryProperty...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。string instanceId="${INSTANCE_ID};MQProducerPtr producer;if(instanceId=""){ producer=mqClient.getProducerRef(topic);} else { producer=mqClient.getProducerRef...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将 云消息队列 RabbitMQ 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 MQTT 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 云消息队列 MQTT 版 实例...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。instanceId="${INSTANCE_ID};this->producer=$this->client->getProducer($instanceId,$topic);} public function run(){ try { for($i=1;i;i+){$publishMessage=new ...
如果您对发送到 云消息队列 RabbitMQ 版 的消息有问题，您可以在控制台查询消息。云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式，前者适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在左侧导航栏，单击 迁移。在 迁移 页面，单击 规格评估。在 规格评估 面板，输入自建Kafka集群的规格信息，然后单击 确定 获取规格建议。在 获取推荐实例规格...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。const instanceId="${INSTANCE_ID};const producer=client.getProducer(instanceId,topic);(async function(){ try {/循环发送4条消息。for(var i=0;i;i+){ let res;...
查看用户列表 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击左侧操作栏的 用户管理，查看所有用户列表。新增用户 在 用户管理 页面，单击 添加LDAP用户。在...
迁移路由 云消息队列 Kafka 版 提供全托管、免运维的实例迁移服务，用于自建实例与 云消息队列 Kafka 版 实例之间或者 云消息队列 Kafka 版 实例之间的数据同步，无需借助工具即可在控制台上实现实例迁移，迁移完成后目标集群的元数据与源...
设置TCP接入域名，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。factoryInfo.setFactoryProperty(ONSFactoryProperty:NAMESRV_ADDR,"XXX");您在消息队列RocketMQ版控制台创建的Topic。factoryInfo.setFactoryProperty...
说明 调用 CreateQueue 或在 云消息队列 RabbitMQ 版 控制台 的 Queue管理 页面创建的Queue默认为持久化Queue。exclusive boolean Queue是否具有排他性：true：排他性类型，只对首次声明其的Connection可见，且会在Connection断开时自动...
设置云消息队列 RocketMQ 版Group ID，在云消息队列 RocketMQ 版控制台创建。properties.setProperty(PropertyKeyConst.GROUP_ID,"GID-XXXXX");AccessKey ID，阿里云身份验证，在阿里云RAM控制台创建。阿里云账号AccessKey拥有所有API的...
secretKey:=os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")/消息所属的Topic，在消息队列RocketMQ版控制台创建。topic:="${TOPIC}"/Topic所属的实例ID，在消息队列RocketMQ版控制台创建。若实例有命名空间，则实例ID必须传入；若实例无命名...
在阿里云 云消息队列 RocketMQ 版 控制台创建资源。更多信息，请参见 准备工作。（可选）参数说明 在使用社区版TCP协议的Java SDK接入阿里云 云消息队列 RocketMQ 版 收发消息时，需要配置相应的参数。更多信息，请参见 参数说明。您也可以...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RabbitMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 ...
设置云消息队列 RocketMQ 版Group ID，在云消息队列 RocketMQ 版控制台创建。properties.setProperty(PropertyKeyConst.GROUP_ID,"GID-XXXXX");AccessKey ID，阿里云身份验证，在阿里云RAM控制台创建。阿里云账号AccessKey拥有所有API的...
设置TCP接入域名，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。factoryInfo.setFactoryProperty(ONSFactoryProperty.NAMESRV_ADDR,"XXX");您在消息队列RocketMQ版控制台创建的Topic。factoryInfo.setFactoryProperty...
需特别注意的是，以下参数所对应的资源应处于同一地域：GROUP_ID：您在 云消息队列 RocketMQ 版 控制台上创建的Group ID。Topic：您在 云消息队列 RocketMQ 版 控制台上创建的Topic。NAMESRV_ADDR：您从 云消息队列 RocketMQ 版 控制台的 ...
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
设置为您在消息队列RocketMQ版控制台创建的Group ID。DefaultMQProducer producer("GID_XXX");设置为您从阿里云消息队列RocketMQ版控制台获取的接入点信息，类似“rmq-cn-XXXX.rmq.aliyuncs.com:8080”。注意！直接填写控制台提供的域名和...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建实例、查看实例详情、升级实例配置、降级实例配置和续费实例。运行状态 云消息队列 RabbitMQ 版 实例运行状态因其付费模式及实例版本不同而有所区别。表 1.运行状态 实例状态 说明 部署中...
创建${QueueName}，该Queue必须在云消息队列RabbitMQ版控制台上已存在。AMQP.Queue.DeclareOk queueDeclareOk=channel.queueDeclare(queueName,true,false,false,new HashMap,Object>());开始消费消息。channel.basicConsume(queueName,...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。string instanceId="${INSTANCE_ID};MQProducerPtr producer;if(instanceId=""){ producer=mqClient.getProducerRef(topic);} else { producer=mqClient.getProducerRef...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。final String instanceId="${INSTANCE_ID};获取Topic的生产者。MQProducer producer;if(instanceId!null&instanceId!{ producer=mqClient.getProducer(instanceId,...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。final String instanceId="${INSTANCE_ID};获取Topic的生产者。MQProducer producer;if(instanceId!null&instanceId!{ producer=mqClient.getProducer(instanceId,...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。创建消息流出任务 登录 云...
本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查看实例详情。背景信息 云消息队列 RocketMQ 版 实例按照规格分为标准版和企业铂金版，请您根据实际业务需求选择合适实例规格。标准版和企业铂金版实例的规格差异和计费...
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
}/${ExchangeName}必须在云消息队列 RabbitMQ 版控制台上已存在，并且Exchange的类型与控制台上的类型一致。{BindingKey}根据业务需求填入相应的BindingKey。AMQP.BasicProperties props=new AMQP.BasicProperties.Builder().messageId...
本文介绍如何在 云消息队列 Kafka 版 控制台创建元数据导入任务，将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署云消息队列 Kafka 版实例：购买并部署VPC实例 购买并部署公网/VPC实例 说明 购买实例的规格可...
操作步骤 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 概览 区域右上角的 开启 ACL。在 提示 对话框，单击 确认，然后手动刷新页面。手动刷新...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。instanceId="${INSTANCE_ID};this->producer=$this->client->getProducer($instanceId,$topic);} public function run(){ try { for($i=1;i;i+){$publishMessage=new ...
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。string instanceId="${INSTANCE_ID};MQProducerPtr producer;if(instanceId=""){ producer=mqClient.getProducerRef(topic);} else { producer=mqClient.getProducerRef...
告警处理：收到实例发送或消费API调用频率告警后，建议按照如下步骤处理：进入 消息队列RocketMQ版控制台 的仪表盘页面，分析API调用频率Top级数据的Topic和Group，判断业务变化是否合理。如果业务变化异常，则应该联系业务方进一步分析...
如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册阿里云账号并完成实名认证。更多信息，请参见 阿里云账号注册流程。步骤一：...