java - 我可以通过rabbitmq使用java发送任务到芹菜吗？

Question

我刚接触 celery 和 java 2 天。:(

现在，我有一个java客户端通过rabbitmq发送任务的任务。Celery 将是处理任务的工人。

我知道 Python->rabbitmq->celery 很容易。但是我可以通过 java->rabbitmq->celery 做到这一点吗？

草案思路是通过json序列化java函数，然后通过rabbitmq发送，再通过celery处理。

最好有示例代码，可以直接运行

谢谢

Answer 1

您当然可以从 Java 通过 RabbitMQ 发送消息。有一个用于与 RabbitMQ 交互的 Java 客户端库 - http://www.rabbitmq.com/api-guide.html

此页面描述了 Celery 消息格式 - http://docs.celeryproject.org/en/latest/internals/protocol.html。一种风格使用 JSON，并且有很多现有的 Java 库用于 JSON 读写；见http://json.org

最好有示例代码，可以直接运行

你是对的。

上面链接的页面包含代码片段，RabbitMQ Java 库有一些（小）示例。（至少，这就是页面所说的。）

Answer 2

最简单的形式是编写一个简单的 python 脚本，它只是向 celery 添加一个任务，然后从 java 调用这个 python 脚本（Runtime.exec() 或类似方法）。