阅读更多

2顶
0踩

开源软件

    分布式消息中间件MetaQ发布1.4.4版本,完整更新日志如下(也可以点击链接查看):

 

1.  配置变更: 

  • 添加新选项stat,可设置全局是否开启实时统计,默认为false

  • 添加新选项updateConsumerOffsets,当消费者的offset不在Broker的数据范围内,是否强制更新消费者的offset为当前最大offset。默认为false。测试开发环境建议开启此选项,生产环境不建议。

  • 添加新选项loadMessageStoresInParallel,是否在启动的时候并行加载数据,提高启动速度,默认为false。

2.  协议变更: 

  • put协议添加checksum,服务端将根据checksum校验producer发送的消息数据是否完整。

  • sync协议新增checksum,类似put

  • stats协议新增reset和help命令,分别用于重设实时统计数据和打印帮助信息。

3.  易用和稳定性改进: 

  • 新增local模式启动服务器,它将启动一个内置的zookeeper服务器并启动metaq服务器,方便用户测试开发。生产环境仍然建议用单独的zookeeper集群。./metaServer.sh start local

  • 添加服务端启动时的配置参数校验,帮助检查配置错误。

  • metaServer.sh新增slave-status命令,用于查看异步复制状态。

  • 更优雅地关闭服务器,避免数据损坏。

  • 当服务器端列表变动的时候,尽量避免producer发送消息异常。

  • 当同步复制的slave服务端无法服务时,master服务器将尽快返回失败异常给producer。

  • 改进consumer的负载均衡实现,更快速和稳定地实现负载均衡。

  • 修复producer可能出现的连接内存泄漏。

4.  性能改进:

  • 改进group commit实现

5.  新功能,主要改进在Java客户端的API上: 

  • Java客户端新增RejectConsumptionHandler接口,当消费消息尝试多次失败后将调用此接口的rejectConsumption方法处理。

  • Java客户端MessageConsumer接口新增setRejectConsumptionHandler方法用于设置拒绝消费处理器。

  • Message对象新增readOnly属性,可设置消息是否只读。在PartitionSelector的getPartition方法中,消息将强制为只读。

  • MessageListener接口的recieveMessages方法可抛出InterruptedException的受控异常,响应中断。当中断发生时正在消费的消息将被回滚。

6.  其他: 

  • 升级gecko到1.1.2版本,修复并发bug。

7.  升级指南: 

  • 1.4.3版本的服务端和客户端,可直接升级到1.4.4,保持兼容;1.4.4之前版本的服务端和客户端,需首先升级服务端,等服务端完全升级完毕之后,才可开始升级客户端。

下载和文档

Java客户端升级

使用Maven很简单,也可以下载

 

<dependency>
    <groupId>com.taobao.metamorphosis</groupId>
    <artifactId>metamorphosis-client</artifactId>
    <version>1.4.4</version>
</dependency>

 

最后感谢很多朋友的帮助。

 

2
0
评论 共 10 条 请登录后发表评论
10 楼 bruce0508 2013-03-15 14:39
dennis_zane 写道
bruce0508 写道
你好,请教个问题,taobao的timetunnel是参考了kafka的设计理念,采用磁盘顺序读写的机制,请问在持续的大数据读写压力下,相比内存队列,这种机制下会不会频繁读写磁盘,导致磁盘寿命受到较大影响,我们担心磁盘成本会较高,你们是如何考虑这个问题的,有方面的测试数据吗?谢谢


淘宝的timetunel已经改用hbase解决存储问题了。
磁盘很贵吗?一个1T盘现在才多少钱。你一天能有多少消息?做个容量规划就知道。

不好意思,写错了,我要说的是metaq,看了metaq的机制,是有做缓冲的。
9 楼 dennis_zane 2013-03-14 10:52
transist 写道
请教用过的前辈们,稳定性如何呢?

新版1.4.4在delicious.com上跑了两周了,暂时没有发现问题。
8 楼 dennis_zane 2013-03-14 10:52
bruce0508 写道
你好,请教个问题,taobao的timetunnel是参考了kafka的设计理念,采用磁盘顺序读写的机制,请问在持续的大数据读写压力下,相比内存队列,这种机制下会不会频繁读写磁盘,导致磁盘寿命受到较大影响,我们担心磁盘成本会较高,你们是如何考虑这个问题的,有方面的测试数据吗?谢谢


淘宝的timetunel已经改用hbase解决存储问题了。
磁盘很贵吗?一个1T盘现在才多少钱。你一天能有多少消息?做个容量规划就知道。
7 楼 transist 2013-03-13 15:22
请教用过的前辈们,稳定性如何呢?
6 楼 bruce0508 2013-03-13 13:51
你好,请教个问题,taobao的timetunnel是参考了kafka的设计理念,采用磁盘顺序读写的机制,请问在持续的大数据读写压力下,相比内存队列,这种机制下会不会频繁读写磁盘,导致磁盘寿命受到较大影响,我们担心磁盘成本会较高,你们是如何考虑这个问题的,有方面的测试数据吗?谢谢
5 楼 icefishc 2013-03-11 22:30
icefishc 写道
dennis_zane 写道
icefishc 写道
你好,MetaQ的特点是什么呢? 是为了解决什么问题开发的它呢?

richard_2010 写道
请问这个和notify的区别是?


两位,关于这个消息中间件的背景可以看下这里的介绍性的文档:

https://github.com/killme2008/Metamorphosis/wiki

谢谢, 值得我学习:)
还有一个问题, 他用的哪个License。 淘蝌蚪那个页面似乎有问题, 源码和文档的链接都指向了taobao主页。
能不能透露下这个项目总共用了多长时间来开发呢。 谢谢~

licence。。。。
4 楼 icefishc 2013-03-11 22:30
dennis_zane 写道
icefishc 写道
你好,MetaQ的特点是什么呢? 是为了解决什么问题开发的它呢?

richard_2010 写道
请问这个和notify的区别是?


两位,关于这个消息中间件的背景可以看下这里的介绍性的文档:

https://github.com/killme2008/Metamorphosis/wiki

谢谢, 值得我学习:)
还有一个问题, 他用的哪个License。 淘蝌蚪那个页面似乎有问题, 源码和文档的链接都指向了taobao主页。
能不能透露下这个项目总共用了多长时间来开发呢。 谢谢~
3 楼 dennis_zane 2013-03-11 20:00
icefishc 写道
你好,MetaQ的特点是什么呢? 是为了解决什么问题开发的它呢?

richard_2010 写道
请问这个和notify的区别是?


两位,关于这个消息中间件的背景可以看下这里的介绍性的文档:

https://github.com/killme2008/Metamorphosis/wiki
2 楼 icefishc 2013-03-11 19:52
你好,MetaQ的特点是什么呢? 是为了解决什么问题开发的它呢?
1 楼 richard_2010 2013-03-11 09:49
请问这个和notify的区别是?

发表评论

您还没有登录,请您登录后再发表评论

相关推荐

  • 分布式消息中间件 MetaQ (庄晓丹)

    MetaQ(全称Metamorphosis)是一个高性能、高可用、可扩展的分布式消息中间件,思路起源于LinkedIn的Kafka,但并不是Kafka的一个Copy。MetaQ具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性,适用于大吞吐量...

  • 分布式消息中间件 MetaQ 作者庄晓丹专访

    分布式消息中间件 MetaQ 作者庄晓丹专访

  • Metamorphosis分布式消息中间件

    关于消息中间件,你应该听说过JMS(1)规范,以及一些开源实现,如ActiveMQ和HornetQ等。Metamorphosis也是其中之一。  Metamorphosis是一款完全的队列模型消息中间件,服务器使用Java语言编写,可在多种软硬件...

  • MetaQ消息中间件研究

    第一部分 MetaQ简介 ... MetaQ(全称Metamorphosis)是一个高性能、高可用、可扩展的分布式消息中间件,思路起源于LinkedIn的Kafka,但并不是Kafka的一个Copy。MetaQ具有消息存储顺序写、吞...

  • metaq

    MetaQ(全称Metamorphosis)是一个高性能、高可用、可扩展的分布式消息中间件,思路起源于LinkedIn的Kafka,但并不是Kafka的一个Copy。MetaQ具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性,适用于大吞吐量...

  • 消息队列系列

    一个具体的消息只能由一个消费者消费。多个生产者可以向同一个消息队列发送消息;...消息队列目前主要 2 种模式, 分别为"点对点模式"和"发布/订阅模式"。单个消息可以被多个订阅者并发的获取和处理。.........

  • MetaQ技术内幕——源码分析(转)

    笔者最近在业务上需要使用到...MetaQ(全称Metamorphosis)是一个高性能、高可用、可扩展的分布式消息中间件,,MetaQ具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性,适用于大吞吐量、顺序消息、广播和日志...

  • Kafka&MetaQ

    Memorphosis是一个消息中间件,它是linkedin开源MQ------kafka的Java版本,针对淘宝内部应用做了定制和优化。 Memorphosis做到了啥: 顺序(没做到,只能保证先进先出) 安全(部分如磁盘掉电会最多丢失1000条...

  • Kafka 消息队列 --1.JMS

    是一个 Java 平台中关于面向消息中间件的 API。用于在两个应用程序之间或 分布式系统中发送消息,进行异步通信。Java 消息服务是一个与具体平台无关的 API。    JMS 干什么用:用来异构系统...

  • 第11讲:深入理解指针(1).pdf

    第11讲:深入理解指针(1)

  • springboot整合 freemarker方法

    springboot整合 freemarker方法

  • 第14讲:深入理解指针(4).pdf

    第14讲:深入理解指针(4)

  • 同行者4.1.2语音助手

    《同行者4.1.2语音助手:车机版安装详解》 在现代科技日新月异的时代,智能车载设备已经成为了汽车生活的重要组成部分。"同行者4.1.2"便是这样一款专为车机设计的语音助手,旨在提供更为便捷、安全的驾驶体验。该版本针对掌讯全系列设备进行了兼容优化,让车主能够轻松实现语音控制,减少驾驶过程中的手动操作,提升行车安全性。 我们来了解下"同行者4.1.2"的核心功能。这款语音助手集成了智能语音识别技术,用户可以通过简单的语音指令完成导航、音乐播放、电话拨打等一系列操作,有效避免了因操作手机或车机带来的分心。此外,其强大的语义理解和自学习能力,使得它能逐步适应用户的口音和习惯,提供更个性化的服务。 在安装过程中,用户需要注意的是,"同行者4.1.2"包含了四个核心组件,分别是: 1. TXZCore.apk:这是同行者语音助手的基础框架,包含了语音识别和处理的核心算法,是整个应用运行的基础。 2. com.txznet.comm.base.BaseApplication.apk:这个文件可能包含了应用的公共模块和基础服务,为其他组件提供支持。 3. TXZsetting.apk:这

  • 市场拓展主管绩效考核表.xls

    市场拓展主管绩效考核表

  • “线上购车3D全方位体验:汽车模型展示与个性化定制功能”,three.js案例- 线上购车3d展示(源码) 包含内容:1.汽车模型展示;2.汽车肤;3.轮毂部件更;4.开关车门动画;5.汽车尺寸测量

    “线上购车3D全方位体验:汽车模型展示与个性化定制功能”,three.js案例- 线上购车3d展示(源码) 包含内容:1.汽车模型展示;2.汽车肤;3.轮毂部件更;4.开关车门动画;5.汽车尺寸测量;6.自动驾驶;7.镜面倒影;8.hdr运用;9.移动端适配; 本为html+css+three.js源码 ,核心关键词:three.js案例; 线上购车3D展示; 汽车模型展示; 汽车换肤; 轮毂部件更换; 开关车门动画; 汽车尺寸测量; 自动驾驶; 镜面倒影; HDR运用; 移动端适配; HTML+CSS+three.js源码。,"Three.js源码:线上购车3D展示案例,含汽车模型、换肤、轮毂更换等九大功能"

  • (数据权威)中国城市_县域统计面板数据二合一

    数据名称:2000-2022年各县市区主要社会经济发展指标面板数据 数据类型:dta格式 数据来源:中国县域统计

  • 120页-环卫车项目初步方案.pdf

    一、智慧环卫管理平台的建设背景与目标 智慧环卫管理平台的建设源于对环卫管理全面升级的需求。当前,城管局已拥有139辆配备车载GPS系统、摄像头和油耗传感器的环卫车辆,但环卫人员尚未配备智能移动终端,公厕也缺乏信息化系统和智能终端设备。为了提升环卫作业效率、实现精细化管理并节省开支,智慧环卫管理平台应运而生。该平台旨在通过信息化技术和软硬件设备,如车载智能终端和环卫手机App,实时了解环卫人员、车辆的工作状态、信息和历史记录,使环卫作业管理透明化、精细化。同时,平台还期望通过数据模型搭建和数据研读,实现更合理的环卫动态资源配置,为环卫工作的科学、健康、持续发展提供决策支持。 二、智慧环卫管理平台的建设内容与功能 智慧环卫管理平台的建设内容包括运行机制体制建设、业务流程设计、智慧公厕系统建设、网络建设、主机和储存平台需求、平台运维管理体系、硬件标准规范体系以及考核评价体系等多个方面。其中,智慧公厕系统建设尤为关键,它能实时监控公厕运行状态,保障公厕的清洁和正常运行。平台建设还充分利用了现有的电子政务网络资源,并考虑了有线和无线网络的需求。在功能上,平台通过普查、整合等手段全面收集环卫车辆、企业、人员、设施、设备等数据,建立智慧环卫基础数据库。利用智能传感、卫星定位等技术实现环卫作业的在线监管和远程监控,实现对道路、公共场所等的作业状况和卫生状况的全面监管。此外,平台还建立了环卫作业网格化管理责任机制,实现从作业过程到结果的全面监管,科学评价区域、部门、单位和人员的作业效果。 三、智慧环卫管理平台的效益与风险规避 智慧环卫管理平台的建设将带来显著的环境、经济和管理效益。环境方面,它将有力推进环境卫生监管服务工作,改善环境卫生状况,为人民群众创造更加清洁、卫生的工作和生活环境。经济方面,通过智慧化监管,大大降低了传统管理手段的成本,提高了监管的准确性和效率。管理方面,平台能够追踪溯源市民反映的问题,如公厕异味、渣土车辆抛洒等,并找到相应的责任单位进行处置,防止类似事件再次发生。同时,平台还拥有强大的预警机制功能,能够在很多环卫问题尚未出现前进行处置。然而,平台建设也面临一定的风险,如部门协调、配合问题,建设单位选择风险以及不可预测的自然灾害等。为了规避这些风险,需要加强领导、统一思想,选择优秀的系统集成商承接项目建设,并做好计算机和应用系统的培训工作。同时,也要注意标准制定工作和相关法律法规的制定工作,以保证系统建设完成后能够真正为环卫管理工作带来便利。

  • 36 -企业管理主管绩效考核表1.xlsx

    36 -企业管理主管绩效考核表1

  • 1.1 -1.4 工程代码

    1.1 -1.4 工程代码

  • USDT合约,USDT智能合约

    USDT合约,USDT智能合约

Global site tag (gtag.js) - Google Analytics