Play Framework 通过 rabbitmq 发送消息

【问题标题】：Play Framework send message via rabbit mqPlay Framework 通过 rabbitmq 发送消息
【发布时间】：2015-04-24 15:01:58
【问题描述】：

有人在 Play Framework 中使用 rabbitmq 吗？

我有一个使用 Play Framework 用 Scala 编写的 AI。我有一个平均堆栈，它处理一个 nosql 数据库。我想通过 rabbitmq 向那个 AI 发送 json 消息。

我已经搞定了 nodejs 和 rabbitmq，但现在我想连接玩，我可能需要你的帮助。

有没有过rabbitmq和play的经验或者一些实用的建议？

谢谢！

【问题讨论】：

你可以使用官方的 RabbitMQ Java 库，工作正常。

标签： scala rabbitmq playframework-2.2

【解决方案1】：

您可以像这样使用标准 Java 库向 RabbitMQ 发送消息：

val factory = new ConnectionFactory()
factory.setUri(serverUri)
val channel = connection.createChannel()
channel.queueDeclare(queue, true, false, false, null)
channel.basicPublish("", queue, true, false, null, data)

在 Play 中使用它时，您可能会将所有逻辑放到 basicPublish 自己的类和 inject that instance into your Controller 中，这样您就可以使用到 Rabbit 的持久连接。

由于您似乎所做的只是从请求中获取 json 并将其推送到 Rabbit，因此您甚至不必处理序列化，只需从 Request 获取文本正文并将其作为 @ basicPublish 的 987654325@ 有效负载（除非您想在传递输入之前对其进行验证）。

【讨论】：