使用Vapor 3保持Socket的活力

Question

我在一个使用Vapor 3构建的应用程序中有一个web socket，我已经将其部署到Heroku。插座一直在关闭。如何使Vapor 3中的套接字保持活动状态？在Vapor 2中，我使用了以下代码行。我如何在Vapor 3中做同样的事情？

background {
    while ws.state == .open {
        try? ws.ping()
        self.console.wait(seconds: 10) // every 10 seconds
    }
}

Answer 1

以下是我使用的解决方案，它似乎在我的用例中运行良好。如果有更好的解决方案，请让我知道。

func runRepeatedTask() {
    _ = req.eventLoop.scheduleTask(in: .seconds(1)) { () -> Void in
        ws.send(Data())
        if socketOpen {
            runRepeatedTask()
        }
    }
}
runRepeatedTask()

我在ws.onText({ ws, string in的上面/下面的web套接字函数中包含了这个。我希望这能帮到你!