消息队列的异步处理(求代码)
我在做一个“基于消息队列的异步处理系统”的项目
在ubuntu平台下运用pythn编程,
想借鉴一下大家的代码,让我学习一下,另外提供些思路。
谢谢
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
我在做一个“基于消息队列的异步处理系统”的项目
在ubuntu平台下运用pythn编程,
想借鉴一下大家的代码,让我学习一下,另外提供些思路。
谢谢
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
接受
或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
发布评论
评论(4)
非常感谢大神,是一个很好的思路。 另外有相关类似的代码么,我想参考一下
另外怎么区分 多进程和异步处理的区别呢?
回复
拉取日志部分我之前有实现一个,你可以参考一下 https://github.com/hongliuliao/simple_flow, mq就很多了
给你一个思路, 比如一个社交系统,在增加好友后,会触发以下逻辑
(1) 为搜索提供索引数据
(2) 为推荐系统提供数据
(3) 为feed系统提供数据
(4) 为统计系统提供数据
怎么把数据给其他系统,同时又不会因为其他系统出问题而影响了加好友的流程?
(1) 在加好友成功之后,打印日志 add friends success for fid: 111, tid: 222
(2) 实时拉取日志内容发送到mq
(3) mq将消息广播到各个子系统