我只接触芹菜和java两天(
现在,我有一个任务,java客户端通过rabbitmq发送任务。芹菜将是处理这项任务的工人。
我知道Python->rabbitmq->芹菜很容易。但是我可以通过java->rabbitmq->celeni来做到这一点吗?
草案的想法是,通过JSON序列化java函数,然后通过rabbitmq发送,然后通过芹菜处理。
最好有示例代码,可以直接运行
感谢
您当然可以从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库有一些(小)示例。(至少页面上是这么说的。)
最简单的形式是编写一个简单的python脚本,只需将任务添加到芹菜中,然后从java(Runtime.exec()或类似方法)调用该python脚本。