Posts
Xmemcached和MetaQ发布新版本
<pre><code>String ns = "user-id"; this.memcachedClient.withNamespace(ns, new MemcachedClientCallable<Void>() {
public Void call(MemcachedClient client) throws MemcachedException, InterruptedException, TimeoutException { //username is in 'user-id' namespace. client.set("username", username); } }); //invalidate the namespace this.memcachedClient.invalidateNamespace(ns); <li> <p> 修复bug,包括setEnableHeartBeat方法无法正常工作,delete方法在连接kestrel最新版本的时候协议错误等。 </p> </li>
Posts
发布MetaQ 1.4.4
<li> <p> 添加新选项updateConsumerOffsets,当消费者的offset不在Broker的数据范围内,是否强制更新消费者的offset为当前最大offset。默认为false。测试开发环境建议开启此选项,生产环境不建议。 </p> </li> <li> <p> 添加新选项loadMessageStoresInParallel,是否在启动的时候并行加载数据,提高启动速度,默认为false。 </p> </li> <li> <p> sync协议新增checksum,类似put </p> </li> <li> <p> stats协议新增reset和help命令,分别用于重设实时统计数据和打印帮助信息。 </p> </li> <li> <p> 添加服务端启动时的配置参数校验,帮助检查配置错误。 </p> </li> <li> <p> metaServer.sh新增slave-status命令,用于查看异步复制状态。 </p> </li> <li> <p> 更优雅地关闭服务器,避免数据损坏。 </p> </li> <li> <p> 当服务器端列表变动的时候,尽量避免producer发送消息异常。 </p> </li> <li> <p> 当同步复制的slave服务端无法服务时,master服务器将尽快返回失败异常给producer。 </p> </li> <li> <p> 改进consumer的负载均衡实现,更快速和稳定地实现负载均衡。 </p> </li> <li> <p> 修复producer可能出现的连接内存泄漏。 </p> </li> <li> <p> Java客户端<code>MessageConsumer</code>接口新增<code>setRejectConsumptionHandler</code>方法用于设置拒绝消费处理器。 </p> </li> <li> <p> <code>Message</code>对象新增<code>readOnly</code>属性,可设置消息是否只读。在<code>PartitionSelector</code>的getPartition方法中,消息将强制为只读。 </p> </li> <li> <p> <code>MessageListener</code>接口的<code>recieveMessages</code>方法可抛出<code>InterruptedException</code>的受控异常,响应中断。当中断发生时正在消费的消息将被回滚。 </p> </li> <li> <p> 文档已经更新: <a href="https://github.