我想使用clojure从队列连接和消费。我不知道这是最好的clojure api(风暴jms??)的任务。有人知道哪个api是最好的吗?也许你有一个例子,说明消费是如何在clojure完成的?我的最终目标是使用clojure宏defspout编写一个storm spout,并使用队列中的元组。任何帮助都将不胜感激!你好,贺拉斯
kyks70gy1#
补充nicolasmodrzyk:langohr是rabbitmq的一个非常好的clojureapi,它与storm集成得很好。
bbuxkriu2#
为了让您开始使用storm,github上为您准备了一个单词计数示例项目:https://github.com/denno-clojure/mascarpone/tree/master/chapter05_storm依赖项都在project.clj文件中,并且是开箱即用的。不过,为了确保这一点,storm正在进行处理,可以与外部排队系统集成。如果您只需要使用排队系统,请查看以下一些示例:使用activemq的clojureredis发布者和redis订户
2条答案
按热度按时间kyks70gy1#
补充nicolasmodrzyk:langohr是rabbitmq的一个非常好的clojureapi,它与storm集成得很好。
bbuxkriu2#
为了让您开始使用storm,github上为您准备了一个单词计数示例项目:
https://github.com/denno-clojure/mascarpone/tree/master/chapter05_storm
依赖项都在project.clj文件中,并且是开箱即用的。
不过,为了确保这一点,storm正在进行处理,可以与外部排队系统集成。如果您只需要使用排队系统,请查看以下一些示例:
使用activemq的clojure
redis发布者和redis订户