所以我正在为嵌入式设备开发一个 Web 应用程序,它使用 QNetworkAccessManager 从 Web 服务器检索信息。每个请求都是一个 GET 请求,调用一个 PHP 页面,在 url 中带有一些参数。 PHP 脚本的输出是我的应用请求的信息。
整个过程非常简单,可以简化为以下几行代码:
void fetch() {
Q_ASSERT(m_reply == 0);
QUrl url = QUrl("http://subdomain.myserver.com/info.php?param1=1¶m2=2");
m_reply = m_qnam->get(url);
connect (m_reply, SIGNAL(readyRead()), this, SLOT(onReadyRead()));
connect (m_reply, SIGNAL(finished()), this, SLOT(onFinished()));
}
void onReadyRead() {
m_contents.append(m_reply->readAll());
}
void onFinished() {
m_reply->deleteLater();
m_reply = 0;
// do something with the contents
m_contents.clear();
// fetch again
fetch();
}
m_qnam 是一个 QNetworkAccessManager 实例,m_contents 是一个 QByteArray。
这很好用,但是当我尝试数百个这样的请求时遇到问题,我最终从服务器 (Apache) 收到 429 错误(来自同一 IP 的连接过多)。要从中恢复,我必须断开与互联网的连接并重新连接(这会给我一个新的 IP 地址)。
我可以增加 Apache 上的最大连接数,但是我认为一旦删除 QNetworkReply 就应该关闭 TCP 连接,但事实似乎并非如此。由于我一次只下载固定数量的请求(这由我的应用程序上的排队系统控制,QNetworkAccessManager 也有同时下载的最大数量),我不认为调整 Apache 是答案。
看来TCP连接没有正常关闭。
所以我的问题是:
如何确保在下载完成后正确关闭与我的服务器的每个连接。 QNetworkAccessManager 应该处理这个吗?这是一个错误吗?我是否应该与服务器建立自己的自定义 TCP 连接并在整个应用程序期间保持一定数量的连接?如果是这样,我应该从哪里开始?
谢谢,我们将不胜感激。
Qt 5.3/OSX/iOS
注意:修改我的问题以符合 Pavel 的评论。一次只有一个请求处于事件状态。
最佳答案
回答我自己的问题:QNetworkAccessManager 会在删除 QNetworkReply 或调用 abort() 或 close() 方法后正确关闭所有连接。当然,这是以异步方式发生的。
我收到的错误来自对我的服务器施加的一些限制,这些限制只允许来自每个 IP 的一定数量的连续连接。
关于apache - 关闭由 QNetworkAccessManager 处理的连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24605559/
Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时,rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack
我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作),这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以
我使用的是Firefox版本36.0.1和Selenium-Webdrivergem版本2.45.0。我能够创建Firefox实例,但无法使用脚本继续进行进一步的操作无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)错误。有人能帮帮我吗? 最佳答案 我遇到了同样的问题。降级到firefoxv33后一切正常。您可以找到旧版本here 关于ruby-无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055),我们在StackOverflow上找到一个类
下面的代码在我第一次运行它时就可以正常工作:require'rubygems'require'spreadsheet'book=Spreadsheet.open'/Users/me/myruby/Mywks.xls'sheet=book.worksheet0row=sheet.row(1)putsrow[1]book.write'/Users/me/myruby/Mywks.xls'当我再次运行它时,我会收到更多消息,例如:/Library/Ruby/Gems/1.8/gems/spreadsheet-0.6.5.9/lib/spreadsheet/excel/reader.rb:11
导读:随着叮咚买菜业务的发展,不同的业务场景对数据分析提出了不同的需求,他们希望引入一款实时OLAP数据库,构建一个灵活的多维实时查询和分析的平台,统一数据的接入和查询方案,解决各业务线对数据高效实时查询和精细化运营的需求。经过调研选型,最终引入ApacheDoris作为最终的OLAP分析引擎,Doris作为核心的OLAP引擎支持复杂地分析操作、提供多维的数据视图,在叮咚买菜数十个业务场景中广泛应用。作者|叮咚买菜资深数据工程师韩青叮咚买菜创立于2017年5月,是一家专注美好食物的创业公司。叮咚买菜专注吃的事业,为满足更多人“想吃什么”而努力,通过美好食材的供应、美好滋味的开发以及美食品牌的孵
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
一段时间以来,我一直在使用open_uri下拉ftp路径作为数据源,但突然发现我几乎连续不断地收到“530抱歉,允许的最大客户端数(95)已经连接。”我不确定我的代码是否有问题,或者是否是其他人在访问服务器,不幸的是,我无法真正确定谁有问题。本质上,我正在读取FTPURI:defself.read_uri(uri)beginuri=open(uri).readuri=="Error"?nil:urirescueOpenURI::HTTPErrornilendend我猜我需要在这里添加一些额外的错误处理代码...我想确保我采取一切预防措施来关闭所有连接,这样我的连接就不是问题所在,但是我
考虑一下:现在这些情况:#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2我需要用其他字符串输出URL。我如何保证&符号不会被转义?由于我无法控制的原因,我无法发送&。求助!把我的头发拉到这里:\编辑:为了澄清,我实际上有一个像这样的数组:@images=[{:id=>"fooid",:url=>"http://
我对图像处理完全陌生。我对JPEG内部是什么以及它是如何工作一无所知。我想知道,是否可以在某处找到执行以下简单操作的ruby代码:打开jpeg文件。遍历每个像素并将其颜色设置为fx绿色。将结果写入另一个文件。我对如何使用ruby-vips库实现这一点特别感兴趣https://github.com/ender672/ruby-vips我的目标-学习如何使用ruby-vips执行基本的图像处理操作(Gamma校正、亮度、色调……)任何指向比“helloworld”更复杂的工作示例的链接——比如ruby-vips的github页面上的链接,我们将不胜感激!如果有ruby-
我有一个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