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

【问题标题】：Can I use java send task to celery through rabbitmq?我可以通过rabbitmq使用java发送任务到芹菜吗？
【发布时间】：2013-02-06 08:49:27
【问题描述】：

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

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

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

草稿思路是把java函数用json序列化，然后用rabbitmq发送，再用celery处理。

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

谢谢

【问题讨论】：

@Stephen C 我刚刚成功创建了一个用Java发送到Rabbitmq的任务，芹菜可以处理这个任务。但是代码非常难看，创建序列化字符串的代码很多，一点都不灵活。是否有一些jar包可以封装这些东西？可以让它像python一样工作，只需通过调用函数创建一个任务？

【解决方案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

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

你是对的。

上面链接的页面包含代码 sn-ps，RabbitMQ Java 库有一些（小）示例。（至少，页面上是这么说的。）

【讨论】：

【解决方案2】：

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

【讨论】：