jjzjj

php - ReactPHP 套接字服务器 : What triggers the write (to client)?

coder 2024-04-27 原文

当尝试写入客户端时，消息被缓冲，在某些情况下，它根本没有被写入。

当前状态:
当我远程登录到服务器时，Server Ready: 消息很容易按预期打印出来。

当我发送随机数据(“关闭”除外)时，服务器的终端每秒都很好地显示进度，但客户端输出等到所有 sleep 结束后，然后一次打印。

最重要的是，当发送“关闭”时，它只是等待强制性的一秒钟，然后在客户端没有任何写入的情况下关闭。

目标:
我的主要目标是在关闭连接之前向客户端写入一条快速消息。

代码:

// server.php
$loop = React\EventLoop\Factory::create();

$socket = new React\Socket\Server($loop);
$socket->on('connection', function ($conn)
{
    $conn->write("Server ready:\n");

    $conn->on('data', function ($data) use ($conn)
    {
        $data = trim($data);

        if( $data == 'close')
        {
            $conn->write("Bye\n");
            sleep(1);
            $conn->close();
        }

        for ($i = 1; $i<5; $i++) {
            $conn->write(". ");
            echo '. '; 
            sleep(1);
        }

        $conn->write(".\n");
        echo ".\n";

        $conn->write("You said \"".$data."\"\n");

    });
});
$socket->listen(1337, '127.0.0.1');
$loop->run();

总结:
为什么我无法在关闭前向客户写入任何内容？

最佳答案

您遇到的问题是因为您忘记了驱动 ReactPHP 的事件循环。我最近在构建服务器时遇到了这个问题，在遵循代码之后，我发现了 2 件事可以帮助您解决问题。

  1. 如果您在写入后关闭连接，它只会在写入之前关闭连接。解决这个问题可以帮助您解决下一个问题...向客户端写入内容然后关闭连接的正确调用称为 $conn->end('msg'); 如果您遵循这个代码链的行为变得清晰；首先它基本上写入连接就像你运行 $conn->write('msg'); 但随后它为 full-drain 注册一个新的事件处理程序事件，此处理程序简单调用 $conn->close();; full-drain 事件仅在写入缓冲区完全清空时才会调度。所以你可以看到end的使用，只是在关闭连接之前等待写入。

drain 和 full-drain 仅在写入流后分派(dispatch)。 full-drain 当写入缓冲区完全为空时发生。 drain 在写入缓冲区清空超过其 softLimit 后调度，默认情况下为 2048 字节。

  1. 您的写入没有通过的原因是因为 $conn->write('msg') 仅将字符串添加到写入缓冲区；它实际上并没有写。事件循环需要在有时间写入之前运行。您对 sleep() 的使用与 react 不正确，因为这会阻止该行的调用。在 React 中，您不想阻止任何代码的执行。如果你完成了一个任务，那么让你的函数返回，代码执行返回到 react 主事件循环。如果你希望让事情在特定的时间间隔运行，或者只是在循环的下一次迭代中运行，你可以使用 $loop->addTimer($seconds, $callback)<>, $loop->addPeriodicTimer($seconds, $callback), $loop->nextTick($callback) 或 $loop->futureTick( $回调)

归根结底，这是因为您在编程时没有意识到我们仍处于阻塞线程中。您的代码阻塞的任何内容，都会阻塞整个 React 事件循环，进而阻塞 React 为您所做的一切。放弃处理时间回到循环，以确保它可以执行您排队的读/写。您只需要循环迭代发生，写入缓冲区就会开始清空(取决于缓冲区的大小，它可能会也可能不会全部写出)

如果您的目标只是修复连接关闭位，请将调用切换到 $conn->end('msg') 而不是 write -> close。但是我相信你打印点的另一个循环也不会按照我认为你期望/希望它工作的方式运行。由于它的目的不那么明确，如果您能告诉我您的目标是什么，我也可以帮助您重组该步骤。

关于php - ReactPHP 套接字服务器 : What triggers the write (to client)?，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22669467/

套接字套接codeconnstrongphpsocketsreactphp

有关php - ReactPHP 套接字服务器 : What triggers the write (to client)?的更多相关文章

  1. ruby - 具有身份验证的私有(private) Ruby Gem 服务器 - 2

    我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时，它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器？这是不可能的吗？谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..

  2. ruby-on-rails - 启动 Rails 服务器时 ImageMagick 的警告 - 2

    最近，当我启动我的Rails服务器时，我收到了一长串警告。虽然它不影响我的应用程序，但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次？当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗？/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru

  3. ruby-on-rails - s3_direct_upload 在生产服务器中不工作 - 2

    在Rails4.0.2中，我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常，但在生产环境中它会抛出如下错误，ActionView::Template::Error(noimplicitconversionofnilintoString)在View中，create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo

  4. ruby-on-rails - 在 Rails 中调试生产服务器 - 2

    您如何在Rails中的实时服务器上进行有效调试，无论是在测试版/生产服务器上？我试过直接在服务器上修改文件，然后重启应用，但是修改好像没有生效，或者需要很长时间(缓存？)我也试过在本地做“脚本/服务器生产”，但是那很慢另一种选择是编码和部署，但效率很低。有人对他们如何有效地做到这一点有任何见解吗？ 最佳答案 我会回答你的问题，即使我不同意这种热修补服务器代码的方式:)首先，你真的确定你已经重启了服务器吗？您可以通过跟踪日志文件来检查它。您更改的代码显示的View可能会被缓存。缓存页面位于tmp/cache文件夹下。您可以尝试手动删除

  5. 网络编程套接字 - 2

    网络编程套接字网络编程基础知识理解源`IP`地址和目的`IP`地址理解源MAC地址和目的MAC地址认识端口号理解端口号和进程ID理解源端口号和目的端口号认识`TCP`协议认识`UDP`协议网络字节序socket编程接口`sockaddr``UDP`网络程序服务器端代码逻辑：需要用到的接口服务器端代码`udp`客户端代码逻辑`udp`客户端代码`TCP`网络程序服务器代码逻辑多个版本服务器单进程版本多进程版本多线程版本线程池版本服务器端代码客户端代码逻辑客户端代码TCP协议通讯流程TCP协议的客户端/服务器程序流程三次握手（建立连接）数据传输四次挥手（断开连接）TCP和UDP对比网络编程基础知识

  6. ruby - 是否可以在不实际发送或读取数据的情况下查明 ruby​​ 套接字是否处于 ESTABLISHED 或 CLOSE_WAIT 状态？ - 2

    s=Socket.new(Socket::AF_INET,Socket::SOCK_STREAM,0)s.connect(Socket.pack_sockaddr_in('port','hostname'))ssl=OpenSSL::SSL::SSLSocket.new(s,sslcert)ssl.connect从这里开始，如果ssl连接和底层套接字仍然是ESTABLISHED，或者它是否在默认值7200之后进入CLOSE_WAIT，我想检查一个线程几秒钟甚至更糟的是在实际上不需要.write()或.read()的情况下关闭。是用select()、IO.select()还是其他方法完成

  7. ruby - 我的 Ruby IRC 机器人没有连接到 IRC 服务器。我究竟做错了什么？ - 2

    require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器，我做错了什么？ 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame

  8. ruby-on-rails - Ruby 的 'open_uri' 是否在读取或失败后可靠地关闭套接字？ - 2

    一段时间以来，我一直在使用open_uri下拉ftp路径作为数据源，但突然发现我几乎连续不断地收到“530抱歉，允许的最大客户端数(95)已经连接。”我不确定我的代码是否有问题，或者是否是其他人在访问服务器，不幸的是，我无法真正确定谁有问题。本质上，我正在读取FTPURI:defself.read_uri(uri)beginuri=open(uri).readuri=="Error"?nil:urirescueOpenURI::HTTPErrornilendend我猜我需要在这里添加一些额外的错误处理代码...我想确保我采取一切预防措施来关闭所有连接，这样我的连接就不是问题所在，但是我

  9. ruby - Rails 开发服务器、PDFKit 和多线程 - 2

    我有一个使用PDFKit呈现网页的pdf版本的Rails应用程序。我使用Thin作为开发服务器。问题是当我处于开发模式时。当我使用“bundleexecrailss”启动我的服务器并尝试呈现任何PDF时，整个过程会陷入僵局，因为当您呈现PDF时，会向服务器请求一些额外的资源，如图像和css，看起来只有一个线程.如何配置Rails开发服务器以运行多个工作线程？非常感谢。 最佳答案 我找到的最简单的解决方案是unicorn.geminstallunicorn创建一个unicorn.conf:worker_processes3然后使用它:

  10. ruby - Faye WebSocket，关闭处理程序被触发后重新连接到套接字 - 2

    我有一个super简单的脚本，它几乎包含了FayeWebSocketGitHub页面上用于处理关闭连接的内容:ws=Faye::WebSocket::Client.new(url,nil,:headers=>headers)ws.on:opendo|event|p[:open]#sendpingcommand#sendtestcommand#ws.send({command:'test'}.to_json)endws.on:messagedo|event|#hereistheentrypointfordatacomingfromtheserver.pJSON.parse(event.d

随机推荐