消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
RocketMQ 5.x Serverless实例概述
在使用消息中间件时，为保证业务的稳定性，往往需要按照业务请求的峰值去配置消息中间件集群的资源，包括CPU、内存、存储、网络等多种资源。但在实际生产使用时，消息中间件所用资源大部分时间处于低利用率状态，造成资源浪费与闲置。云...
中间件产品总览
Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息中间件 ...
在线教育视频直播
部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里巴巴集团已超过13年，经过交易核心链路反复打磨与历年双十一高并发场景的...
应用部署时的默认启动命令参数
微服务 address.server.port 8080 中间件服务器地址的端口，通过该地址查找中间件服务端的真实地址。微服务 configserver.client.port 8000 ConfigServer服务端的地址，配置后，Config Server Client会连接服务端的这个端口。微服务 dpath....
版本说明
0.6（2020-01-10）发布 SOFAStack 消息队列，是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成。支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息。详见 消息类型。提供专业、可靠、...
产品架构
集群级别的高可用，是 云消息队列 RocketMQ 版 跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。重要 文中所提及的 云消息队列 RocketMQ 版...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
领域模型概述
消息传输模型介绍 主流的消息中间件的传输模型主要为点对点模型和发布订阅模型。点对点模型 点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信...
产品架构
集群级别的高可用，是消息队列跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。说明 文中所提及的消息队列的服务端或者服务器包含 Name ...
术语介绍
以下通过示例帮助您更好地理解授权组的概念：您在阿里云上共10个ECS实例，其中：应用服务器2个（APP1、APP2）数据库服务器2个（DB1、DB2）中间件服务器2个（M1、M2）开发测试服务器4个（TEST1-4）您单位共有三类工作人员：开发人员...
什么是云消息队列 RocketMQ 版？
削峰填谷提高稳定性 传统消息中间件仅满足业务的异步化需求，而 云消息队列 RocketMQ 版 诞生于在线互联网和交易业务场景，除了满足异步能力，还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性，还能大幅降低业务成本...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息类型，并具备高可靠、...
消费重试
云消息队列 RocketMQ 版 作为金融级的可靠业务消息中间件，在消息投递处理机制的设计上天然支持可靠传输策略，通过完整的确认和重试机制保证每条消息都按照业务的预期被处理。了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
签名鉴权模式
签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、AccessKeyId和...
通信消息相关问题
本文介绍设备与物联网平台和物联网平台与服务器端的通信相关问题和解决方法。类目 问题 上下行消息 设备重复收到消息，如何去重？设备使用MQTT协议接入物联网平台后，接收不到通信数据，怎么办？物联网平台发送消息比较慢，存在超时情况，...
什么是Topic
代理者（Broker）是设备和业务服务器消息通信的中介，解耦了设备和业务服务器，实现了设备和业务服务器之间的异步通信。MQTT协议消息的组成部分 主题（Topic）：使用正斜杠（/）作为分隔符构造字符串，例如/${productKey}/${deviceName}/...
漏洞公告|Windows SMBv3远程执行代码漏洞（CVE-2020-...
漏洞信息 漏洞编号：CVE-2020-0796 漏洞评级：高危，风险极大 补丁更新日期：2020年03月12日 漏洞位置：Windows 10和Windows Server的服务器消息模块3.1.1（Server Message Block 3.1.1，简称SMBv3）影响版本：Windows 10，Version 1903，...
应用总览
应用服务被调用-service 应用总量、LDC 总量、IDC 总量、接口方法明细、来源应用、服务器、应用实例 SQL 耗时检测-sql 应用 Top Flow Limit-flowlimit 应用总量、LDC 总量、IDC 总量、服务器 消息发布-msgpub 应用总量、LDC 总量、IDC 总量...
应用总览
Top Flow Limit-flowlimit 应用总量、LDC 总量、IDC 总量、服务器 消息发布-msgpub 应用总量、LDC 总量、IDC 总量、Topic Eventcode 总量、服务器、应用实例 消息订阅-msgsub 应用总量、LDC 总量、IDC 总量、Topic Eventcode 总量、服务器...
配置相关
与消息队列配置相关的常见问题如下：消息队列消息在服务器保存多长时间？消息队列消息 Body 的长度限制是多少？消息队列客户端如何设置消费线程数？消息队列消息在服务器保存多长时间？存储的消息最多保存 3 天，超过 3 天未消费的消息会被...
产品架构
本文介绍 云消息队列 Kafka 版 的系统架构和发布/订阅模型。云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示，一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
一机一密概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的设备访问凭证相关的请求以及消息收发业务。计算方式 按照 鉴权概述 的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect ...
OnsMessageDetail-查询消息详细信息
1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息所属的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。MSG_REGION Name string 消息...
物联网平台通信方式概述
消息基于Topic传递数据，Topic中的数据格式请参见 数据格式。服务端订阅：使用物联网平台的服务端订阅功能，订阅一个或多个消息类型。物联网平台根据您设置的订阅，将产品下所有设备的该类型消息流转至您的服务器。支持以下两种方式的服务...
自定义鉴权模式
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明 无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...
OnsMessageGetByMsgId-通过MsgId查询消息
通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾被消费过。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 Open...
OnsDLQMessageGetById-根据Message ID查询死信消息
0BC16699165C03B925DB8A404E2D*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。...
OnsMessageGetByKey-根据Message Key查询消息
1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...
通过ALB连接优雅中断实现业务平稳下线
当您移除某个后端服务器或者后端服务器健康检查异常时，该后端服务器已建立的连接不会立即中断，客户端访问时仍持续有请求转发至这些后端服务器。此时会导致后端服务器的业务长期无法下线或出现请求错误。为了避免该问题，您可以使用ALB的...
资产指纹调查
具体采集以下内容：服务器信息：中间件所在的服务器信息，包括服务器名称和IP地址。中间件：中间件的名称。类型：中间件的所属类型。运行时环境版本：中间件运行时的环境的版本。版本：原中间件的版本号。PID：中间件的启动进程的ID。启动...
- 产品推荐
- 这些文档可能帮助您