草庐IT

scala-tools

全部标签

scala - 使用 OFormat 序列化案例类时从 Play 应用程序收到警告

我有一个函数,我在其中使用play-jsonOFormat来序列化用于api响应的案例类,现在我注意到一些警告出现在play应用程序的日志中,如下所示:zation(akka://application)(77)-UsingthedefaultJavaserializerforclass[model.ValidationResponse]whichisnotrecommendedbecauseofperformanceimplications.Useanotherserializerordisablethiswarningusingthesetting'akka.actor.warn-

scala - 游戏中的 Redis 发布订阅

我正在尝试在我的play应用程序中安装一个redis客户端,它将订阅来自redis的更新。网上的资料不多,仅供引用:https://github.com/pvillega/play21-redis-pubsub/blob/master/app/controllers/Application.scala据我所知,用scala比用java更容易完成这个,但我没有scala技能,所以我试图理解事情..我想要的是一个单例对象,通过它我将能够从整个应用程序发布和获取更新(使用订阅者)。这是我想出的:objectRedisextendsActor{valchannel="myChannel"val

scala - 游戏中的 Redis 发布订阅

我正在尝试在我的play应用程序中安装一个redis客户端,它将订阅来自redis的更新。网上的资料不多,仅供引用:https://github.com/pvillega/play21-redis-pubsub/blob/master/app/controllers/Application.scala据我所知,用scala比用java更容易完成这个,但我没有scala技能,所以我试图理解事情..我想要的是一个单例对象,通过它我将能够从整个应用程序发布和获取更新(使用订阅者)。这是我想出的:objectRedisextendsActor{valchannel="myChannel"val

scala - 将 SSE 与 Redis 发布/订阅和 Akka Streams 一起使用的最简单方法是什么?

我想为以下场景流式传输分block服务器发送的事件:订阅Redis键,如果键发生变化,使用AkkaStreams流式传输新值。它应该只在有新值时流式传输。据我了解,我需要一个Source。我猜这是对channel的订阅:redis.subscriber.subscribe("MyChannel"){casemessage@PubSubMessage.Message(channel,messageBytes)=>println(message.readAs[String]())casePubSubMessage.Subscribe(channel,subscribedChannelsCo

scala - 将 SSE 与 Redis 发布/订阅和 Akka Streams 一起使用的最简单方法是什么?

我想为以下场景流式传输分block服务器发送的事件:订阅Redis键,如果键发生变化,使用AkkaStreams流式传输新值。它应该只在有新值时流式传输。据我了解,我需要一个Source。我猜这是对channel的订阅:redis.subscriber.subscribe("MyChannel"){casemessage@PubSubMessage.Message(channel,messageBytes)=>println(message.readAs[String]())casePubSubMessage.Subscribe(channel,subscribedChannelsCo

scala - 使用 Redis 示例提升

我一直在分别使用Redis和Scala,并认为将它们结合到一个简单的Lift应用程序中会很巧妙。我进行了大量谷歌搜索,但找不到任何使用Redis的Lift应用示例。这是有原因的吗?您推荐使用带Lift的Redis的哪些驱动程序/API?我目前正在使用Jedis(https://github.com/xetorthio/jedis)。 最佳答案 我将scalatra与jedis一起用作redis的连接器,效果也很好。当导入scala.collection.JavaConversions._时(在scala2.8或更高版本中),Java

scala - 使用 Redis 示例提升

我一直在分别使用Redis和Scala,并认为将它们结合到一个简单的Lift应用程序中会很巧妙。我进行了大量谷歌搜索,但找不到任何使用Redis的Lift应用示例。这是有原因的吗?您推荐使用带Lift的Redis的哪些驱动程序/API?我目前正在使用Jedis(https://github.com/xetorthio/jedis)。 最佳答案 我将scalatra与jedis一起用作redis的连接器,效果也很好。当导入scala.collection.JavaConversions._时(在scala2.8或更高版本中),Java

scala - 关闭时如何替换nutcracker.yml中的master(twemproxy,redis)?

我正在使用twemproxy进行分片。在nutcracker.yml文件中,我已经放置了所有的大师。然后我做了这些主人的多个奴隶。我正在使用redis-sentinel来监控所有的主人。Redis-sentinel做得很好。当其中一个主人下线时,它的奴隶就会成为主人。由于twemproxy没有更新新主人,它正在ping到旧主人。还有什么方法可以更新nutcracker.yml文件中的master吗?我将Redis与ScalaPlayFramework一起使用。 最佳答案 redis-twemproxy-agent-https://g

scala - 关闭时如何替换nutcracker.yml中的master(twemproxy,redis)?

我正在使用twemproxy进行分片。在nutcracker.yml文件中,我已经放置了所有的大师。然后我做了这些主人的多个奴隶。我正在使用redis-sentinel来监控所有的主人。Redis-sentinel做得很好。当其中一个主人下线时,它的奴隶就会成为主人。由于twemproxy没有更新新主人,它正在ping到旧主人。还有什么方法可以更新nutcracker.yml文件中的master吗?我将Redis与ScalaPlayFramework一起使用。 最佳答案 redis-twemproxy-agent-https://g

java - 将java序列化对象反序列化为Scala类

我需要从Redis数据库中读取序列化对象(用Java完成)并将其转换为Scala中的案例类。序列化后的对象是这样的:��srmodels.mongo.Memberxrcom.mongodb.BasicDBObject¹Ʒ#��Z_isPartialObjectxrorg.bson.BasicBSONObject¹Ʒ#��xrjava.util.LinkedHashMap4�N\l��Z accessOrderxrjava.util.HashMap���`�FloadFactorIthresholdxp?@wt_idsrorg.bson.types.ObjectId¹Ʒ#��I_