草庐IT

欢迎订阅

全部标签

java - Jedis(Java Redis) 如何连接两个或多个订阅者?

我有两个订阅者,他们应该连接到不同的channel。但是,如果我尝试为他们订阅channel,则什么也不会发生。我认为这是一些多线程问题,但不知道如何解决这个问题。有没有关于如何与多个订阅者一起工作的示例? 最佳答案 如果不处于竞争状态,https://github.com/xetorthio/jedis/pull/998可以帮到你,预定下个版本发布。顺便说一句,如果您不需要动态订阅,或者您的channel具有相同的模式,则无需为每个channel创建订阅者。您可以使用Jedis.subscribe()和Jedis.psubscri

压力测试下的Redis hooking(发布-订阅)——负载下的性能

基于suggestedsolusion并关注example,我正在尝试在收到另一个key已过期的通知后立即删除一个key。问题是,在设置600K新key并将其中一半的过期时间设置为2秒的重负载压力测试下,我得到以下异常:Exceptioninthread"main"redis.clients.jedis.exceptions.JedisConnectionException:Unknownreply:t问题是编写这样的监听器的最佳实践是什么?(线程池?如果是在什么上下文中实现它?)绝地武士版本:2.7.2Redis版本:2.8.19到目前为止我的代码:订阅者类:publicclassS

redis - Redis订阅 channel 到底是什么?

因此,当我创建一个新的Jedis订阅实例并让我的Jedis实例订阅它时,我必须指定channel。它到底是什么?我假设它是一个字符串,它将成为其他一些系统的url[我有一个API平台,它应该收到重做状态更改的通知]。Jedis和Redis订阅页面都没有具体说明我对channel感到好奇的字符串类型。谢谢! 最佳答案 字符串可以是任何字符串,不一定只是URL。它用作Redischannel的名称-发布者和订阅者都用来“连接”到正确channel的唯一标识符-因此只要每个人都知道该名称,他们就可以使用该channel。

校园跑腿小程序还受欢迎不?

校园跑腿小程序是如今大学生群体中越来越受欢迎的一种服务模式。它为大学生提供了一个便捷的平台,使他们能够在校园内完成各类生活事务,如购买食品、快递取送、打印复印等。这种形式的服务在过去几年里在全球范围内迅速发展,并取得了巨大的成功。下面,我将从多个角度探讨校园跑腿小程序的受欢迎程度。首先,校园跑腿小程序受欢迎的原因之一是其极大的便利性。大学生通常在学业繁忙、时间紧张的情况下,很难抽出时间去完成一些琐碎但必要的事务。校园跑腿小程序为他们提供了一个方便快捷的解决方案,使他们能够通过手机应用轻松地委托他人代劳。无论是购买日常用品还是办理一些辅助性工作,用户只需要在手机上下单,然后等待服务人员将物品送到

ruby-on-rails - 用于发布和订阅事件的 Ruby 中 Redis SUB/PUB 的替代方案

我遇到的问题是,在使用heroku的免费附加组件时,我被限制为20个Redis连接。每个订阅事件都在使用一个连接,导致我的应用程序在使用有限的情况下达到最大。该应用程序是使用网络套接字的消息服务。我知道因为使用免费托管服务而进行重构似乎是一个糟糕的决定,但是,这是Redis唯一的用途。 最佳答案 尝试使用faye或em-websocket进行发布/订阅,然后如果需要,您可以使用redis或postgres进行持久化。http://faye.jcoglan.com/https://github.com/igrigorik/em-web

c# - 如何在 Servicestack.Redis 中使用 "New Managed Pub/Sub Server"取消订阅 channel

在NewManagedPub/SubServer他们的文档展示了如何在pubsubserver的初始化中订阅channel。但是,您如何在程序稍后需要时取消订阅特定channel?我的代码:usingServiceStack.Redis;usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Threading;namespaceva.communication{classProgram{staticvoidMain(string[]args){varclientsManager=newPoole

Python redis 订阅无法获取所有数据?

我正在使用python从redis获取数据,然后将其解析到kafka。它适用于大多数情况。但是当我用python模拟建数据到redis,或者queuen中有快速放入datas时,我无法获取到所有的数据。这是我关于redisproducer的代码,用于模拟构建20000个数据到redis:rc=redis.Redis(host='127.0.0.1',port=6379)rc.ping()ps=rc.pubsub()ps.subscribe('bdwaf')r_str="--8198b507-A--\n[22/Jun/2017:14:13:19+0800]ucTcxcMcicAcAcAc

python - 如何用一个线程监听redis的所有订阅 channel ?

我使用python3.6.3,动态构建channel。当客户端连接到webwsocket服务器时,redis_client构建。我有大约1000到100,0000个redis_clients,每个redis_client订阅一些channel。如何使用一个线程或IOLoop监听所有客户端消息?你能给我一个线程可以添加新的pubsub对象来收听更多channel的例子吗?是否有任何解决方案使用协程替换线程在这里等待并且可以将所有协程连接在一起(不能使用joinall因为一些监听器稍后会接近。)我使用的是redis-py库。 最佳答案

redis - Redis重启后如何重启Redis所做的所有订阅?

Redis服务器重启后,如何启动Redis实例运行的所有进程?在我的应用程序中,我可以看到已创建Redis实例,但Redis实例正在执行的所有订阅都没有重新启动。因此,应用程序无法从事件总线/Redis总线接收新消息。 最佳答案 您的应用程序需要捕获断开连接事件,一旦数据库重新联机,重新连接到它并重新订阅相关channel。 关于redis-Redis重启后如何重启Redis所做的所有订阅?,我们在StackOverflow上找到一个类似的问题: https:

redis - 多个订阅一个主题

我一直在使用pubsub进行一些异步工作,并且想知道为什么有人可能会为单个主题创建多个订阅。我的默认值如下:project_id='project'topic_name='app'subscription_name='general'实际功能的路由——以及如何处理它——在subscriber接收器本身中进行。为什么会出现各种订阅名称?唯一能想到的就是把item分散到多个服务器上处理,比如:server1--`main-1`server2--`main-2`etc.是否还有任何其他原因导致订阅名称不能很好地与一个值一起使用? 最佳答案