草庐IT

subscribedChannels

全部标签

scala - 发布/订阅中的 Redis 插件阻塞

我正在尝试使用TypesafeRedisPlayplugin连接到Redis以进行发布-订阅.我有以下测试场景,由一个每秒生成消息的actor组成://InitializationhappensinApplication.scala,privatelazyvalfakeStreamActor=Akka.system.actorOf(Props[FakeStreamActor])valactorPut=Akka.system.scheduler.schedule(Duration(1000,MILLISECONDS),Duration(1000,MILLISECONDS),fakeStr

scala - 发布/订阅中的 Redis 插件阻塞

我正在尝试使用TypesafeRedisPlayplugin连接到Redis以进行发布-订阅.我有以下测试场景,由一个每秒生成消息的actor组成://InitializationhappensinApplication.scala,privatelazyvalfakeStreamActor=Akka.system.actorOf(Props[FakeStreamActor])valactorPut=Akka.system.scheduler.schedule(Duration(1000,MILLISECONDS),Duration(1000,MILLISECONDS),fakeStr