flushTxLogAtCommit=1 stat=true dataPath=/data1/metaq/data dataLogPath=/data1/metaq/log [zookeeper] zk.zkConnect...下都执行metaServer.sh start 需要停止时执行metaServer.sh stop 查看状态sh metaServer.sh status 5，应用例子 package com.test.metaq...MetaClientException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } package com.test.metaq...Auto-generated catch block e.printStackTrace(); } } } 打包test.jar后，传服务器上 java -cp test.jar com.test.metaq.Products...命令行输入message 打包test.jar后，传服务器上 java -cp test.jar com.test.metaq.AsyncConsum 命令行会接收到message
下载MetaQserver 1.4.6.2 下载链接：https://meta-queue.googlecode.com/files/metaq-server-1.4.6.2.tar.gz，下载metaq-server...Metaq的文件结构： l bin： metaq的命令文件夹....启动MetaQ集群 首先启动两个slave： 合肥和广州将目录切换到/usr/lib/metaq/bin下，使用slave模式启动MetaQ： ....可以添加一个topic而不重启MetaQ吗？...四．参考 MetaQ HA: https://github.com/killme2008/Metamorphosis/wiki/HA MetaQ源码分析：https://github.com/killme2008
3 metaq消息队列 2015年加入神州专车, 那个时候神州专车处于上升期。各个系统遇到了较大的瓶颈。metaq的故事很精彩,而且相关引申的知识点很多。...当时我们使用的metaq是庄晓丹在github开源的版本。2016年初，我checkout了metaq的源码，边理解业务，边深入理解metaq的机制。...3 一场zk奔溃引发的一连串的知识点 我们也都知道metaq依赖zookeeper。metaq在zk里要保存。突然有一天，专车整个zk集群down掉了。...metaq和服务治理共用一组zk集群合适吗？ 来公司后,阅读metaq源码后,我发现metaq消费者多的情况下,启动的时候，会频繁的争抢锁，另外消费的过程，也会对offset频繁的修改。...虽然,我并不完全知道神州架构团队为什么要去重构metaq，但可以从下面几点来说一下: metaq的网络通讯框架 metaq的通讯框架是庄晓周自研的。
--- MetaQ的作者庄晓丹 3.1 惊艳消费者模型 2015年，我主要从事神州专车订单研发工作。 MetaQ满足了我对于消息队列的幻想：“分布式，高吞吐，高堆积”。...为了减少MetaQ对zk集群的影响，我们的目标是：“MetaQ使用独立的zk集群”。 需要部署新的zk集群； MetaQ的zk数据需要同步到新的集群； 保证切换到新的集群，应用服务基本无感知。...MetaQ也有他的缺点。...MetaQ的基层通讯框架是gecko，MetaQ偶尔会出现rpc无响应，应用假死的情况，不太好定位问题； MetaQ的运维能力薄弱，只有简单的Dashboard界面，无法实现自动化主题申请，消息追踪等功能...4 钟情RocketMQ 4.1 开源的盛宴 2014年，我搜罗了很多的淘宝的消息队列的资料，我知道MetaQ的版本已经升级MetaQ 3.0，只是开源版本还没有放出来。
像在支付宝后面就使用了metaq，因为之前的中间件tbnotify在处理慢消费的情况下会很被动，而metaq在这块会有极大的优势，为什么，请听后面分解。...现今最新版本, kafka也是metaq的前身，最开始是linkedIn开源出来的日志消息系统 ),metaq基本上把kafka的原理和机制用java写了一遍,经过多次改造,支持事务，发展速度很快，并且在阿里和国内有很比较好的社区去做这块的维护...，这个是最初metaq的一个架构，最初metaq使用的是taobao内部的gecko和notify-remoting集成的一些高性能的NIO框架去分发消息: ?...目前来说基本上activemq,metaq都不能保证消息的幂等性，这就需要一些业务来保证了。...这点上activemq和metaq基本上机制一样： 生产者保证：生产数据后到broker后必须要持久化才能返回ACK broker保证：metaq服务器接收到消息后，通过定时刷新到硬盘上，然后这些数据都是通过同步
为了减少MetaQ对zk集群的影响，我们的目标是：“MetaQ使用独立的zk集群”。 需要部署新的zk集群； MetaQ的zk数据需要同步到新的集群； 保证切换到新的集群，应用服务基本无感知。...MetaQ也有他的缺点。...MetaQ的基层通讯框架是gecko，MetaQ偶尔会出现rpc无响应，应用假死的情况，不太好定位问题； MetaQ的运维能力薄弱，只有简单的Dashboard界面，无法实现自动化主题申请，消息追踪等功能...也许在看到他们重构MetaQ的那一刻，我的心里埋下了种子。...MetaQ 3.0，只是开源版本还没有放出来。
在2011年的时候，业界出现了现在被很多大数据领域所推崇的Kafka消息引擎，阿里在研究了Kafka的整体机制和架构设计之后，基于Kafka的设计使用Java进行了完全重写并推出了MetaQ 1.0版本...而在2012年，阿里对于MetaQ进行了架构重组升级，开发出了MetaQ 2.0，这时就发现MetaQ原本基于Kafka的架构在阿里巴巴如此庞大的体系下很难进行水平扩展，所以在2012年的时候就开发了RocketMQ...很多人会问到RocketMQ 3.0和MetaQ 3.0的区别，其实这两者是等价的版本，只不过阿里内部使用的称为MetaQ 3.0，外部开源称之为RocketMQ 3.0。...以上就是RocketMQ的整体发展历史，其实在阿里巴巴内部围绕着RocketMQ内核打造了三款产品，分别是MetaQ、Notify和Aliware MQ。...这三者分别采用了不同的模型，MetaQ主要使用了拉模型，解决了顺序消息和海量堆积问题；Notify主要使用了推模型，解决了事务消息；而云产品Aliware MQ则是提供了商业化的版本。如图： ?
支付宝的开源分布式消息中间件–Metamorphosis(MetaQ) Metamorphosis (MetaQ) 是一个高性能、高可用、可扩展的分布式消息中间件，类似于LinkedIn的Kafka，具有消息存储顺序写
RocketMQ作为一款分布式的消息中间件（阿里的说法是不遵循任何规范的，所以不能完全用JMS的那一套东西来看它），经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼，在功能和性能上远超ActiveMQ...在Metaq1.x/2.x的版本中，分布式协调采用的是Zookeeper，而RocketMQ自己实现了一个NameServer，更加轻量级，性能更好！
因为 MetaQ 集群和服务治理共用一组 zookeeper 集群 。...MetaQ 消费者负载均衡时，会频繁的争抢锁 ，同时也会频繁的提交 offset ； 专车的注册服务也越来越多，注册信息通过Hession 序列化存储在 zookeeper 的节点。...为了减少 zookeeper 集群的性能压力，架构团队将 MetaQ 使用的 zookeeper 集群独立出来。
在2011年的时候，业界出现了现在被很多大数据领域所推崇的Kafka消息引擎，阿里巴巴在研究了Kafka的整体机制和架构设计之后，基于Kafka的设计使用Java进行了完全重写并推出了MetaQ 1.0...在2012年，阿里巴巴对于MetaQ进行了架构重组升级，开发出了MetaQ 2.0，这时就发现MetaQ原本基于Kafka的架构在阿里巴巴如此庞大的体系下很难进行水平扩展，所以在2012年的时候就开发了...很多人会问到RocketMQ 3.0和MetaQ 3.0的区别，其实这两者是等价的版本，只不过阿里内部使用的称为MetaQ 3.0，外部开源称之为RocketMQ 3.0。...以上就是RocketMQ的整体发展历史，其实在阿里巴巴内部围绕着RocketMQ内核打造了三款产品，分别是MetaQ、Notify和Aliware MQ。...这三者分别采用了不同的模型，MetaQ主要使用了拉模型，解决了顺序消息和海量堆积问题；Notify主要使用了推模型，解决了事务消息；而云产品Aliware MQ则是提供了商业化的版本。
演进过程 在 RocketMQ 的早期版本其实不叫 RocketMQ，而是叫 MetaQ，在 MetaQ1.0 和 MetaQ2.0 实际上是依赖的是 Zookeeper，但是从 MetaQ3.0 的时候更名为
RocketMQ作为一款分布式的消息中间件（阿里的说法是不遵循任何规范的，所以不能完全用JMS的那一套东西来看它），经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼，在功能和性能上远超ActiveMQ...5.在Metaq1.x/2.x的版本中，分布式协调采用的是Zookeeper，而RocketMQ自己实现了一个NameServer，更加轻量级，性能更好！
metadata) { String property = context.getEnvironment().getProperty("ons.type"); return "metaq...{ MetaPushConsumer consumer = new MetaPushConsumer("consumerId"); log.info("create metaq
因为 MetaQ 集群和服务治理共用一组 zookeeper 集群 。...MetaQ 消费者负载均衡时，会频繁的争抢锁 ，同时也会频繁的提交 offset ；专车的注册服务也越来越多，注册信息通过Hession 序列化存储在 zookeeper 的节点。...为了减少 zookeeper 集群的性能压力，架构团队将 MetaQ 使用的 zookeeper 集群独立出来。
因此，在2011年，阿里巴巴决定以文件系统作为存储研发了MetaQ，以满足对顺序消息和海量消息堆积的需求。经过不断的探索和开发，MetaQ逐渐发展并成熟。...在2012年，阿里巴巴参考Kafka的设计，基于对MetaQ的理解和实际使用，研发了一套通用消息队列引擎，也就是RocketMQ。...MetaQ在双十一期间承载了万亿级消息的流转，展示了其强大的性能和稳定性。同时，阿里巴巴将RocketMQ捐献给Apache基金会，RocketMQ正式成为Apache的顶级项目。
常见的分布式消息中间件有ActiveMQ、RabbitMQ、Kafka、MetaQ等。...MetaQ具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性，适用于大吞吐量、顺序消息、广播和日志数据传输等场景。...由于篇幅优先，这里只介绍采用MetaQ消息队列解决方案，并省略了MetaQ相关配置仅给出了核心代码。...如果需要重新消费该消息，只需要在MetaQ管理平台上点击"消息验证"即可。...常见的交互协议有： MetaQ的消息通知； CORBA消息通知。 4.4.常见系统间交互方式 4.4.1.请求-应答 ?
之前说过rocketMq的历史，它的前身就是metaQ，metaQ来自哪里知道不老铁，其实就是借鉴了kafka，基本上metaQ的第一版就是超的kafka。...2010年底kafka开源后，阿里立刻行动通过java模仿了一版kafka名字叫metaQ。作者的名字killme2008，目前在蚂蚁金服。 ?
分布式协调服务zookeeper 日志glog 命令行参数gflag 嵌入式数据库SQLite3 嵌入式键值对数据库levelDB 分布式缓存memcached 消息中间件RabbitMQ、ActiveMQ、metaq
文章目录 RocketMQ 应用 RocketMQ 特性 实现 Binlog 分发 实现分布式一致性 RocketMQ 应用 RocketMQ 在阿里巴巴被大规模应用，其前身是淘宝的 MetaQ，后来改名为
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
