时间戳

首页 > 解决方案 > ruby 'async/io' 和 Reactor，帮助理解示例

ruby - ruby 'async/io' 和 Reactor，帮助理解示例

问题描述

我需要一些帮助来理解这里给出的基本“async/io”示例：

require 'async/io'

def echo_server(endpoint)
    Async::Reactor.run do |task|
        # This is a synchronous block within the current task:
        endpoint.accept do |client|
            # This is an asynchronous block within the current reactor:
            data = client.read(512)

            # This produces out-of-order responses.
            task.sleep(rand * 0.01)

            client.write(data.reverse)
        end
    end
end

def echo_client(endpoint, data)
    Async::Reactor.run do |task|
        endpoint.connect do |peer|
            result = peer.write(data)

            message = peer.read(512)

            puts "Sent #{data}, got response: #{message}"
        end
    end
end

Async::Reactor.run do
    endpoint = Async::IO::Endpoint.tcp('0.0.0.0', 9000)

    server = echo_server(endpoint)

    5.times.collect do |i|
        echo_client(endpoint, "Hello World #{i}")
    end.each(&:wait)

    server.stop
end

反应堆模式（如果错了请纠正）基本上是一种同步任务的调度程序，这样在阻塞时，一个任务被挂起，另一个任务被启动，依此类推，一旦任务被解除阻塞，任务就会恢复[来源]

在给定的 github 示例中，首先定义 echo_server 返回的方法Async::Task，并将其分配给服务器变量server

现在创建了变量，底层任务开始监听套接字并被client.read(512)调用阻塞。它被挂起，流到达循环部分，5 个客户端Async::Task一个一个地向套接字写入消息。

现在发生了一些我不明白的事情。服务器任务被解锁并回复第一条消息。之后它应该退出，因为没有循环。然而，它服务于所有五个请求并在此之后退出。显然有什么我错了，但我无法弄清楚。任何意见都受到高度赞赏。

标签： rubyasync-awaitreactortcpsocket

解决方案

echo_client在从循环中调用时执行 5 次。该函数调用endpoint.connect并发送单个消息并读取单个响应。

echo_server执行 1 次并调用endpoint.accept为每个连接生成块。服务器读取一条消息并将其写回。

服务器任务被解锁并回复第一条消息。之后它应该退出，因为没有循环。

endpoint.accept实现为循环：

        def accept(backlog = Socket::SOMAXCONN, &block)
            bind do |server|
                server.listen(backlog)

                server.accept_each(&block)
            end
        end

这里是实现server.accept_each：

        def accept_each(task: Task.current)
            task.annotate "accepting connections #{self.local_address.inspect}"

            while true
                self.accept(task: task) do |io, address|
                    yield io, address, task: task
                end
            end
        end

如您所见，它绑定到套接字，侦听传入连接，然后在循环中调用接受。

推荐阅读