草庐IT

c++ - 套接字发送调用被阻塞了这么久

coder 2023-09-18 原文

我每 10 秒在套接字上发送 2 个字节的应用程序数据(阻塞)，但发送调用在下面的最后一个实例中被阻塞了超过 40 秒。

  • 2012-06-13 12:02:46.653417|信息|发送前
  • 2012-06-13 12:02:46.653457|INFO|发送后 (2)
  • 2012-06-13 12:02:57.566898|信息|发送前
  • 2012-06-13 12:02:57.566962|INFO|发送后 (2)
  • 2012-06-13 12:03:08.234060|INFO|发送前
  • 2012-06-13 12:03:08.234101|INFO|发送后 (2)
  • **2012-06-13 12:03:19.010743|INFO|发送前
  • 2012-06-13 12:04:00.969162|INFO|发送后 (2)**

机器(linux)上的 tcp 默认发送缓冲区大小是 65536。

2 个字节的数据用于与服务器进行心跳，服务器希望客户端至少每 15 秒发送一次 HB。

此外，我没有禁用 naggle 的算法。

问题是 - send 调用是否可以像 40 秒那样长时间被阻塞？而且它只是偶尔发生，它发生在运行将近 12 小时后。

我知道的发送调用应该只是将数据复制到 TCP 发送缓冲区。

发布每 10 秒调用一次。不，它不会逐渐减慢发送调用的速度。它突然发生一次，然后由于另一侧的套接字关闭，所以应用程序退出。 

int publish(char* buff, int size) const {
      /* Adds the 0x0A to the end */
      buff[size]=_eolchar;

      if (_debugMode)
      {
          ACE_DEBUG((MY_INFO "before send\n"));
      }

      int ret = _socket.send((void*)buff, size+1);

      if (_debugMode)
      {
          ACE_DEBUG((MY_INFO "after send (%d)\n", ret));
          //std::cout << "after send " << ret << std::endl;
      }

      if (ret < 1)
      {
          ACE_DEBUG((MY_ERROR "Socket error, FH going down\n"));
          ACE_OS::sleep(1);
          abort();
      }
      return ret;
 }

最佳答案

当使用阻塞式send() 调用时，从您的应用程序的角度来看，您可以将远程TCP 缓冲区、网络和本地发送TCP 缓冲区视为一个大缓冲区。

也就是说，如果远程应用程序在从其 TCP 缓冲区读取新字节时出现延迟，最终您的本地 TCP 缓冲区将(几乎)变满。如果您尝试 send() 溢出 TCP 缓冲区的新负载，send() 实现(内核系统调用)将不会将焦点返回给您的应用程序直到 TCP 缓冲区获得足够的空间来存储该有效负载。

达到该状态的唯一方法是当远程应用程序没有读取足够的字节时。 测试 环境中的一个典型场景是远程应用程序在断点处暂停...:-)

这就是我们所说的SLOW CONSUMER 问题。如果您分享了该诊断结果，那么有多种方法可以解决该问题:

  1. 如果您可以控制远程应用程序，请使其足够快，这样本地应用程序就不会被阻止。
  2. 如果您没有远程应用程序的控制权，那么可能有多个答案:
    • 根据您自己的需要，最多可以阻止 40 秒。
    • 如果不是这样，您需要使用 send() 系统调用的非阻塞版本。从这里开始，有多种可能的政策；我在下面描述一个。 (请稍等!:-))

您可以尝试使用动态数组，它充当伪造的发送 TCP FIFO，并在发送调用返回给您 EWOULDBLOCK 时增长。在这种情况下，您可能必须使用 select() 系统调用来检测远程应用程序何时跟上步伐并首先向其发送看不见的数据。

这里的简单 publish() 函数可能有点棘手(虽然在大多数网络应用程序中很常见)。您还必须知道，无法保证动态缓冲区增长到您不再拥有任何可用内存的程度，然后您的本地应用程序可能会崩溃。 “实时”网络应用程序中的一个典型策略是为缓冲区选择一个任意的最大大小，当达到时关闭 TCP 连接，从而避免您的本地应用程序耗尽可用内存。明智地选择最大值，因为它取决于潜在的慢速消费者连接的数量。

关于c++ - 套接字发送调用被阻塞了这么久，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/11037867/

套接字套接codelisectionc++linuxsocketstcp

有关c++ - 套接字发送调用被阻塞了这么久的更多相关文章

  1. ruby-on-rails - 如何优雅地重启 thin + nginx？ - 2

    我的瘦服务器配置了nginx，我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例，但找不到好的解决方案。有没有人能做到这一点？ 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器，例如server{listen80;server

  2. 使用 ACL 调用 upload_file 时出现 Ruby S3 "Access Denied"错误 - 2

    我正在尝试编写一个将文件上传到AWS并公开该文件的Ruby脚本。我做了以下事情:s3=Aws::S3::Resource.new(credentials:Aws::Credentials.new(KEY,SECRET),region:'us-west-2')obj=s3.bucket('stg-db').object('key')obj.upload_file(filename)这似乎工作正常，除了该文件不是公开可用的，而且我无法获得它的公共(public)URL。但是当我登录到S3时，我可以正常查看我的文件。为了使其公开可用，我将最后一行更改为obj.upload_file(file

  3. c# - 如何在 ruby​​ 中调用 C# dll？ - 2

    如何在ruby​​中调用C#dll？ 最佳答案 我能想到几种可能性:为您的DLL编写(或找人编写)一个COM包装器，如果它还没有，则使用Ruby的WIN32OLE库来调用它；看看RubyCLR,其中一位作者是JohnLam，他继续在Microsoft从事IronRuby方面的工作。(估计不会再维护了，可能不支持.Net2.0以上的版本)；正如其他地方已经提到的，看看使用IronRuby，如果这是您的技术选择。有一个主题是here.请注意，最后一篇文章实际上来自JohnLam(看起来像是2009年3月)，他似乎很自在地断言RubyCL

  4. jquery - 我的 jquery AJAX POST 请求无需发送 Authenticity Token (Rails) - 2

    rails中是否有任何规定允许站点的所有AJAXPOST请求在没有authenticity_token的情况下通过？我有一个调用Controller方法的JqueryPOSTajax调用，但我没有在其中放置任何真实性代码，但调用成功。我的ApplicationController确实有'request_forgery_protection'并且我已经改变了config.action_controller.consider_all_requests_local在我的environments/development.rb中为false我还搜索了我的代码以确保我没有重载ajaxSend来发送

  5. java - 从 JRuby 调用 Java 类的问题 - 2

    我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java，并成功地将它与另一个Java包一起使用，但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www

  6. ruby - 调用其他方法的 TDD 方法的正确方法 - 2

    我需要一些关于TDD概念的帮助。假设我有以下代码defexecute(command)casecommandwhen"c"create_new_characterwhen"i"display_inventoryendenddefcreate_new_character#dostufftocreatenewcharacterenddefdisplay_inventory#dostufftodisplayinventoryend现在我不确定要为什么编写单元测试。如果我为execute方法编写单元测试，那不是几乎涵盖了我对create_new_character和display_invent

  7. ruby - 使用 Ruby 通过 Outlook 发送消息的最简单方法是什么？ - 2

    我的工作要求我为某些测试自动生成电子邮件。我一直在四处寻找，但未能找到可以快速实现的合理解决方案。它需要在outlook而不是其他邮件服务器中，因为我们有一些奇怪的身份验证规则，我们需要保存草稿而不是仅仅发送邮件的选项。显然win32ole可以做到这一点，但我找不到任何相当简单的例子。 最佳答案 假设存储了Outlook凭据并且您设置为自动登录到Outlook，WIN32OLE可以很好地完成此操作:require'win32ole'outlook=WIN32OLE.new('Outlook.Application')message=

  8. 【鸿蒙应用开发系列】- 获取系统设备信息以及版本API兼容调用方式 - 2

    在应用开发中，有时候我们需要获取系统的设备信息，用于数据上报和行为分析。那在鸿蒙系统中，我们应该怎么去获取设备的系统信息呢，比如说获取手机的系统版本号、手机的制造商、手机型号等数据。1、获取方式这里分为两种情况，一种是设备信息的获取，一种是系统信息的获取。1.1、获取设备信息获取设备信息，鸿蒙的SDK包为我们提供了DeviceInfo类，通过该类的一些静态方法，可以获取设备信息，DeviceInfo类的包路径为：ohos.system.DeviceInfo.具体的方法如下：ModifierandTypeMethodDescriptionstatic StringgetAbiList​()Obt

  9. ruby - 使用 `+=` 和 `send` 方法 - 2

    如何将send与+=一起使用？a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法，而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:

  10. 网络编程套接字 - 2

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

随机推荐