RocketMQ Apache - 腾讯云开发者社区

文章/答案/技术大牛

发布

Apache RocketMQ QuickStart

http://rocketmq.apache.org/docs/quick-start/ Quick Start This quick start guide is a detailed instruction...recommended; 64bit JDK 1.8+; Maven 3.2.x Git Clone & Build > git clone -b develop https://github.com/apache...> cd distribution/target/apache-rocketmq Start Name Server > nohup sh bin/mqnamesrv & > tail -f...use environment variable NAMESRV_ADDR > export NAMESRV_ADDR=localhost:9876 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer...> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer ConsumeMessageThread_%d Receive

8734 0

Apache RocketMQ组建了解

Name Server是RocketMQ的寻址服务。用于把Broker的路由信息做聚合。客户端依靠Name Server决定去获取对应topic的路由信息，从而决定对哪些Broker做连接。...Filter Server（可选）RocketMQ可以允许消费者上传一个Java类给Filter Server进行过滤。

5702 0

您找到你想要的搜索结果了吗？

是的

没有找到

Apache RocketMQ：简单消息示例

通过三种方式来发送RocketMQ消息使用: 可靠的同步发送, 可靠的异步发送和单向传输。这个页面举例说明了这三种消息发送方式. 根据示例找出最适合你的特定用例。...msg = new Message("TopicTest" /* Topic */, "TagA" /* Tag */, ("Hello RocketMQ...msg = new Message("TopicTest" /* Topic */, "TagA" /* Tag */, ("Hello RocketMQ...producer.shutdown(); } } 转自并发编程网 – ifeve.com 地址: 《Apache RocketMQ用户指南》之简单消息示例

4382 0

Apache RocketMQ 的基础特性介绍

Apache RocketMQ 的基础特性介绍 Apache RocketMQ 系列： Apache RocketMQ之JMS基本概念及使用：https://www.jianshu.com/p/d2e3fd77c4f4...Apache RocketMQ 基础概念及架构解析：https://www.jianshu.com/p/95ab928960b3 Apache RocketMQ 的基础特性介绍：https://www.jianshu.com.../p/570680b32590 Apache RocketMQ 集群搭建（两主两从）：https://www.jianshu.com/p/b090138cf52c Apache RocketMQ 刷盘策略与复制策略...源码Git地址：https://github.com/apache/rocketmq RocketMQ 模块划分：名称描述 broker broker模块：c和p端消息存储逻辑 client 客户端...端：消费模型： org.apache.rocketmq.common.protocol.heartbeat.MessageModel#BROADCASTING org.apache.rocketmq.common.protocol.heartbeat.MessageModel

1K1 0

给Apache RocketMQ提了个bug

超级开心给Apache RocketMQ提了个PR,采纳了 1.起因和疑问goutou 因公司需要，在rocketmq的官方文档上学下rocketmq,我在看官方提供的异步发送demo的时候有了个小疑问...，demo如下 rocketmq异步发送demo 关于CountDownLauch的原理可以看看我之前的文章CountDownLauch解析，其实就是一个带阻塞功能的计数器。...这里Apache RocketMQ又提供了一个coutdownlatch2，我看了代码，大致是为了设置一个等待时间又封装了下。...就把这事忘了好几天，今天竟然又收到了Apahe让提pr的邮件我才想起来，然后down了代码提了一个pr给Apache。...他们效率极高，提了pr当晚就给修复了，很感谢Apache RocketMQ团队的大佬们，让我感觉技术圈真的很open!

3514 0

如何从RocketMQ企业版迁移Apache RocketMQ (一)

近期很多客户在咨询如何从RocketMQ企业版迁移到标准的Apache RocketMQ。基于此，我做了一下的第一版的Java代码Demo，来尝试总结一些迁移的注意事项和两者在客户端的主要差别。...使用社区的客户端我们在项目里选择使用org.apache.rocketmq的客户端。当前比较新的版本是4.8.0，完全没有问题。... org.apache.rocketmq rocketmq-client Apache RocketMQ的每个consumer只能对应一个MessageListener。所以在使用下面的代码的时候你会发现MessageListener会被覆盖。...想要享受开源便利，又不希望自己运维的同学们可以开始试用了～下期预告: Apache RocketMQ 在RoP上如何做延迟消息和事物消息。

1.3K4 0

Apache RocketMQ 安装、测试、报错解决

clean install -U > cd distribution/target/apache-rocketmq 3.启动mqnamesrv 、mqbroker > nohup sh bin...启动消费者 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer ConsumeMessageThread_%d Receive...: No route info of this topic, TopicTest 解决方式：解决：org.apache.rocketmq.client.exception.MQClientException...解决方式：解决：Could not find or load main class org.apache.rocketmq.example.quickstart.Producer 参考官方文档：https...://rocketmq.apache.org/docs/quick-start/

1.3K2 0

Apache RocketMQ 基础概念及架构解析

Apache RocketMQ 基础概念及架构解析 Apache RocketMQ 系列： Apache RocketMQ之JMS基本概念及使用：https://www.jianshu.com/p/d2e3fd77c4f4...Apache RocketMQ 基础概念及架构解析：https://www.jianshu.com/p/95ab928960b3 Apache RocketMQ 的基础特性介绍：https://www.jianshu.com.../p/570680b32590 Apache RocketMQ 集群搭建（两主两从）：https://www.jianshu.com/p/b090138cf52c Apache RocketMQ 刷盘策略与复制策略...在2015年，又基于RocketMQ开发了阿里云上的Aliware MQ和Notify 3.0。在2016年的时候，阿里巴巴将RocketMQ的内核引擎捐赠给了Apache基金会。...---- 五、RocketMQ最佳实践总结 Apache RocketMQ 集群搭建（两主两从）:https://www.jianshu.com/p/b090138cf52c ---- 如有问题，请留言

8944 0

Apache RocketMQ Docker 容器化部署指南

镜像准备拉取ROCKETMQ镜像使用以下命令通过轩辕镜像加速地址拉取最新版本的ROCKETMQ镜像：展开代码语言：BashAI代码解释dockerpullxxx.xuanyuan.run/apache/...rocketmq:latest拉取完成后，可通过以下命令验证镜像是否成功下载：展开代码语言：BashAI代码解释dockerimages|grepapache/rocketmq若输出包含apache/rocketmq.../logs:/root/logs\-e"MAX_HEAP_SIZE=512m"\-e"HEAP_NEWSIZE=128m"\xxx.xuanyuan.run/apache/rocketmq:latest...=1024m"\-e"HEAP_NEWSIZE=256m"\xxx.xuanyuan.run/apache/rocketmq:latest\shmqbroker-c/opt/rocketmq/conf/...参考资源轩辕镜像文档（ROCKETMQ）https://xuanyuan.cloud/r/apache/rocketmqROCKETMQ镜像标签列表https://xuanyuan.cloud/r/apache

3011 0

Docker系列之Apache RocketMQ安装教程

Docker系列之Apache RocketMQ安装教程 64bit JDK 1.8 Docker version 1.13.1 1、查找安装rocketmq [root@localhost ~]# docker...for Apache RocketMQ 46 docker.io docker.io/foxiswho/rocketmq.../rocketmq-console-ng rocketmq-console-ng 33 ......选取start最多的rocketinc docker pull rocketmqinc/rocketmq 2、启动rocketmq mqnamesrv docker run -d -p 9876:9876...-v /root/rocketmq/data/namesrv/logs:/root/logs -v /root/rocketmq/data/namesrv/store:/root/store --name

1.3K3 0

Apache RocketMQ 5.0 腾讯云落地实践

Apache RocketMQ 发展历程回顾 RocketMQ 最早诞生于淘宝的在线电商交易场景，经过了历年双十一大促流量洪峰的打磨，2016年捐献给 Apache 社区，成为 Apache 社区的顶级项目...proxy module：https://github.com/apache/rocketmq/wiki/RIP-55-Support-remoting-protocol-in-rocketmq-proxy-module...更详细的实现方案详见RIP文档: [RIP57] Tieredstorage for RocketMQ：https://github.com/apache/rocketmq/wiki/RIP-57-Tiered-storage-for-RocketMQ...腾讯云 RocketMQ 的商业化历程腾讯云消息队列团队过去几年基于 Apache RocketMQ 社区走过了完整的商业化历程，在2023年9月正式推出了5.x 商业化版本，提供极致弹性和更低成本的...RocketMQ 社区更紧密配合，为 Apache RocketMQ 的繁荣发展做出贡献，为用户提供更优质的 RocketMQ 服务。

1.2K2 0

Apache Pulsar, RabbitMQ, RocketMQ机器消耗对比

Apache Pulsar, RabbitMQ, RocketMQ机器消耗对比完整搭建一个三节点的性能最优的集群，需要多少台机器 RabbitMQ ?...RocketMQ ?...RocketMQ-on-DLedger Group 是可以水平扩展的，也即可以部署任意多个 RocketMQ-on-DLedger Group 同时对外提供服务。...Apache Pulsar ? Pulsar 由 3 个主要组件组成：broker、Apache BookKeeper 和 Apache ZooKeeper。...备注：RabbitMQ和Apache Pulsar的三个节点都可以收发消息，而RocketMQ在主节点可以收发消息，从节点可以向Consumer发消息但是不能接收Producer的消息。

9871 0

Apache RocketMQ 刷盘策略与复制策略

Apache RocketMQ 刷盘策略与复制策略 Apache RocketMQ 系列： Apache RocketMQ之JMS基本概念及使用：https://www.jianshu.com/p/d2e3fd77c4f4...Apache RocketMQ 基础概念及架构解析：https://www.jianshu.com/p/95ab928960b3 Apache RocketMQ 的基础特性介绍：https://www.jianshu.com.../p/570680b32590 Apache RocketMQ 集群搭建（两主两从）：https://www.jianshu.com/p/b090138cf52c Apache RocketMQ 刷盘策略与复制策略...: https://www.jianshu.com/p/d66b381428bb ---- RocketMQ 的所有消息都是持久化的，先写入系统 PAGECACHE，然后刷盘，可以保证内存与磁盘都有一份数据

1.5K6 0

Apache RocketMQ 集群搭建（两主两从）

Apache RocketMQ 集群搭建（两主两从） Apache RocketMQ 系列： Apache RocketMQ之JMS基本概念及使用：https://www.jianshu.com/p/...d2e3fd77c4f4 Apache RocketMQ 基础概念及架构解析：https://www.jianshu.com/p/95ab928960b3 Apache RocketMQ 的基础特性介绍...：https://www.jianshu.com/p/570680b32590 Apache RocketMQ 集群搭建（两主两从）：https://www.jianshu.com/p/b090138cf52c...Apache RocketMQ 刷盘策略与复制策略: https://www.jianshu.com/p/d66b381428bb 优秀博客： https://www.jianshu.com/p/...---- 测试：可以启动RocketMQ的监控查看：监控源码下载地址： https://github.com/apache/rocketmq-externals.git 配置namesrv rocketmq.config.namesrvAddr

8.5K5 1

Apache RocketMQ 4.0.0 - linux安装与配置笔记

一、安装与配置 1、下载官网：http://rocketmq.apache.org/ 如：rocketmq-all-4.0.0-incubating-bin-release.zip 需要 64bit...=/opt/rocketmq/apache-rocketmq-all export PATH=$PATH::$ROCKETMQ_HOME/bin 输入:wq!.../apache-rocketmq-all/bin && nohup sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq/apache-rocketmq-all...export NAMESRV_ADDR=localhost:9876 sh /opt/rocketmq/apache-rocketmq-all/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer...测试消费者： sh /opt/rocketmq/apache-rocketmq-all/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

2.5K6 0

Apache RocketMQ原理(1)——服务端组件介绍

获取上云帮助文档：http://rocketmq.cloud/zh-cn/blog/tocloud-catalog.html 本期文章为Apache RocketMQ原理系列文章第一篇，主要介绍RocketMQ...服务端组件架构示例图 Name Server Name Server是RocketMQ的寻址服务。用于把Broker的路由信息做聚合。...Filter Server（可选） RocketMQ可以允许消费者上传一个Java类给Filter Server进行过滤。...本期关于RocketMQ服务端组件的介绍就到这里，接下来三期我们将分别介绍RocketMQ的核心概念及术语、水平扩展和负载均衡、消息ACK机制及消费进度管理相关的内容，敬请期待～作者介绍： Jaskey...Lam， Apache RocketMQ committer，知乎专栏RocketMQ详解作者，曾工作于Oracle，网易，微众银行，现任OPPO消费金融业务高级软件工程师；具备用户思维的程序员，王者荣耀单排王者选手

7481 0

Apache RocketMQ之JMS基本概念及使用

Apache RocketMQ之JMS基本概念及使用 Apache RocketMQ 系列： Apache RocketMQ之JMS基本概念及使用：https://www.jianshu.com/p/...d2e3fd77c4f4 Apache RocketMQ 基础概念及架构解析：https://www.jianshu.com/p/95ab928960b3 Apache RocketMQ 的基础特性介绍...：https://www.jianshu.com/p/570680b32590 Apache RocketMQ 集群搭建（两主两从）：https://www.jianshu.com/p/b090138cf52c...Apache RocketMQ 刷盘策略与复制策略: https://www.jianshu.com/p/d66b381428bb ---- 优秀博客： https://blog.csdn.net/...8.png ---- RocketMQ 是什么? 是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点。 RocketMQ是一个消息中间件，那什么是消息中间件？

2.8K1 0

Apache RocketMQ原理(1)——服务端组件介绍

7374 0

深度解析Apache RocketMQ：从核心原理到实战应用

Apache RocketMQ作为一款源自阿里、捐献给Apache基金会的开源消息中间件，凭借其金融级可靠性、丰富的功能特性及优秀的性能表现，已成为互联网、金融、电商等领域的主流选择。...一、RocketMQ简介：起源与定位 RocketMQ最初由阿里巴巴团队研发，用于解决内部复杂业务场景下的消息通信问题，历经双十一等高并发场景的长期打磨，于2016年正式捐献给Apache基金会，成为顶级开源项目...四、高级特性：RocketMQ的核心竞争力 RocketMQ的核心优势在于其丰富的高级特性，原生支持多种复杂业务场景，无需依赖第三方插件，且性能与可靠性兼顾，这也是其在金融、电商领域广泛应用的关键。...五、RocketMQ 5.0版本核心升级 RocketMQ 5.0作为里程碑式版本，围绕“云原生化、轻量化、场景拓宽”三大目标进行架构重构，核心升级点如下，同时保持对4.x版本的向下兼容，支持平滑升级。...九、总结 Apache RocketMQ凭借其金融级可靠性、丰富的高级特性、简洁的架构设计及云原生演进能力，已成为分布式系统中核心的消息中间件选择。

2711 0

腾讯宣布开源 RoP：Apache Pulsar 支持原生 RocketMQ 协议

作者 | 冉小龙，刘昱 RocketMQ 用户可以无缝迁移到 Apache Pulsar 了。自此，Apache Pulsar 补齐了兼容主流消息队列协议的能力。...Apache Pulsar 是下一代云原生分布式消息流平台，集消息、存储、轻量化函数式计算为一体。...Apache Pulsar 通过对 Consumer 层的抽象，提供了队列和流两种消费模型的统一抽象。...Apache Pulsar 在 PIP-41(https://github.com/apache/pulsar/wiki/PIP-41%3A-Pluggable-Protocol-Handler) 中介绍了一种全新的接入方式...Apache Pulsar 的存储层使用了 Apache BookKeeper，Pulsar 相当于 BookKeeper 的 Client，通过调用 ManagerLedger 对象能够很容易的达到为分布式日志操作的目的

1.1K2 1

点击加载更多

Apache RocketMQ QuickStart

Apache RocketMQ组建了解

Apache RocketMQ：简单消息示例

Apache RocketMQ 的基础特性介绍

给Apache RocketMQ提了个bug

如何从RocketMQ企业版迁移Apache RocketMQ (一)

Apache RocketMQ 安装、测试、报错解决

Apache RocketMQ 基础概念及架构解析

Apache RocketMQ Docker 容器化部署指南

Docker系列之Apache RocketMQ安装教程

Apache RocketMQ 5.0 腾讯云落地实践

Apache Pulsar, RabbitMQ, RocketMQ机器消耗对比

Apache RocketMQ 刷盘策略与复制策略

Apache RocketMQ 集群搭建（两主两从）

Apache RocketMQ 4.0.0 - linux安装与配置笔记

Apache RocketMQ原理(1)——服务端组件介绍

Apache RocketMQ之JMS基本概念及使用

Apache RocketMQ原理(1)——服务端组件介绍

深度解析Apache RocketMQ：从核心原理到实战应用

腾讯宣布开源 RoP：Apache Pulsar 支持原生 RocketMQ 协议

相关资讯

热门标签

活动推荐

运营活动

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐