我有一个 redis 列表“waiting”和一个 redis 列表“partying”。
我有一个长时间运行的进程,可以安全地阻止“等待”列表项出现,然后弹出它并使用 BRPOPLPUSH 自动将其推送到“聚会”列表中.太棒了。
“waiting”列表中的用户反复查询“我在“partying”列表中了吗?”,但没有快速(即 < o(n))检查用户是否在="" redis="">
所以我求助于从 redis 列表切换到 redis 排序集,其中“分数”作为他们加入“等待”排序集时的 unix 时间戳。我可以阻止得分最低的流行音乐(队列头部的用户)。使用排序集,我可以使用 ZSCORE 来检查 O(1) 时间,如果它们在任一列表中,所以它看起来很有希望。
如何在排序集上执行 BRPOPLPUSH 的原子等价物?
就像我需要一个神话般的 BZRPOPMIN & ZADD= BZRPOPMINZADD。如果进程在这两个集合之间终止,则用户实际上将从两个集合中消失。
查看 MULTI EXEC transactions在 redis 中,它们并不是乍一看的样子,它们更像是“管道”,因为我无法获得第一个命令 (BZRPOPMIN) 的结果并提供给它进入第二个命令 (ZADD)。我非常怀疑将阻塞 BZRPOPMIN 也放入 MULTI 中,我这样做对吗?
最佳答案
How can I perform the nice atomic equivalent of BRPOPLPUSH on sorted sets?
对不起,你不能。我们实际上在添加 ZPOP 系列时讨论过这个问题并决定反对它:“但是我不支持 BZPOPZADD 部分,因为列表的经验表明这通常不是一个好主意,不幸的是,增加安全性消息处理可能使用其他方式。BZPOPZADD 和 BRPOPLPUSH 等最糟糕的事情是级联效应,它们在复制中造成很多问题,例如,我们的 BRPOPLPUSH 复制在某些方面仍然不正确(我们可以谈谈如果你愿意的话)。” (引用:https://github.com/antirez/redis/pull/4879#issuecomment-389116241)
I'm very suspicious of putting the blocking BZRPOPMIN into the MULTI too, am I right to be?
当然,阻塞命令无论如何都不能在事务中调用。
关于Redis 原子弹出并添加到有序集合,相当于 BRPOPLPUSH,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52023929/
当我使用Bundler时,是否需要在我的Gemfile中将其列为依赖项?毕竟,我的代码中有些地方需要它。例如,当我进行Bundler设置时:require"bundler/setup" 最佳答案 没有。您可以尝试,但首先您必须用鞋带将自己抬离地面。 关于ruby-我需要将Bundler本身添加到Gemfile中吗?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/4758609/
我的代码目前看起来像这样numbers=[1,2,3,4,5]defpop_threepop=[]3.times{pop有没有办法在一行中完成pop_three方法中的内容?我基本上想做类似numbers.slice(0,3)的事情,但要删除切片中的数组项。嗯...嗯,我想我刚刚意识到我可以试试slice! 最佳答案 是numbers.pop(3)或者numbers.shift(3)如果你想要另一边。 关于ruby-多次弹出/移动ruby数组,我们在StackOverflow上找到一
我有一个ModularSinatra应用程序,我正在尝试将Bootstrap添加到应用程序中。get'/bootstrap/application.css'doless:"bootstrap/bootstrap"end我在views/bootstrap中有所有less文件,包括bootstrap.less。我收到这个错误:Less::ParseErrorat/bootstrap/application.css'reset.less'wasn'tfound.Bootstrap.less的第一行是://CSSReset@import"reset.less";我尝试了所有不同的路径格式,但它
我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作),这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以
当谈到运行时自省(introspection)和动态代码生成时,我认为ruby没有任何竞争对手,可能除了一些lisp方言。前几天,我正在做一些代码练习来探索ruby的动态功能,我开始想知道如何向现有对象添加方法。以下是我能想到的3种方法:obj=Object.new#addamethoddirectlydefobj.new_method...end#addamethodindirectlywiththesingletonclassclass这只是冰山一角,因为我还没有探索instance_eval、module_eval和define_method的各种组合。是否有在线/离线资
我注意到类定义,如果我打开classMyClass,并在不覆盖的情况下添加一些东西我仍然得到了之前定义的原始方法。添加的新语句扩充了现有语句。但是对于方法定义,我仍然想要与类定义相同的行为,但是当我打开defmy_method时似乎,def中的现有语句和end被覆盖了,我需要重写一遍。那么有什么方法可以使方法定义的行为与定义相同,类似于super,但不一定是子类? 最佳答案 我想您正在寻找alias_method:classAalias_method:old_func,:funcdeffuncold_func#similartoca
我有带有Logo图像的公司模型has_attached_file:logo我用他们的Logo创建了许多公司。现在,我需要添加新样式has_attached_file:logo,:styles=>{:small=>"30x15>",:medium=>"155x85>"}我是否应该重新上传所有旧数据以重新生成新样式?我不这么认为……或者有什么rake任务可以重新生成样式吗? 最佳答案 参见Thumbnail-Generation.如果rake任务不适合你,你应该能够在控制台中使用一个片段来调用重新处理!关于相关公司
这个问题在这里已经有了答案:关闭10年前。PossibleDuplicate:Pythonconditionalassignmentoperator对于这样一个简单的问题表示歉意,但是谷歌搜索||=并不是很有帮助;)Python中是否有与Ruby和Perl中的||=语句等效的语句?例如:foo="hey"foo||="what"#assignfooifit'sundefined#fooisstill"hey"bar||="yeah"#baris"yeah"另外,类似这样的东西的通用术语是什么?条件分配是我的第一个猜测,但Wikipediapage跟我想的不太一样。
什么是ruby的rack或python的Java的wsgi?还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
我正在尝试使用Curbgem执行以下POST以解析云curl-XPOST\-H"X-Parse-Application-Id:PARSE_APP_ID"\-H"X-Parse-REST-API-Key:PARSE_API_KEY"\-H"Content-Type:image/jpeg"\--data-binary'@myPicture.jpg'\https://api.parse.com/1/files/pic.jpg用这个:curl=Curl::Easy.new("https://api.parse.com/1/files/lion.jpg")curl.multipart_form_