Can I use java send task to celery through rabbitmq?(我可以通过rabbitmq使用java发送任务到芹菜吗?)
问题描述
我刚接触 celery 和 java 2 天.:(
I just touch celery and java for 2 days. :(
现在,我有一个java客户端通过rabbitmq发送任务的任务.Celery 将是处理任务的工人.
Right now, I have a task that java client send task through rabbitmq. Celery will be the worker to handle task.
我知道 Python->rabbitmq->celery 很容易.但是我可以通过 java->rabbitmq->celery 做到这一点吗?
I know it's easy for Python->rabbitmq->celery. But can I do this by java->rabbitmq->celery ?
草稿思路是把java函数用json序列化,然后用rabbitmq发送,再用celery处理.
The draft idea is that serialization the java function by JSON and then send by rabbitmq, and then handle by celery.
最好有示例代码,可以直接运行
It's better to have example code and could be run directly
谢谢
推荐答案
你当然可以从 Java 中通过 RabbitMQ 发送消息.有一个用于与 RabbitMQ 交互的 Java 客户端库 - http://www.rabbitmq.com/api-guide.html
You can certainly send messages through RabbitMQ from Java. There is a Java client-side library for interfacing with RabbitMQ - http://www.rabbitmq.com/api-guide.html
本页描述了 Celery 消息格式 - http://docs.celeryproject.org/en/latest/internals/protocol.html.一种风格使用 JSON,并且有很多现有的 Java 库用于 JSON 读写;请参阅 http://json.org
This page describes the Celery message format - http://docs.celeryproject.org/en/latest/internals/protocol.html. One flavour uses JSON, and there are lots of existing Java libraries for reading and writing in JSON; see http://json.org
最好有示例代码,可以直接运行
It's better to have example code and could be run directly
你是对的.
上面链接的页面包含代码片段,RabbitMQ Java 库有一些(小)示例.(至少,页面上是这么说的.)
The page linked above includes code snippets, and the RabbitMQ Java library has some (small) examples. (At least, that's what the page says.)
这篇关于我可以通过rabbitmq使用java发送任务到芹菜吗?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本文标题为:我可以通过rabbitmq使用java发送任务到芹菜吗?


基础教程推荐
- 首次使用 Hadoop,MapReduce Job 不运行 Reduce Phase 2022-01-01
- 如何在不安装整个 WTP 包的情况下将 Tomcat 8 添加到 Eclipse Kepler 2022-01-01
- 如何使用 Eclipse 检查调试符号状态? 2022-01-01
- Java 中保存最后 N 个元素的大小受限队列 2022-01-01
- 如何使用 Stream 在集合中拆分奇数和偶数以及两者的总和 2022-01-01
- 如何强制对超级方法进行多态调用? 2022-01-01
- 如何对 HashSet 进行排序? 2022-01-01
- 由于对所需库 rt.jar 的限制,对类的访问限制? 2022-01-01
- 在螺旋中写一个字符串 2022-01-01
- Spring Boot Freemarker从2.2.0升级失败 2022-01-01