udp - 使用 Crystal/Kemal 监听 UDP 数据包

Question

我一直在尝试使用 Crystal 和 Kemal 创建一个非阻塞服务器，它将 (a) 监听发送给它的 UDP 消息流，然后 (b) 然后将该消息转发到 WebSocket 到任何已启动的浏览器ws 连接。

到目前为止，我能管理的最好的是:

require "kemal"
require "socket"

server = UDPSocket.new
server.bind "localhost", 1234
puts "Started..."

ws "/" do |socket|

    udp_working = true

    while udp_working
        message, client_addr = server.receive
        socket.send message
    end

    socket.on_close do
        puts "Goodbye..."
        udp_working = false
    end
end

这一切似乎有点不雅，而且确实没有按预期工作，因为:

在正在启动的 Crystal 服务器和连接到 Crystal 服务器的第一个 Web 浏览器之间发送的所有 UDP 数据包都被缓存并发送到一个巨大的积压中

浏览器从 WebSockets 断开连接没有得到正确处理，即 socket.on_close 没有被触发，循环继续直到我终止 Crystal 服务器

我希望有一个 server.on_message 类型的处理，它可以让我只在收到 UDP 数据包时运行代码，而不是阻止服务器的持续轮询。是否有另一种方法可以使用 Crystal/Kemal 实现这一目标？

谢谢!

Answer 1

你的方法有几个问题:

一、socket.on_close无法工作，因为这条线永远不会到达。只要 udp_working == true，while 循环就会运行它只会设置为 false在 on_close钩。

如果您不希望 UDP 数据报堆积，那么您需要从一开始就接收它们，并在没有连接 websocket 的情况下做任何您想做的事情(也许处理？)。没有on_message Hook UDPServer但是 receive已经是非阻塞的。所以你可以在一个循环中运行它(在它自己的光纤中)并在方法返回时采取行动。见 Crystal Concurrency详情；还有一个使用 TCPSocket 的例子，但 UDP 在这方面应该是类似的。