rocketmq高性能
社区干货
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。, producer.WithCredentials(primitive.Cre...
干货|字节跳动流式数据集成基于Flink Checkpoint两阶段提交的实践和优化(2)
> > > 字节跳动开发套件数据集成团队(DTS ,Data Transmission Service)在字节跳动内基于 Flink 实现了流批一体的数据集成服务。其中一个典型场景是 Kafka/ByteMQ/RocketMQ -> HDFS/Hive 。Kafka/ByteMQ/RocketMQ -> HDFS/Hive(下面均称之为 MQ dump,具体介绍可见> 字节跳动基于Flink的MQ-Hive实时数据集成> 在数仓建设第一层,对数据的准确性和实时性要求比较高。> > > > 
特惠活动
rocketmq高性能-优选内容
rocketmq高性能-相关内容
跨可用区部署 RocketMQ 实例
跨可用区部署可提高实例的可用性,本文档介绍跨可用区部署方式对于实例的影响。 注意事项创建跨可用区部署的 RocketMQ 实例前,应确认以下问题: 部署 RocketMQ 客户端的 ECS 和 RocketMQ 实例所在的可用区应尽量一致,避免故障域不对等的问题。 跨可用区部署的实例可能会出现 2ms~3ms 的网络延迟,确认单请求时延上升对业务是否有影响。 客户端使用同步方式调用接口的情况下,实例的吞吐性能可能会下降,需要考虑预留一定的性能空间、升...
计费项
本文介绍消息队列 RocketMQ版提供的计费项。 计费项消息队列 RocketMQ版的计费项包括计算规格费用和存储规格费用。 计费项 说明 计算规格 按支持的业务流量峰值提供不同性能的计算规格。计费类型为包年包月或按量计费。 存储规格 消息队列 RocketMQ版实例存储空间的费用。计费类型为包年包月或按量计费。 说明 关于计费类型的信息,详情请参见计费类型。 实例价格消息队列 RocketMQ版实例支持多种实例规格配置,按计算规格...
RocketMQ 客户端使用建议
本文档介绍 RocketMQ 客户端的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 日志配置RocketMQ 的日志一般是单独配置的,业务日志独立管理。日志默认保存在 ${user.home}/logs/rocketmqlogs 目录的 10 个文件中,每个文件大小为 1G,日志文件名为 rocketmq_client.log。有些业务的用户目录的磁盘空间不大,很容易造成磁盘空间不足。您可以通过设置系统变量的方式配置 ...
什么是消息队列 RocketMQ版
消息队列 RocketMQ版是火山引擎基于 Apache RocketMQ 构建的分布式消息中间件服务,完全兼容开源 RocketMQ 的各个组件与概念,同时具备低延迟、弹性高可靠、高吞吐等特性优势,业务代码无需改造,帮助用户快速迁移上云。 产品功能多种消费类型:消息队列 RocketMQ版提供灵活、可扩展性强的消费主题模式设置,支持发布/订阅、集群消费和广播消费模式。 多种消息类型:消息队列 RocketMQ版支持丰富的消息类型,支持顺序消息、事务消息、定...
CreateAccessKey
调用 CreateAccessKey 创建 RocketMQ 密钥。 注意事项请求频率:该接口请求频率限制为 10 次/秒;单用户请求频率限制为 2 次/秒。 使用说明火山引擎消息队列 RocketMQ版通过密钥管理 Topic 权限,密钥由 AccessKey ID 与对应的 AccessKey Secret 组成,用于访问实例、生产消费时的鉴权与身份认证。此接口用于创建密钥。 说明 所有 RocketMQ 实例默认开启 ACL 访问控制,无需手动开启或关闭。 创建密钥后,密钥默认为已启用状态。若不再...
RocketMQ 消费者使用建议
本文档介绍 RocketMQ 消费者的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 消费过程幂等RocketMQ 无法保证消息只被消费一次(Exactly-Once),即无法避免消息重复,主要由于以下原因: 消息发送失败时会重试 消费者批量消费,消费进度上报时回上报最小的 offset。 支持重置消费进度如果业务对消费重复非常敏感,务必要在业务层面进行去重处理,例如借助关系数据库进行去...
产品优势
消息类型丰富消息队列 RocketMQ版提供丰富的消息类型,支持顺序消息(全局顺序 / 分区顺序)、事务消息、定时消息、延时消息等多种消息类型,满足各类场景下的数据消费需求。 顺序消息:按照消息的发布顺序进行顺序消费(FIFO),支持全局顺序与分区顺序。 事务消息:实现系统间解耦的同时,保证数据的最终一致性。 定时/延时消息:消息可在指定的时间点或延迟时间进行投递。 消息免运维消息队列 RocketMQ版支持消息查询和回溯、消息重试与死...
步骤二:创建资源
本文将为您介绍消息队列 RocketMQ版控制台创建 RocketMQ 实例、Group 和 Topic 的操作步骤。 准备工作已开通消息队列 RocketMQ版,并进行了相关环境准备。创建的 RocketMQ 实例运行于私有网络中,在创建前确保已存在可用的私有网络和子网,详情请参见环境准备。 如果需要通过公网访问消息队列 RocketMQ版实例,请先申请同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作步骤请参考申请公网 IP。 1 创建实例说...
消息队列 RocketMQ版生成消息轨迹
前言 在本教程中,您将学习如何使用JAVA开源SDK在火山消息队列 RocketMQ版上生成消息轨迹。 关于实验 预计部署时间:30分钟级别:初级相关产品:消息队列 RocketMQ版 云服务器受众: 通用 环境说明 如果还没有火山引擎账... 配置文件MqConfig文件如下 undefined /** * * Licensed under the Apache License, Version 2.0 (the License ); * you may not use this file except in compliance with the License. * You may obtain a copy ...
