草庐IT

websocket-client

全部标签

spring-boot - 组织.redisson.client.RedisNodeNotFoundException : Node: NodeSource hasn't been discovered yet

我是Redisson的新手,我试图在Redis缓存的帮助下为分布式锁集成redisson+springboot。我遇到以下错误:org.redisson.client.RedisNodeNotFoundException:Node:NodeSource[slot=14577,addr=redis://10.150.77.93:6381,redisClient=null,redirect=MOVED,entry=null]尚未被发现。在org.redisson.connection.MasterSlaveConnectionManager.createNodeNotFoundFuture

exception - 我想知道,为什么会得到redis.clients.jedis.exceptions.JedisConnectionException异常?

我在我的java项目中使用了jedis,一主一从,一旦从机启动,它在redis_slave.log中就会出现这样的情况:44764[2721]24Dec14:07:41.157*ConnectingtoMASTER...44765[2721]24Dec14:07:41.158*MASTERSLAVEsyncstarted44766[2721]24Dec14:07:41.158#ErrorconditiononsocketforSYNC:Connectionrefused而在我的java源文件中,我想删除redis中的所有数据,所以我写了这段代码:publicclassTestJedis

ruby-on-rails - Redis `CLIENT KILL TYPE pubsub` ruby 中的等效命令

我想知道是否有与RedisCLIENTKILLTYPEpubsub命令等效的ruby​​或hack方法。谢谢你的帮助 最佳答案 如果您正在谈论使用redisgem将Redis命令重写为ruby,您可以使用启动的Redis客户端上可用的call方法调用任何命令。所有参数都必须在数组中与命令名称一起传递,例如:#firstjustanexamplethatcallingcommandslikethisworks:Redis.new.client.call(["client","list"])#=>"addr=127.0.0.1:3796

javascript - 管理 Node Websockets topic-subscriber Map 的最佳方式是什么?

在服务于websockets的Node应用程序中,用户可以订阅多个已发布的主题并实时获取主题的新更新,存储主题-订阅者映射的最佳方式是什么?实时主题:主题1、主题2、主题3、主题4User1订阅了主题1、主题2、主题4。User2订阅了Topic2,Topic4。所以应该有一个map对象如下Topic1=>[User1]Topic2=>[User1,User2]Topic4=>[User1,User2]因此,当Topic1有更新时,应用程序应将更新传递给User1的websocket。问题:将主题-订阅者映射保留为应用程序变量(javascript对象)是否足够好?还是使用REDIS来

go - 关闭 redis 订阅并在 websocket 连接关闭时结束 go 例程

我正在将事件从redis订阅推送到通过websocket连接的客户端。当客户端断开websocket时,我无法取消订阅并退出redisgo例程。灵感来自thispost,这是我到目前为止所拥有的。我能够通过websocket接收订阅事件并向客户端发送消息,但是当客户端关闭websocket和deferclose(done)时代码触发,我的caseb,ok:=不开火。好像是被defaultcase重载了???packageapiimport(..."github.com/garyburd/redigo/redis""github.com/gorilla/websocket")funcws

mysql - 带 mysql 和 redis 的 Tornado websockets

我有一个Tornado服务器,它将与客户端建立网络套接字连接。每当客户端请求某些数据时,我需要从Redis或MySQL-DB获取它。除此之外,我需要收听来自Tornado服务器的广播,接收网络数据包并将它们发送给订阅了数据的客户端。向客户端发送广播数据包取决于数据包中的token。如果客户订阅了token,我们应该将数据包发送给他。请求率:5000个事件的网络套接字连接(可以增加)每秒每个套接字连接1-DB请求,因此总共5000个DB-请求/秒每秒每个套接字连接有1个Redis请求,因此总共有5000个Redis请求/秒。在广播中我应该监听1000个数据包/秒并检查是否有任何用户订阅了

django - 带有 Django channel 的 Websocket 不工作,连接失败

大家好!我用django-channels创建了一个聊天室。每次我尝试在生产环境中通过网络套接字连接到我的聊天室时,它都会失败。在本地它工作正常。我在digitalocean上托管点卡住:channels==2.1.2channels-redis==2.3.0daphne==2.2.1'''我已经安装了redis-serversudoapt-getinstallredis-server这是我的设置。INSTALLED_APPS=[#''''channels',#''']CHANNEL_LAYERS={'default':{'BACKEND':'channels_redis.core.R

java - 使用 Redis 运行 Storm 时出错 : java. lang.NoClassDefFoundError: Lredis/clients/jedis/Jedis

我的Storm类使用Redis队列来收集数据。我尝试运行我的Stormjarstormjarjar_file_name.jarTopology_nameconfiguration_file但是我遇到了以下异常:Exceptioninthread"main"java.lang.NoClassDefFoundError:Lredis/clients/jedis/Jedis;atjava.lang.Class.getDeclaredFields0(NativeMethod)atjava.lang.Class.privateGetDeclaredFields(Class.java:2397)a

ruby-on-rails - websocket-rails 在 Heroku 上启用同步失败

我正在使用Websocket-rails、sidekiq、redis、backbone。#config/initializers/websocket_rails.rbWebsocketRails.setupdo|config|config.standalone=falseconfig.synchronize=true#uri.host,:port=>uri.port||6379}end当我在本地主机上使用这个初始化程序时,它运行良好。当我将它推送到heroku时:$herokups===web(1X):`bundleexecrailsserver-p$PORT`web.1:crashe

redis.clients.jedis.exceptions.JedisConnectionException : Unexpected end of stream

我在尝试使用Jedis客户端向Redis服务器添加一些数据时出现以下错误:Unexpectedendofstream错误。发生这种情况的原因可能是什么?redis.clients.jedis.exceptions.JedisConnectionException:Unexpectedendofstream.[info]atredis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:198)[info]atredis.clients.util.RedisInputStream.readByte(RedisInp