目前想实现一个webserver,能够异步处理消息的,收到消息立刻返回,降低延迟,内部维护一个消息队列,然后用celery或者其他方式异步处理消息队列,实现低延迟 高吞吐,请问,celery可以使用一个内部维护的消息队列吗?比如自己在程序里封装的,而不是redis或者rq这种,因为服务可以接受消息丢失。
或者说,这个时候用线程池可行吗,有什么不妥的地方吗
目前想实现一个webserver,能够异步处理消息的,收到消息立刻返回,降低延迟,内部维护一个消息队列,然后用celery或者其他方式异步处理消息队列,实现低延迟 高吞吐,请问,celery可以使用一个内部维护的消息队列吗?比如自己在程序里封装的,而不是redis或者rq这种,因为服务可以接受消息丢失。
或者说,这个时候用线程池可行吗,有什么不妥的地方吗
2 回答5.1k 阅读✓ 已解决
2 回答1.1k 阅读✓ 已解决
4 回答1.4k 阅读✓ 已解决
3 回答1.3k 阅读✓ 已解决
3 回答1.2k 阅读✓ 已解决
1 回答1.7k 阅读✓ 已解决
1 回答1.2k 阅读✓ 已解决
如果消息并发不高,且处理消息用时不太长,直接用
gevent
可能更合适点