rocketmq异步消息
社区干货
RocketMQ 存储机制浅析
RocketMQ/Kafka/RabbitMQ 均采用的是消息刷盘至所部署虚拟机/物理机的文件系统做持久化。ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文... 后续由 OS 后台线程异步将 PageCache 数据刷入底层磁盘文件。消费消息时,采用随机读的方式,由于 PageCache 局部性热点原理且整体情况下还是从旧到新的有序读,大部分 Case 消息还能直接从 Page Cache 读,不会产生太...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 当然其他主流的开源消息项目也没有进行云原生架构转型,比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。
特惠活动
rocketmq异步消息-优选内容
rocketmq异步消息-相关内容
RocketMQ 生产者使用建议
消息重发就会导致相同的消息有不一样的 msgId。 日志打印建议在消息发送成功或者失败时打印消息日志,日志中应包含 SendResult 和 Key 字段。可根据实际情况来选择是否打印消息体,如果消息内容比较重要,在消息发送失败时推荐打印消息体。 说明 对于发送结果为 SEND_OK 的消息,可以不打印消息日志,以免造成日志过多,浪费存储资源。 消息发送模式目前消息队列 RocketMQ版提供了三种消息发送模式,说明如下: 说明 异步发送和单向发...
步骤三:生产消费普通消息
发送普通消息您可以通过以下方式发送普通消息: 在消息队列 RocketMQ版控制台的Topic管理页签中找到需要测试消息发送的 Topic,并在其对应的操作列单击发送消息。详细说明请参考在线调试。建议仅在业务调试阶段进行普通消息的发送测试。业务正常运行期间通过该方式发送消息可能会产生脏数据。 下载并安装 RocketMQ 客户端 Java SDK 后,运行以下示例代码,异步发送普通消息。 成功发送消息之后,如果可以通过消息查询功能检索到这条消...
RocketMQ 存储机制浅析
RocketMQ/Kafka/RabbitMQ 均采用的是消息刷盘至所部署虚拟机/物理机的文件系统做持久化。ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文... 后续由 OS 后台线程异步将 PageCache 数据刷入底层磁盘文件。消费消息时,采用随机读的方式,由于 PageCache 局部性热点原理且整体情况下还是从旧到新的有序读,大部分 Case 消息还能直接从 Page Cache 读,不会产生太...
消息队列 RocketMQ版-火山引擎
消息队列 RocketMQ版是一款基于 Apache RocketMQ 构建的分布式消息中间件服务,完全兼容开源 RocketMQ 客户端。消息队列 RocketMQ版具备低延迟、弹性高可靠、高吞吐等特性优势,支持顺序、延迟、定时、重投、死信消息等功能,完美适配电商大促等业务场景
步骤一:准备环境
消息队列 RocketMQ版是火山引擎基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。本文介绍使用消息队列 RocketMQ版进行消息收发之前,需要完成的准备工作。 1 准备账号开通服务之前,您需要注册一个火山引擎账号,并完成企业实名认证。对于计费类型为“按量计费”类型的 RocketMQ 实例,需要保证账户余额不低于 100 元才能正常创建和使用。 创建火山引擎账号。详细操作请参考注册账号。 完成企业认证。...
创建 Topic
本文介绍创建 Topic 的操作步骤。 背景信息在RocketMQ 实例中,Topic 是消息发送与接收的基本单元,消息队列 RocketMQ版通过 Topic 对各类消息进行分类管理。消息的生产者将消息发送到 RocketMQ Topic 中,而消息的消... 保留字符:RMQ_SYS_TRANS_OP_HALF_TOPIC、BenchmarkTest、TBW102、OFFSET_MOVED_EVENT、SELF_TEST_TOPIC、RMQ_SYS_TRANS_HALF_TOPIC、SCHEDULE_TOPIC_XXXX、RMQ_SYS_TRACE_TOPIC 特殊前缀:rocketmq-broker-、%RETRY...
使用前必读
消息队列 RocketMQ版是一款火山引擎提供的消息中间件服务。RocketMQ 基于高可用分布式集群技术,提供了高可靠、可扩展、灵活路由的托管消息队列,泛应用于秒杀、流控、系统解耦等场景。 调用说明消息队列 RocketMQ版提供了 OpenAPI,您可以通过发送 HTTPS 请求调用消息队列 RocketMQ版的 API。调用API时,您需要向火山引擎消息队列 RocketMQ版 API 的服务端地址发送 HTTPS 请求,并参考各个业务接口文档,在 HTTPS 请求中填入正确的请求...
为消息队列 RocketMQ 版集成 DNS 高可用插件
本文档介绍如何在火山引擎消息队列 RocketMQ 版的 Golang 客户端中集成 dns-stale-cache 插件。 前提条件您的 Golang 必须是 1.18 或更高版本。 您的 RocketMQ 客户端使用的 rocketmq-client-go SDK 必须是 v2 版本... ( "fmt" "os" "github.com/apache/rocketmq-client-go/v2/producer" . "github.com/volcengine/dns-stale-cache/common" . "github.com/volcengine/dns-stale-cache/rocketmq/v2")func NewMQ() { ...
定时消息和延时消息
消息队列 RocketMQ版提供 TCP 协议下的 RocketMQ 开源 Go SDK 的相关说明,本文档介绍收发定时消息和延时消息的示例代码。 背景信息如果发送消息到消息队列 RocketMQ版服务端后,不希望立即投递消息,可以使用定时或延时消息,根据消息中指定的属性延迟一定时间投递或指定时间点投递至消费端。其中,推迟到后续的某个指定时间再投递到消费端进行消费的消息为定时消息。推迟一定时间再投递到消费端进行消费的消息为延时消息,例如指定在...
