活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
热门活动
AI服务
教育应用
合作伙伴
天翼云携手合作伙伴，共创云上生态，合作共赢
开发者
开发者相关功能入口汇聚
消息队列RocketMQ版_相关内容
- 开源对比开源自建对比项 对比项 开源自建 分布式消息服务RocketMQ 自动化部署 不支持自动化部署,需要专业人员自行部署、运维 全托管PaaS,免机器资源一键自动化部署。开箱即用,按需使用,支持弹性扩容 运维监控 缺乏配套的监控运维能力 提供多维度的数据可视化监控,快速定位、处理问题 增强能力 功能单一,无法支持多种场景需求 功能丰富,支持消息重试、消息查询、消息轨迹查询、数据自动清理等定制化功能 延迟消息/定时消息 仅支持18个固定延迟时长,最长延迟2小时。
- 创建RocketMQ实例本文介绍分布式消息服务RocketMQ入门指引的创建RocketMQ实例内容。 实例介绍 RocketMQ实例订购支持用户自定义规格和自定义特性,采用物理隔离的方式部署。租户独占RocketMQ实例,可根据业务需要可定制相应规格的RocketMQ实例。在新的资源池节点上,还支持选择主机类型和存储规格等丰富用户选项。 操作步骤 1、在产品详情页点击立即开通按钮,或者进入消息管理控制台创建实例,进入订购分布式消息RocketMQ页面。 2、创建实例,注意选择产品规格。
- 设备轨迹本文为您介绍分布式消息服务MQTT的操作指南-设备轨迹。 分布式消息服务MQTT支持按clientId按天维度查询设备轨迹,以帮助排查设备在线问题和定位问题的原因。通过设备轨迹查询,您可以获取设备的连接历史和动作说明,以便更好地了解设备的行为和状态。 操作步骤 1、 天翼云官网点击控制中心,选择产品分布式消息服务MQTT。 2、 登录分布式消息服务MQTT控制台,点击右上角地域选择对应资源池。 3、 进入实例列表,点击【管理】按钮进入管理菜单。
- 消息收发发往该主题消息会转发至MQTT Broker实现云端与移动端互通 mqtt-device-connect 设备上线主题,内容 {"clientid":客户端ID,"ts":上线时间戳 } mqtt-device-disconnect 设备下线主题,内容 {"clientid":客户端ID,"ts":下线时间戳 } SDK支持 分布式消息服务MQTT支持标准的MQTT协议,理论上适配所有的MQTT客户端SDK。
- 基于消息队列RocketMQ实现全链路灰度本章节介绍如何基于消息队列RocketMQ实现全链路灰度 概述 本文介绍在使用消息队列(RocketMQ)这种异步场景下,可以在不修改业务代码的情况下,实现异步场景的灰度,从而实现全链路灰度。本文介绍基于消息队列RocketMQ实现全链路灰度。 背景介绍 在大多数业务场景中对于消息的灰度并没有RPC调用那么严格,但是当全链路灰度调用中涉及到消息消费时,如果消息消费没有按照全链路流量规则路由,则会导致通过消息产生的流量逃逸,从而破坏全链路规则,导致出现一些不符合预期的情况。
- 生产消费验证无序消息的特点是高吞吐量和低延迟,适用于一些不要求严格顺序的业务场景,如日志收集等。 在RocketMQ中,有序消息和无序消息的实现方式略有不同。有序消息需要借助MessageQueue的分区机制和消费者端的顺序消息消费来实现。而无序消息则是通过消息的发送和接收的并发处理来实现的。 总的来说,RocketMQ既支持有序消息也支持无序消息,根据业务需求选择合适的消息类型来满足业务的要求。 选择消费方式,目前仅提供pull方式。
- 环境准备生产消费验证涉及的SDK如下: rocketmq引擎版本:推荐使用的社区版Java SDK版本为4.9.3,请访问Apache RocketMQ官网下载。 ctgmq引擎版本(已调整白名单特性):点击ctgmq-SDK直接下载。
- 产品定义开源对比 相较于开源自建RocketMQ,分布式消息服务RocketMQ在自动化部署、运维监控、增强能力、延迟消息/定时消息、ACL访问控制等方面更具优势。更多信息请参见开源对比。 支持的消息类型 分布式消息服务RocketMQ支持的消息类型包括普通消息、顺序消息、事务消息与延时消息。 普通消息:RocketMQ中无特性的消息,普通消息主要包含同步消息和异步消息两种。
- 功能特性事务消息 消息队列 RocketMQ 提供类似 X/Open XA 的分布事务功能。半事务消息发送后,根据预设的事务进行判断,满足事务的消息将会被服务端确认,不满足的事务的消息不会被服务端接收,从而实现在分布式场景下保障消息生产和本地事务的最终一致性。 半消息: 暂不能投递的消息,发送方已经将消息成功发送到了消息队列服务端,但是服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状态,处于该种状态下的消息即半消息。
- 产品规格天翼云分布式消息服务RocketMQ支持的产品规格如下所示: 说明TPS(Transaction per second)是指每秒可以生产消息和消费消息的总次数,可以理解为对应规格每秒生产消息和消费消息的总吞吐量。
- 名词解释在广播消费模式下,一条消息被多个Consumer消费,即使这些Consumer属于同一个Consumer Group,消息也会被Consumer Group中的每个Consumer都消费一次,广播消费中的Consumer Group概念可以认为在消息划分方面无意义。V1.x版本由于广播消费的消费进度,是保存在客户端的,对于很多使用场景会带来影响,在RocketMQ中,并不推荐使用此消费模式。
- 创建主题和订阅组5)填写每个Broker分区数,分区数必须大于0,小于等于8,创建严格顺序队列时,设置分区数为1,且只能选择一个broker。 6)选择生产模式,RocketMQ是一个开源的分布式消息中间件,它支持两种消息生产模式:有序和无序。 有序消息生产模式(Ordered Message)是指按照特定规则将消息发送到相同的Message Queue中,并且确保消息在消费者端按照相同的顺序进行消费。这种模式适用于那些需要严格按照消息顺序进行处理的场景,比如订单处理、流程审批等。
- 分布式消息产品选型特性 Kafka RabbitMQ RocketMQ 功能 支持功能较少,不支持延迟发送,消息重试等功能 功能丰富,支持多个队列种类(优先级队列、延迟队列、死信队列镜像队列等),提供丰富的策略分配 功能完善,支持事务消息、定时消息、事务消息等 单机吞吐量 十万级 万级 几万级 稳定性 队列/分区多时性能不稳定 消息堆积时,性能不稳定 队列较多、消息堆积时性能保持稳定 可用性 非常高(分布式)具有主备故障自动切换 较高,基于主从架构实现高可用性 非常高(分布式)具有主备故障自动切换
- 分布式消息产品选型特性 Kafka RabbitMQ RocketMQ 功能 支持功能较少,不支持延迟发送,消息重试等功能 功能丰富,支持多个队列种类(优先级队列、延迟队列、死信队列镜像队列等),提供丰富的策略分配 功能完善,支持事务消息、定时消息、事务消息等 单机吞吐量 十万级 万级 几万级 稳定性 队列/分区多时性能不稳定 消息堆积时,性能不稳定 队列较多、消息堆积时性能保持稳定 可用性 非常高(分布式)具有主备故障自动切换 较高,基于主从架构实现高可用性 非常高(分布式)具有主备故障自动切换
- 分布式消息产品选型特性 Kafka RabbitMQ RocketMQ 功能 支持功能较少,不支持延迟发送,消息重试等功能 功能丰富,支持多个队列种类(优先级队列、延迟队列、死信队列镜像队列等),提供丰富的策略分配 功能完善,支持事务消息、定时消息、事务消息等 单机吞吐量 十万级 万级 几万级 稳定性 队列/分区多时性能不稳定 消息堆积时,性能不稳定 队列较多、消息堆积时性能保持稳定 可用性 非常高(分布式)具有主备故障自动切换 较高,基于主从架构实现高可用性 非常高(分布式)具有主备故障自动切换
- 创建实例租户独占RocketMQ实例,可根据业务需要可定制相应规格的RocketMQ实例。在新的资源池节点上,还支持选择主机类型和存储规格等丰富用户选项。 操作步骤 1、在产品详情页点击立即开通按钮,或者进入消息管理控制台创建实例,进入订购分布式消息RocketMQ页面。 2、创建实例,注意选择产品规格。按照不同资源池,提供新旧两种模式创建实例。 (1)旧模式创建实例 以下适用于南京3、上海7、重庆2、乌鲁木齐27、石家庄20、内蒙6、晋中、北京5节点。
- 云日志服务C SDK本文主要介绍云日志服务C SDK接入指南。 前言 安装使用C SDK可以帮助开发者快速接入使用天翼云的日志服务相关功能,目前支持日志同步上传。 2. 使用条件 2.1. 先决条件 用户需要具备以下条件才能够使用LTS SDK C版本: 1、购买并订阅了天翼云的云日志服务,并创建了日志项目和日志单元,获取到相应编码(logProject、logUnit)。 2、已获取AccessKey 和 SecretKey。 3、已安装C 运行环境。 2.2.
- 云日志服务C++ SDK3、将ctyun_lts_cpp_sdk的include目录下的头文件,全部移动到您项目的include目录下,(如果直接使用SDK 则可以不用移动)。 4、之后就可以在您的项目内使用SDK了,只需要引入对应的头文件即可。 5、编译您的程序,在您目录下内编译您的程序,构建出可执行文件。 如sample_putlogs.cpp: g++ sample_putlogs.cpp -I./include -L.
- 产品优势支持灵活的消息过滤机制:RocketMQ可以通过对消息的属性进行过滤,只有满足条件的消息才会被消费者接收。这样可以实现消息的动态路由和选择性消费,提升系统的灵活性和效率。 支持消息延迟发送和定时消费:RocketMQ可以设置消息的延迟时间,使消息在指定的时间后才能被消费者接收。这对于实现定时任务和延迟处理非常有用。 良好的可扩展性:RocketMQ采用了分布式架构,并且支持主从复制和消息分区机制。
- SDK参考该页面主要介绍关系数据库MySQL版的SDK,您可以根据实际业务需求进行集成。 各语言SDK下载及使用支持语言SDK附件JavaMySQL-SDK-JAVA.zip(v1.0.0)GoMySQL-SDK-GO.zip(v1.0.0)说明由于运行环境的多样性,部分接口在某些特定配置下可能存在适配差异,我们的技术团队将持续优化兼容性。如有问题,可提单咨询。
- 入门指引5.生产消费验证 以上工作完成后,通过控制台拨测功能生成生产和消费测试数据,用户应用也可按照规范接入RocketMQ,发送、消费消息。
- Nacos SDK应用和限制技术栈 原生SDK 框架(Spring Boot) 框架(Spring Cloud) Java Naocs提供Java SDK 连接实例 Spring Boot框架的接入方案请参考章节:Nacos Spring Boot快速接入 Spring Cloud框架的接入方案请参考章节:如何在MSE上为Spring Cloud应用构建服务注册中心? SDK的使用限制 Java 不推荐的版本 不推荐原因 解决方案 0.X ~ 1.3.X 版本陈旧,影响性能。
- 云日志服务.NET SDK3、已安装C#10.0 以上开发环境,推荐支持.NET 6或以上版本。 2.2. 下载及安装 项目基于.Net Standard 2.0 构建,可适用于.netcore、.net5.0以上框架使用。从官方渠道下载ctyun_lts_net_sdk.zip压缩包,放到相应位置后并解压。“ctyun_lts_net_sdk”目录中ctyun_lst_net_sdk 模块是SDK的逻辑代码,test_net_sdk模块为SDK的使用示例代码。
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
