分布式消息中间件MetaQ发布1.4.5版本。主要改进如下:
1.新功能:
- 新增
com.taobao.metamorphosis.consumer.ConsumerMessageFilter
接口,用于实现服务端和客户端的消息过滤,具体见Java客户端指南高级主题。消费者可以过滤消费特定的消息。 - Dashboard支持RESTFul API,用于查询Broker信息,具体见Dashboard API
- 新增
com.taobao.metamorphosis.client.consumer.MessageIdCache
接口,用于实现消费者的消息去重,防止重复消费,默认提供一个LRU的内存实现,具体见Java客户端指南高级主题。
2.配置变更:
- Topic配置,新增配置消费者的过滤器功能,类似
group.xxxGroup=com.test.MyConsumerMessageFilter
,用于配置特定消费分组的消息过滤器,具体见Java客户端指南高级主题。
3.功能改进和Bug修复:
- 修复Dashboard无法处理超过Integer.MAX_VALUE范围的offset的bug。
- 改进支持Storm的
MetaqSpout
,使用回滚替代异常来回滚消息。 - 将进程pid加入默认的consumer id。
- 改进LocalOffsetStorage的实现,感谢网友横云断岭的建议。
- 改进事务超时的异常提示。
- 修复bug,具体见milestone
4.API变更:
- 废弃
com.taobao.metamorphosis.client.consumer.MessageIterator
,推荐用com.taobao.metamorphosis.consumer.MessageIterator
类。
5.依赖类库升级,quartz升级到2.1.7,gecko升级到1.1.4,zkclient升级到0.3版本等。
下载地址:http://code.google.com/p/meta-queue/downloads/list
项目主页: https://github.com/killme2008/Metamorphosis
项目文档: https://github.com/killme2008/Metamorphosis/wiki
谢谢,欢迎反馈意见。
2 楼 qbibnmdb 2013-07-19 11:43
1 楼 paomo30000 2013-07-16 15:06