storm drpc中的java更新与请求回复

7bsow1i6  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(327)

我正在构建一个实时api来处理两种类型的调用:
更新,
计算请求。
在内部,更新在工人中广播。worker在ram中保持工作数据结构(如哈希表),并在更新到来时修改内容。
当一个计算请求到来时,正好有一个空闲的工作线程使用多个线程处理它,处理ram中的本地副本。
我想知道是否可以将当前的实现迁移到storm。据我所知,storm是相当实时的,可以在可伸缩性和容错性方面给我很大帮助。
目前,我正在使用uwsgi/python来处理api请求,并使用java工作者来进行计算。我正在考虑将java工作者作为螺栓放入storm拓扑中。然而,我不太确定的喷口。
据我所知,我可以使用drpc来处理计算请求,只需从python连接到drpc服务器。文档中清楚地写着drpc可以处理请求-应答范式的整个生命周期。但是更新呢?
我的问题是:使用drcp只以非阻塞方式提交更新,而不是等待回复(因为没有结果),这是一个好主意(或者甚至是可能的吗?)?

wooyq4lh

wooyq4lh1#

对于非阻塞的异步更新,应该使用像gearman这样的作业服务器
这将使您能够提交,无需等待任何响应。每当用户使用instagram应用程序上传照片时,instagram就会使用gearman将照片分享到facebook/twitter。

相关问题