clojure&activemq&storm:使用clojure从队列消费

kmynzznz  于 2021-06-24  发布在  Storm
关注(0)|答案(2)|浏览(366)

我想使用clojure从队列连接和消费。我不知道这是最好的clojure api(风暴jms??)的任务。
有人知道哪个api是最好的吗?也许你有一个例子,说明消费是如何在clojure完成的?
我的最终目标是使用clojure宏defspout编写一个storm spout,并使用队列中的元组。
任何帮助都将不胜感激!
你好,贺拉斯

kyks70gy

kyks70gy1#

补充nicolasmodrzyk:langohr是rabbitmq的一个非常好的clojureapi,它与storm集成得很好。

bbuxkriu

bbuxkriu2#

为了让您开始使用storm,github上为您准备了一个单词计数示例项目:
https://github.com/denno-clojure/mascarpone/tree/master/chapter05_storm
依赖项都在project.clj文件中,并且是开箱即用的。
不过,为了确保这一点,storm正在进行处理,可以与外部排队系统集成。如果您只需要使用排队系统,请查看以下一些示例:
使用activemq的clojure
redis发布者和redis订户

相关问题