Play Framework 通过 rabbitmq 发送消息

Play Framework send message via rabbit mq

有人在 Play Framework 中使用 rabbitmq 吗?

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

我已经掌握了 nodejs 和 rabbitmq,但现在我想连接玩游戏,我可能需要你的帮助。

有没有人玩过rabbitmq和玩过或者有一些实用的建议?

谢谢!

您可以像这样使用标准 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 之前的所有逻辑放在它自己的 class 和 inject that instance into your Controller 中,这样您就可以使用持久连接来兔子.

因为你所做的一切似乎都是从请求中获取 json 并将其推送到 Rabbit,你甚至不必处理序列化,只需从 Request 并将其作为 basicPublishdata 有效载荷传递(除非您想在传递之前对输入执行验证)。