简单消息队列系统 ElasticMQ 0.3 发布,新 API,新内存存储
fmms 13年前
<p>ElasticMQ 0.3 发布了,ElasticMQ 是一个使用 Scala 编写的简单消息队列系统。当前使用嵌入式数据库 H2 来存储消息。ElasticMQ 实现了 SQS REST 接口的子集,提供一个 SQS 的可选方案。</p> <p>该版本包含两个主要改进:</p> <p>1. 基于内存的消息存储,显著提升性能</p> <p>使用方法:</p> <pre class="brush: scala; title: ; notranslate"> val node = NodeBuilder.withInMemoryStorage().build() val server = SQSRestServerFactory.start(node.nativeClient, 8888, "http://localhost:8888")</pre> <p>2. 主要 API 进行重写,更有面向对象的感觉:</p> <pre class="brush: scala; title: ; notranslate"> val node = NodeBuilder.withInMemoryStorage().build() val client = node.nativeClient val queue = client.createOrLookupQueue("queue1"); queue.sendMessage("msg1") queue.sendMessage(MessageBuilder("msg2").withNextDelivery(tomorrow)) queue.receiveMessage().map(message => { println(message.content) message.delete() })</pre> <p>详情请看 <a href="/misc/goto?guid=4958328444072585350">Client</a>, <a href="/misc/goto?guid=4958328444881137307">Queue</a>, <a href="/misc/goto?guid=4958328445672976226">QueueOperations</a>, <a href="/misc/goto?guid=4958328446476249468">Message</a> and <a href="/misc/goto?guid=4958328447271241285">MessageOperations</a></p>