我在使用 Python3/asyncio(Protocol) 编写的服务器应用程序时遇到了问题,但我很确定它与 python 或 asyncio 的关系不大,因为我尝试了不同的版本,还有一些 5liner 只是带有套接字接口(interface)。 它是关于与许多客户端硬件 TCP/IP<->RS232 转换器的并发通信。这就是使用 asyncio 而不是阻塞写入的线程的原因。
有一些周期性的短数据发送。当我物理地切断连接并等待异常发生时出现问题:
asyncio - Fatal read error on socket transport protocol
<_SelectorSocketTransport fd=11 read=polling write=<idle, bufsize=0>>
Traceback (most recent call last):
File "/usr/lib/python3.5/asyncio/selector_events.py", line 663, in
_read_ready
data = self._sock.recv(self.max_size)
OSError: [Errno 113] No route to host
它发生了,但是在 15 分钟 之后,这意味着我发出 15 分钟的信号,一切都很好,但事实并非如此,这是难以忍受的漫长和功能中断。 在不同硬件的 Ubuntu 16.04、Ubuntu 14.04 和 Debian Jessie 中检查了行为。
我发现(可能)内核正在缓冲数据,因为如果我在十分钟后重新连接设备,所有数据都会立即刷新。我知道这对短暂断开连接有好处,10 秒、15 秒甚至一分钟都没有问题,但 15 分钟太多了。
通过实现应用程序协议(protocol)回答了类似的问题,这在我的情况下是不可能的。
我只是想确保对方在某个合理的时间内收到数据包(TCP ack)。
我仔细阅读了有关 socket.setsockopt 的文档,但没有发现任何有用的信息。也没有找到方法如何检查发送缓冲区是否被刷新来做一些变通方法——手动检测断开的路由。
TCP keep-alive 也没有帮助,因为它基于不活动时间并且发送数据是事件的。
->最佳答案
您将看到 TCP 的重传超时 (RTO) 行为。
您的 TCP 永远不会收到任何反馈¹,因此它会非常努力地尝试让这些段通过。在 Linux 上,此行为受 net.ipv4.tcp_retries2 = 15 约束。 :
This value influences the timeout of an alive TCP connection, when RTO retransmissions remain unacknowledged. Given a value of N, a hypothetical TCP connection following exponential backoff with an initial RTO of TCP_RTO_MIN would retransmit N times before killing the connection at the (N+1)th RTO.
The default value of 15 yields a hypothetical timeout of 924.6 seconds and is a lower bound for the effective timeout. TCP will effectively time out at the first RTO which exceeds the hypothetical timeout.
这意味着您的 send 显然有效(即 TCP 最终同意发送您的数据)并且您等待 TCP 继续重试约 900 秒。
更改应用程序协议(protocol)是解决此问题的可靠方法,但由于您提到它对您不起作用,您的选择围绕着询问 TCP。
TCP_USER_TIMEOUT似乎完全按照您的意愿行事:
When the value is greater than 0, it specifies the maximum amount of time in milliseconds that transmitted data may remain unacknowledged before TCP will forcibly close the corresponding connection and return
ETIMEDOUTto the application.
有关 Application Control of TCP retransmission 的更多详细信息.
Also didn't find method how to check if send buffer was flushed to do some workarounds-manual detection of broken route.
上面链接的问题有 SIOCOUTQ - 检查输出队列中的数据量 - 作为您描述的解决方法。
¹例如,它可能会收到 TCP RST 或无法访问的 ICMP。
关于Python:TCP 中断路由的检测速度非常慢,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36936293/
关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。
Rails2.3可以选择随时使用RouteSet#add_configuration_file添加更多路由。是否可以在Rails3项目中做同样的事情? 最佳答案 在config/application.rb中:config.paths.config.routes在Rails3.2(也可能是Rails3.1)中,使用:config.paths["config/routes"] 关于ruby-on-rails-Rails3中的多个路由文件,我们在StackOverflow上找到一个类似的问题
我收到这个错误:RuntimeError(自动加载常量Apps时检测到循环依赖当我使用多线程时。下面是我的代码。为什么会这样?我尝试多线程的原因是因为我正在编写一个HTML抓取应用程序。对Nokogiri::HTML(open())的调用是一个同步阻塞调用,需要1秒才能返回,我有100,000多个页面要访问,所以我试图运行多个线程来解决这个问题。有更好的方法吗?classToolsController0)app.website=array.join(',')putsapp.websiteelseapp.website="NONE"endapp.saveapps=Apps.order("
我没有找到太多关于如何执行此操作的信息,尽管有很多关于如何使用像这样的redirect_to将参数传递给重定向的建议:action=>'something',:controller=>'something'在我的应用程序中,我在路由文件中有以下内容match'profile'=>'User#show'我的表演Action是这样的defshow@user=User.find(params[:user])@title=@user.first_nameend重定向发生在同一个用户Controller中,就像这样defregister@title="Registration"@user=Use
我真的为这个而疯狂。我一直在搜索答案并尝试我找到的所有内容,包括相关问题和stackoverflow上的答案,但仍然无法正常工作。我正在使用嵌套资源,但无法使表单正常工作。我总是遇到错误,例如没有路线匹配[PUT]"/galleries/1/photos"表格在这里:/galleries/1/photos/1/edit路线.rbresources:galleriesdoresources:photosendresources:galleriesresources:photos照片Controller.rbdefnew@gallery=Gallery.find(params[:galle
这个问题在这里已经有了答案:关闭10年前。PossibleDuplicate:Pythonconditionalassignmentoperator对于这样一个简单的问题表示歉意,但是谷歌搜索||=并不是很有帮助;)Python中是否有与Ruby和Perl中的||=语句等效的语句?例如:foo="hey"foo||="what"#assignfooifit'sundefined#fooisstill"hey"bar||="yeah"#baris"yeah"另外,类似这样的东西的通用术语是什么?条件分配是我的第一个猜测,但Wikipediapage跟我想的不太一样。
什么是ruby的rack或python的Java的wsgi?还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
华为OD机试题本篇题目:明明的随机数题目输入描述输出描述:示例1输入输出说明代码编写思路最近更新的博客华为od2023|什么是华为od,od薪资待遇,od机试题清单华为OD机试真题大全,用Python解华为机试题|机试宝典【华为OD机试】全流程解析+经验分享,题型分享,防作弊指南华为o
我想解析一个已经存在的.mid文件,改变它的乐器,例如从“acousticgrandpiano”到“violin”,然后将它保存回去或作为另一个.mid文件。根据我在文档中看到的内容,该乐器通过program_change或patch_change指令进行了更改,但我找不到任何在已经存在的MIDI文件中执行此操作的库.他们似乎都只支持从头开始创建的MIDI文件。 最佳答案 MIDIpackage会为您完成此操作,但具体方法取决于midi文件的原始内容。一个MIDI文件由一个或多个音轨组成,每个音轨是十六个channel中任何一个上的
本文主要介绍在使用Selenium进行自动化测试或者任务时,对于使用了iframe的页面,如何定位iframe中的元素文章目录场景描述解决方案具体代码场景描述当我们在使用Selenium进行自动化测试的时候,可能会遇到一些界面或者窗体是使用HTML的iframe标签进行承载的。对于iframe中的标签,如果直接查找是无法找到的,会抛出没有找到元素的异常。比如近在咫尺的例子就是,CSDN的登录窗体就是使用的iframe,大家可以尝试通过F12开发者模式查看到的tag_name,class_name,id或者xpath来定位中的页面元素,会抛出NoSuchElementException异常。解决