簡單消息隊列系統 ElasticMQ

openkk 14年前發布 | 14K 次閱讀 消息隊列 Scala

ElasticMQ 是一個使用 Scala 編寫的簡單消息隊列系統。當前使用嵌入式數據庫 H2 來存儲消息。ElasticMQ 實現了 SQS REST 接口的子集,提供一個 SQS 的可選方案。ElasticMQ 使用 Squeryl 來訪問數據庫。

squeryl是一個ORM和DSL框架,可以通過它用最有效和最安全的方式和數據庫打交道,讓你從此告別訪問數據庫的煩惱和冗余代碼,寫SQL像寫Scala一樣簡單搞笑(高效)。

看看它的特性:

  • 能夠讓編譯器幫你檢查數據庫訪問的代碼。通過編譯的Squeryl代碼不會在運行時出錯。當編譯出錯的時候,能夠告訴你哪兒錯了。從此可以不用頭疼SQL的無厘頭報錯方式了。
  • 讓你像編寫SQL那樣編寫你的數據庫訪問,但是不用再和那些麻煩的底層API打交道了。
  • Squeryl語句的組合功能能夠讓你一次編寫到處使用,減少代碼的復雜度

示例代碼:

// First we need to create a Node
val node = NodeBuilder.createNode
// Then we can expose the native client using the SQS REST interface
val server = SQSRestServerFactory.start(node.nativeClient, 8888, "http://localhost:8888")
// ... use ...
// Finally we need to stop the server and the node
server.stop()
node.shutdown()
項目地址: https://github.com/adamw/elasticmq

 本文由用戶 openkk 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!