最近总结下最近的一些开发经验，形成几个 clojure 的开源项目： clj.qrcode：二维码生成 https://github.com/killme2008/clj.qrgen 示例： (use 'clj.qrgen) (as-file (from "hello world")) (as-bytes (from "hello world")) (from (vcard "John Doe" :email "john.doe@example.org" :address "John Doe Street 1, 5678 Doestown" :title "Mister" :company "John Doe Inc." :phonenumber "1234" :website "www.example.org")) secure-rand：安全随机数生成器 https://github.com/killme2008/secure-rand 想要安全的随机数，还是要使用 java.security.SecureRandom 类 示例： (ns test (:refer-clojure :exclude [rand rand-int rand-nth]) (:use [secure-rand.core :only [rand rand-int rand-nth]])) (rand) (rand 10) (rand-int 100) (rand-nth (range 10)) (secure-rand.core/base64 32) clj.qiniu：七牛云存储 SDK https://github.

<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>

<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.