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

我只是触摸芹菜和java 2天。 🙁

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

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

草案的想法是通过JSON序列化java函数然后由rabbitmq发送，然后由celery处理。

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

谢谢

Answer 1

您当然可以通过RabbitMQ从Java发送消息。 有一个Java客户端库可以与RabbitMQ连接 – 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

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