我正试图找到从Scala实时通信到JavaScript的最佳解决方案。
到目前为止测试过的几个想法,但由于图书馆必须处理每秒约1000个请求,并不是每个解决方案都是最好的。
下面附上其中一种方法。 if (modulo == 0)
声明需要一些快速的库来将事件推送到前端。
您对vert.x
及其酒馆子库有何看法? https://github.com/vert-x/vertx-examples/tree/master/src/raw/scala/pubsub。
这个库可以处理每秒1000个请求吗?同样的问题与此https://github.com/vert-x/vertx-examples/tree/master/src/raw/scala/websockets 我正在尝试这个推消息库https://www.scaledrone.com/,但它在开始时失败(每秒只有10个请求)。
或者我可能期待很多,并且很容易通过简单的方式实现如此多的请求。我使用的是Redis,它有pub sub协议。所以也许有一些简单的方法可以在前端将数据从Redis推送到JavaScript?如何在JavaScript和Scala之间实现实时通信
private def checkQueue(r: RedisClient, numbers: List[Int]): Unit = {
val d1 = new Date()
val format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
val now = new Date()
for (nr <- numbers) {
val ranges = r.hkeys("user_" + nr + ":soldier:queue_time")
ranges match {
case Some(ss) => for (range <- ss) {
val added_time = r.hget("user_" + nr + ":soldier:queue_time", range)
val saved = format.parse(added_time.get)
val diff = (now.getTime - saved.getTime)/1000 // diff in sec
val interval = r.hget("user_" + nr + ":soldier:interval", range)
val modulo = diff % interval.get.toInt
if (modulo == 0) {
val queue_amount = r.hget("user_" + nr + ":soldier:queue_amount", range)
if (queue_amount.get.toInt >= 1) {
r.hincrby("user_" + nr + ":soldier:amount", range, 1)
r.hincrby("user_" + nr + ":soldier:queue_amount", range, -1)
}
}
}
case None =>
}
}
val d2 = new Date()
println("loop time: " + (d2.getTime - d1.getTime) + " milliseconds")
}