新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
获取MQTT客户端在线状态
业务应用一般部署在阿里云的服务器上，业务应用通过向后端存储消息队列订阅这条消息来获取所有客户端的上下线动作。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要根据事件发生的时间序列分析出客户...
调用TCP协议的SDK收发普通消息
在控制台创建完所有资源之后，您可以调用 云消息队列 RocketMQ 版 的TCP协议的SDK收发普通消息。前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务...
示例代码
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个...
MQTT客户端上下线事件数据流出
业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要根据事件发生的时间序列分析出客户端的...
Spring集成
RabbitListener(queues="myQueue")public void receiveFromMyQueue(Message message,Channel channel){/进入消息消费业务逻辑。须在Ack有效期（消息重试间隔时间）内返回Ack，否则为无效确认，消息还会被重复投递。channel.basicAck...
什么是云消息队列 RocketMQ 版？
应用场景 云消息队列 RocketMQ 版 基于统一消息存储和轻量计算层，主要应用于微服务异步解耦、流式数据处理、事件驱动等场景。业务消息 异步解耦、削峰填谷 云消息队列 RocketMQ 版 初始于阿里巴巴双十一核心链路，广泛应用于物流、购物车...
解决方案介绍
背景信息 阿里云Web应用防火墙混合云解决方案（混合云WAF），支持为部署在阿里云公共云+线下IDC机房的业务、部署在阿里云公共云+第三方云厂商环境的业务提供统一的Web应用防护和管理方案，对无法上云的业务流量提供防护，打造共享和独享相...
操作流程
业务链路 从任务视角对所有监控任务运行状态进行实时监控，同时支持告警信息的统一查看。具体操作，请参见 查看业务链路。监控概览 从全局角度，对监控内容进行分类统计展示，便于掌握整体的运行情况。具体操作，请参见 查看监控概览。
操作流程
业务链路 从任务视角对所有监控任务运行状态进行实时监控，同时支持告警信息的统一查看。具体操作，请参见 查看业务链路。监控概览 从全局角度，对监控内容进行分类统计展示，便于掌握整体的运行情况。具体操作，请参见 查看监控概览。
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
可观测性体系概述
指标 云消息队列 RocketMQ 版 中定义了详细的Metrics指标，这些指标覆盖生产者、消费者、服务端及消息收发关键接口和流程的统计数据，并支持从实例、Topic和Group等多个维度进行聚合展示，帮助您实时监控消息业务或 云消息队列 RocketMQ 版...
产品简介
事件中心 统一的报警、事件、故障任务流转处理 事件中心是统一的任务流转中心，统一管理整个企业业务系统运行过程中的所有报警、事件、故障。管理系统历史的所有报警记录、报警消息及时通知订阅对象，帮助企业实时发现问题，规避风险；管理...
消费者（Consumer）
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输行为：消费者身份：消费者必须关联一个指定的消费者分组，以获取分组内统一...
全场景解决方案
单机房>同城双活>异地多活>混合云 金融级应用 PaaS，安全生产支撑 异构 IaaS 适配/多集群/应用管理/可观测性/应急容灾 Mesh 异构集成，存量应用平滑上云 基础架构和业务解耦/多语言/多协议/多平台 客户案例 建议产品 统一应用运维 方案架构...
消息 Mesh
缺乏一个统一的架构指导思想，混乱无序地向客户端叠加相关功能只会让消息客户端变得越来越臃肿和难以维护，也变相增加了业务系统的接入、调试和排查问题的成本。消息 Mesh 作为 Service Mesh 的补充，能显著带来如下价值和收益：快速升级：...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
产品概述
数据采集：采集设备实时数据，集成信息系统业务数据 提供标准化设备数据接入流程，快速采集设备数据 广泛设备协议接入能力，支持OPC、Modbus和多种三方驱动协议 支持API、WebService、消息队列、FTP文件多种业务数据集成方式 根据业务规则...
通用WebSocket接入指南
4.发送&接收业务消息 说明 业务消息指的是不同于建连、断开、心跳、心跳回执这类系统消息，是代表有业务意义的消息，如互动数字人的语音流消息，以及互动数字人返回的ASR文本消息。消息格式：业务消息协议：消息内容：5{"messageId":...
统一语言
本文介绍如何在统一语言页面新建和管理角色、业务术语和动词库。新建和管理角色 新建角色 登录BizWorks，在 选择平台 下拉列表中选中 建模平台。单击页面右上角 图标或其文本框区域，在下拉列表中单击目标项目名称后，单击 建模 页签。在 ...
产品简介
平台提供通讯录管理、即时通讯、音视频、消息触达、应用接入能力，支持专有云部署。助力解决三融五跨组织数字化协同、沟通和统一工作门户的问题。客户群体 金融行业：助力监管机构、银行、证券、保险行业企业构建专有的移动数字化协同体系...
应用场景
云盒适用于数据本地处理、低延时、数据安全、多分支机构集中统一管理等场景。数据本地处理 场景说明 场景示例 使用云盒的优势 某些场景下需要使用大量数据，这些数据传输到云上处理不仅会受到带宽或时间等限制，还会产生传输费用，因此需要...
实例类型
本文介绍 云消息队列 MQTT 版 的实例类型。地域限制 专业版实例和Serverless版实例仅华东1（杭州）、华东2（上海）、华北3（张家口）、华北2（北京）和华南1（深圳）地域支持，其他地域暂不支持。表 1.实例类型 项目 Serverless版 专业版 ...
死信消息
示例如下：messageBuilder.addProperty("originalTopic","testTopic")死信消息和主业务区分处理 死信消息是正常业务流程中消息重试仍然失败的消息，需要和主业务流程分开处理，避免影响正常业务。死信Topic和原消息发送Topic不能相同，避免...
消费重试
了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略可以帮助您分析如下问题：如何保证业务完整处理消息：了解消费重试策略，可以在设计实现消费者逻辑时保证每条消息处理的完整性，避免部分消息出现异常时被忽略，导致业务状态不...
实例化支持
在2019年01月23日，云消息队列 RocketMQ 版 优化了资源隔离、资源申请、协议支持以及权限管理。本文提供相关更新说明，帮助您更顺畅地使用 云消息队列 RocketMQ 版。说明 为兼容新老资源配置，建议您将ons-client客户端升级到最新版本。...
附录：SOFAStack 产品目录
引入消息队列后，利用消息队列的抗堆积能力，这些业务系统作为消息的消费方，可以根据自身应用的能力进行消息的消费，不受大流量的影响。API 网关 API 网关（API Gateway）是一个 API 管理平台，帮助企业统一管理对内外开放的 API，为网络...
示例代码
云消息队列 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...
迁移上云概述
您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验，本文为您介绍开源RocketMQ集群迁移上云的方案及原理。产品差异对比 和开源RocketMQ相比，阿里云 云消息队列 RocketMQ 版 在技术架构、弹性效率、运维复杂...
消息幂等
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
领域模型概述
消息生产 生产者（Producer）：云消息队列 RocketMQ 版 中用于产生消息的运行实体，一般集成于业务调用链路的上游。生产者是轻量级匿名无身份的。消息存储 主题（Topic）：云消息队列 RocketMQ 版 消息传输和存储的分组容器，主题内部由多...
事务消息
基于 云消息队列 RocketMQ 版 分布式事务消息：支持最终一致性 上述普通消息方案中，普通消息和订单事务无法保证一致的原因，本质上是由于普通消息无法像单机数据库事务一样，具备提交、回滚和统一协调的能力。而基于 云消息队列 RocketMQ ...
基本概念
主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。更多信息，请参见 主题（Topic）。消息类型（MessageType）云消息队列 RocketMQ 版 中按照消息...
回执消息简介与配置流程
重要 初始状态下，没有关联过队列的号码池统一使用默认队列接收消息。单击 确定。HTTP批量推送模式。开启HTTP批量推送模式左侧的功能开关。说明 部分消息类型没有HTTP批量推送模式，请以控制台显示的消息类型为准。如：异常号码状态推送无...
消息重试
云消息队列 RocketMQ 版 支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
应用容灾
消息：业务流量在机房内部和跨机房的异步调用方式，基于消息削峰填谷，一般有 Producer、Consumer、Broker 等角色。数据层涵盖业务应用数据读写、数据存储和数据同步，其具备流量路由、数据一致性保护、数据同步三个核心能力。云平台是支撑...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
- 产品推荐
- 这些文档可能帮助您