基于消息队列RocketMQ版实现全链路灰度

通过消息队列这类异步场景下的流量控制,您可以在不需要修改任何业务代码的情况下,实现全链路灰度。本文介绍MSE基于消息队列RocketMQ版实现全链路灰度。前提条件 开通MSE微服务治理。创建Kubernetes托管版集群。Demo架构 本文以容器服务...

开发场景:基于消息队列RocketMQ版实现环境隔离

本文介绍如何在 Serverless应用引擎SAE(Serverless App Engine)上基于阿里云 消息队列RocketMQ版 实现环境隔离,您可以在不修改任何业务代码的情况下,实现异步场景下的流量控制。背景信息 支持RocketMQ版本:4.2.0及以上版本。支持Pull...

快速使用MQTT的Java SDK收发消息(终端和云端消息收发...

接入点说明 终端和云端服务与 云消息队列 MQTT 版 通信时,需要在各自的SDK代码中设置 云消息队列 MQTT 版 实例的接入点信息,通过接入点和 云消息队列 MQTT 版 服务端连接。终端SDK接入点格式 使用终端SDK接入 云消息队列 MQTT 版 时,...

快速使用MQTT的Java SDK收发消息(终端和终端消息收发...

各终端设备均通过终端SDK 云消息队列 MQTT 版 与 云消息队列 MQTT 版 服务端连接实现消息收发。本文以公网环境为例,说明如何使用Java SDK完成消息收发。接入点说明 终端和云端服务与 云消息队列 MQTT 版 通信时,需要在各自的SDK代码中...

通过RAM角色实现跨云账号授权

通过API访问资源 企业B的RAM用户可通过调用 云消息队列 RocketMQ 版 提供的API接口访问企业A的资源。调用API的方法,请参见 API调用方式。相关文档 权限概述 RAM主子账号授权 服务关联角色 云消息队列 RocketMQ 版自定义权限策略

通过RAM角色实现跨云账号授权

步骤二:跨云账号访问资源 通过SDK访问资源 企业B的RAM用户可通过SDK访问企业A的 云消息队列 RocketMQ 版 资源,完成消息收发功能。SDK访问有以下两种配置方式:配置STS Token:使用STS Token方式,您必须在SDK代码中提供RAM用户的...

Topic导入/导出

消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时,使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...

Topic导入/导出

消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时,使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...

Group导入/导出

消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Group的跨实例迁移。你可以在更换实例或者克隆实例时,使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...

Group导入/导出

消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Group的跨实例迁移。你可以在更换实例或者克隆实例时,使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...

消息收发功能

发送端和消费端的终端设备均通过开源的终端SDK接入 云消息队列 MQTT 版 实现消息收发。典型场景示例 即时通信:例如,两个安装有聊天App的移动手机直接通过消息队列 MQTT 版 服务端收发聊天信息。智能设备管理:例如,通过安装在手机上...

示例代码

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息,只要不抛出异常,就代表发送成功。try { SendResultONS sendResult=...

收发普通消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息,只要不抛出异常,就代表发送成功。try { SendResultONS sendResult=...

收发顺序消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");分区顺序消息中区分不同分区的关键字段。如果是全局顺序消息,该字段可以设置为任意非...

消息查询

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息。不设置也不会影响消息正常收发。msg.setKey("TestKey"+System.currentTimeMillis());按 Topic 查询 按Topic查询一般用在Message ID和Message Key都无法获得的...

收发定时消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time单位ms,指定一个时刻,在这个时刻之后消息才能被消费,这个例子表示3s后...

收发顺序消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey(orderId);分区顺序消息中区分不同分区的关键字段,Sharding Key与普通消息的key是完全不同的概念。...

示例代码

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_"+i);try { SendResult sendResult=producer.send(msg);同步发送消息,只要不抛异常就是成功...

示例代码

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time,单位:ms。指定一个时刻,在这个时刻之后消息才能被消费,这个例子表示...

收发定时消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");try {/定时消息,单位毫秒(ms),在指定时间戳(当前时间之后)进行投递,例如2016-...

收发定时消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time,单位:ms。指定一个时刻,在这个时刻之后消息才能被消费,这个例子表示...

迁移上云操作

步骤二:配置网络信息 创建迁移任务并配置源自建集群的网络信息,用于 云消息队列 RocketMQ 版 迁移工具读取源自建集群的元数据信息,并实现后续迁移任务的控制。注意事项 云消息队列 RocketMQ 版 迁移工具按照最小范围粒度仅访问源自建...

消息收发流程变更

消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...

短轮询和长轮询

消息服务MNS 提供短轮询(Short Polling)和长轮询(Long Polling)两种方式来获取队列中的消息。短轮询 创建队列时,长轮询时间设置为0,且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息,popMessage请求会向...

ACL授权

ACL授权主要有两种方式:通过消息队列 Confluent 版 控制台实现ACL授权。本文详细介绍这一授权方式。使用Confluent CLI实现ACL授权。操作步骤,请参见 使用Confluent CLI进行管理ACL。ACL授权 登录 云消息队列 Kafka 版 控制台,在左侧...

基于Flink的资讯场景实时数仓

解决的问题 通过消息队列 Kafka 版 和实时计算Flink实现实时数据处理和数据流。通过消息队列 Kafka 版 和实时计算Flink实现实时数据分析。通过消息队列 Kafka 版 和实时计算Flink实现事件触发。部署架构图 选用的产品 云消息队列 ...

SDK列表

消息队列 RabbitMQ 版 SDK(RAM角色跨账号授权场景)如果您是RAM STS角色授权的使用场景,需要通过消息队列 RabbitMQ 版 SDK收发消息,该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 ...

应用场景

本文为您介绍 云消息队列 RabbitMQ 版 的应用场景,以便您更好地判断如何在业务中使用 云消息队列 RabbitMQ 版。异步解耦 云消息队列 RabbitMQ 版 可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再...

新零售电子价签解决方案(MQTT)

新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出,通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项,其他类似行业可参考该方案...

配置消息日志

您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时,您可在日志服务查询并分析消息的操作日志,进行异常诊断。前提条件 创建 云消息队列...

消息存活时间

设置方式 云消息队列 RabbitMQ 版 支持您通过以下方式设置消息存活时间:云消息队列 RabbitMQ 版 控制台 您可以通过消息队列 RabbitMQ 版 控制台为指定Queue设置消息存活时间。具体操作,请参见 Queue管理。OpenAPI Explorer 您可以通过...

SDK FAQ

您需要通过Maven配置依赖库才能接入 云消息队列 RabbitMQ 版 收发消息。如何通过Maven配置依赖库来收发消息,请参见 JMS概述。JMS标准有哪些接口不支持?云消息队列 RabbitMQ 版 支持 JMS 1.1。具体兼容的接口信息,请参见 JMS接口兼容性。...

自由使用Group

注意事项 在生产环境,长期开启自由使用Group的功能,可能会由于客户端使用不当出现资源随意使用,导致运维成本增加,并且极易造成系统不稳定,建议您通过消息队列 Kafka 版 控制台或者调用OpenAPI手动创建Group,进行统一管理。...

队列(MessageQueue)

本文介绍 云消息队列 RocketMQ 版 中队列(MessageQueue)的定义、模型关系、内部属性、版本兼容性及使用建议。定义 队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器,也是 云消息队列 RocketMQ 版 消息的最小存储单元。云消息...

开源RabbitMQ元数据迁移上云

否 重要 如果您的RabbitMQ集群使用了用户管理Vhost的权限,您可以通过访问控制为 云消息队列 RabbitMQ 版 实例实现对应的用户管理Vhost的权限。更多信息,请参见 RAM权限策略。parameters RabbitMQ集群的运行时参数。否 global_parameters ...

延时消息

方案对比 云消息队列 RabbitMQ 版 和开源RabbitMQ支持的延时消息实现方案对比如下:项目 开源RabbitMQ 云消息队列 RabbitMQ 版 死信Exchange+Queue的消息存活时间 支持 支持 死信Exchange+消息的消息存活时间 支持 支持 开源延时消息插件...

DeleteCaCertificate-删除CA证书

消息队列 MQTT 版支持X.509证书认证,客户端可通过设备证书完成接入认证。CA证书用于为客户端签发设备证书,并验证设备证书的正确性。使用CA证书需要先将证书注册到云消息队列 MQTT 版服务端,若您不再需要使用某个CA证书,您可以调用...

步骤二:创建资源

一个新的应用接入 云消息队列 RabbitMQ 版 服务端,您需要提前创建 云消息队列 RabbitMQ 版 的相关资源,包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...

将云消息队列 Kafka 版接入阿里云Elasticsearch

当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将 云消息队列 Kafka 版 接入阿里云Elasticsearch的操作方法。前提...

作为Input接入

本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC接入。下载并安装Filebeat。具体操作,请参见 ...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 弹性公网IP 云安全中心 全局事务服务 (文档停止维护) 短信服务
新人特惠 爆款特惠 最新活动 免费试用