分布式消息中间件MetaQ发布1.4.5


P.S. 这是我个人从淘宝开源的MetaQ 1.x版本发展起来的github分支,与目前淘宝开源的MetaQ 2.0的发展方向不同。

分布式消息中间件MetaQ发布1.4.5版本。主要改进如下:

 1.新功能:

  • MetaQ终于有了一个Web管理平台,默认访问http://[host]:8120即可访问管理平台。使用管理平台可以查询本机和集群信息,查询Topic信息以及某个消费分组的消费信息,查询日志信息,重载配置文件等。P.S. 整个管理平台是使用Clojure语言编写的。
  • 大幅度改进XA事务实现(两阶段提交协议支持分布式事务),消除了原来无法运作在broker集群的限制。
  • 提供了全新的Spring框架支持API,简化Java客户端配置和编程,具体见Spring框架支持
  • 新增TopicBrowser API,用于遍历某个Topic下的所有消息。
  • 改动同步复制,在slave写入失败情况下将自动移除master,并且自动检测恢复。
  • 改进对Storm框架支持,升级spout支持storm 0.8 API。

2.API改进:

  • Message消息对象新增setRollbackOnly()方法,用于主动回滚消息。
  • ConsumerConfig消费者配置新增方法setConsumeFromMaxOffset(boolean always)用于设置是否每次consumer启动都从最新位置开始消费。
  • 新增分区选择器RandomPartitionSelector,用于随机发送消息。
  • 当消息发送失败,提供更详细的错误信息,包括服务器地址,分区号,topic等等。
  • XAMessageProducer新增setUniqueQualifier方法用于设置全局唯一标识符。
  • MessageSessionFactory新增方法createTopicBrowser用于创建TopicBrowser
  • Spring框架支持相关API。

3.配置和脚本变更

  • 服务端新增配置项dashboardHttpPort用于设置web管理平台的HTTP端口,默认是8120端口。
  • 同步复制Master配置新增三个选项:
    #发送到slave的消息超时时间,单位毫秒
    sendToSlaveTimeoutInMills=2000
    #发送到Slave消息连续失败次数阈值,超过这个数值将会自动把master从zookeeper移除并在后台做检测
    #当检测slave成功恢复,将自动注册master到zookeeper。
    slaveContinuousFailureThreshold=100
    #检测slave恢复的时间间隔,单位毫秒。
    checkSlaveIntervalInMills=100
  • Java客户端新增环境变量metaq.client.loopback.connection.enable,用于设置对于本机服务器,是否优先使用网络回路连接,节省带宽。默认不启用。
  • env.sh新增选项export enableHttp=false,用于设置服务端是否启用HTTP RESTFull接口。如果启用,用户可以通过HTTP方式发送或者消费消息。
  • 添加locaMetaServer.bat脚本,用于windows环境下启动内嵌zookeeper模式的MetaQ服务器。
  • 移除服务端diamond相关配置。

4.其他改进:

  • 提供了详细的Java客户端用户指南
  • 移除了一些不再需要的淘宝类库依赖。
  • 修复Javadoc乱码问题,新的文档看这个
  • 升级gecko到1.1.3版本,修复并发隐患。
  • 升级aviator到2.3.0版本。
  • 部分bug修复。
  • 改进分布式事务,改进spring框架支持例子。

5.升级指南:

  • 服务端和客户端都保持向前兼容。但是如果你是从1.4.3之前版本升级上来的,请先升级服务端,再升级客户端。
  • 服务端可无缝升级,如果你同一台机器跑了多个broker,需要明确配置每个broker的dashboardHttpPort,防止冲突。
  • 客户端也可以无缝升级,推荐使用Spring框架的朋友采用新API来简化编程。

Java客户端Maven引用:

  1. <dependency>  
  2.     <groupId>com.taobao.metamorphosis</groupId>  
  3.     <artifactId>metamorphosis-client</artifactId>  
  4.     <version>1.4.5</version>  
  5. </dependency>  

下载地址:http://code.google.com/p/meta-queue/downloads/list
项目主页: https://github.com/killme2008/Metamorphosis
项目文档: https://github.com/killme2008/Metamorphosis/wiki

  1. da shang
    donate-alipay
               donate-weixin weixinpay

发表评论↓↓