收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
基本概念
可参考以下说明：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和堆积情况，通过观察这些指标可初步判断业务的消费是否异常。...
一机一密概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的设备访问凭证相关的请求以及消息收发业务。计算方式 按照 鉴权概述 的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect ...
步骤五：到控制台验证
基于 开发单元化应用 中的转账与积分场景，在完成相应的转账或存款等操作后，您可以前往各个产品控制台验证单元化效果：分布式链路跟踪：查看单元间流量走向 分布式事务：查看事务执行情况 消息队列：查看消息轨迹 微服务：按单元推送动态...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
自定义鉴权模式
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 版 ...
使用场景和主要概念
场景2：客户现有业务应用如需接入到BizWorks体系中进行统一运营，但尚未完成微服务改造，可利用应用集成平台快速接入到BizWorks体系内。主要组成部分 集成应用 集成应用是BizWorks的一种应用类型，用来承载具体的编排逻辑的实现。设计、...
组件中心
任务调度 提供分布式任务调度框架，实现任务的分布式处理，并能规范化、自动化、可视化和集中化地对金融企业不同业务系统的任务进行统一的调度和全方位的监控运维管理。消息队列 在蚂蚁集团关键链路中历经十年实战打磨，是一款具备高可靠、...
可观测性体系概述
指标 云消息队列 RocketMQ 版 中定义了详细的Metrics指标，这些指标覆盖生产者、消费者、服务端及消息收发关键接口和流程的统计数据，并支持从实例、Topic和Group等多个维度进行聚合展示，帮助您实时监控消息业务或 云消息队列 RocketMQ 版...
什么是云原生应用组装平台BizWorks
云原生应用组装平台BizWorks是基于组装式理念和阿里巴巴中台实践构建的一体化云原生应用开发和组装平台，提供了业务建模、微服务开发、轻应用组装、能力开放等平台功能，致力于帮助企业快速设计、构建、组装和运营可复用的业务能力组件和...
产品简介
事件中心 统一的报警、事件、故障任务流转处理 事件中心是统一的任务流转中心，统一管理整个企业业务系统运行过程中的所有报警、事件、故障。管理系统历史的所有报警记录、报警消息及时通知订阅对象，帮助企业实时发现问题，规避风险；管理...
产品架构
开发者可通过EMAS Serverless支撑各类小程序前端，在一朵云内实现统一的资源管理、统一的数据运营和统一的业务设计。产品文档 移动测试 移动测试服务（Mobile Testing）是为企业客户和移动开发者提供真机测试服务的云平台，提供大量热门...
统一语言
本文介绍如何在统一语言页面新建和管理角色、业务术语和动词库。新建和管理角色 新建角色 登录BizWorks，在 选择平台 下拉列表中选中 建模平台。单击页面右上角 图标或其文本框区域，在下拉列表中单击目标项目名称后，单击 建模 页签。在 ...
消费者（Consumer）
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输行为：消费者身份：消费者必须关联一个指定的消费者分组，以获取分组内统一...
消息 Mesh
缺乏一个统一的架构指导思想，混乱无序地向客户端叠加相关功能只会让消息客户端变得越来越臃肿和难以维护，也变相增加了业务系统的接入、调试和排查问题的成本。消息 Mesh 作为 Service Mesh 的补充，能显著带来如下价值和收益：快速升级：...
产品概述
数据采集：采集设备实时数据，集成信息系统业务数据 提供标准化设备数据接入流程，快速采集设备数据 广泛设备协议接入能力，支持OPC、Modbus和多种三方驱动协议 支持API、WebService、消息队列、FTP文件多种业务数据集成方式 根据业务规则...
通用WebSocket接入指南
回执消息格式：业务消息协议：消息内容：6{"messageId":"msg_1659937198426_687"} 消息格式：Text类型的DataFrame（字符串，编码：UTF-8）回执消息会带上对应消息的messageId，发送方可以根据是否收到回执消息才判断接收方是否成功接收到...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
产品简介
平台提供通讯录管理、即时通讯、音视频、消息触达、应用接入能力，支持专有云部署。助力解决三融五跨组织数字化协同、沟通和统一工作门户的问题。客户群体 金融行业：助力监管机构、银行、证券、保险行业企业构建专有的移动数字化协同体系...
应用场景
云盒适用于数据本地处理、低延时、数据安全、多分支机构集中统一管理等场景。数据本地处理 场景说明 场景示例 使用云盒的优势 某些场景下需要使用大量数据，这些数据传输到云上处理不仅会受到带宽或时间等限制，还会产生传输费用，因此需要...
模型画布简介
模型中心提供在模型画布中对业务模型进行组装、编排。在模型画布中，您可通过鼠标的拖拽和简单的条件设定，即可快速实现数据和原子算法的快速组装，即便是没有基础的业务人员，也可方便的建立自己的模型、形成自己的标签、自主探索使用数据...
实例类型
本文介绍 云消息队列 MQTT 版 的实例类型。地域限制 专业版实例和Serverless版实例仅华东1（杭州）、华东2（上海）、华北3（张家口）、华北2（北京）和华南1（深圳）地域支持，其他地域暂不支持。表 1.实例类型 项目 Serverless版 专业版 ...
死信消息
示例如下：messageBuilder.addProperty("originalTopic","testTopic")死信消息和主业务区分处理 死信消息是正常业务流程中消息重试仍然失败的消息，需要和主业务流程分开处理，避免影响正常业务。死信Topic和原消息发送Topic不能相同，避免...
实例化支持
在2019年01月23日，云消息队列 RocketMQ 版 优化了资源隔离、资源申请、协议支持以及权限管理。本文提供相关更新说明，帮助您更顺畅地使用 云消息队列 RocketMQ 版。说明 为兼容新老资源配置，建议您将ons-client客户端升级到最新版本。...
- 产品推荐
- 这些文档可能帮助您