草庐IT

php - Nginx + PHP : stop process at canceled request

coder 2023-06-15 原文

我有 Nginx 1.4.4 和 PHP 5.5.6。我正在发出长轮询请求。问题是，如果我取消通过 Ajax 发送的 HTTP 请求，请求仍在处理中(它们不会停止)。我在文件末尾使用 PHP mail() 函数对其进行了测试，邮件仍在发送，文件并未停止)。

我很担心，因为我认为它可能会因为未关闭请求的高负载而导致服务器崩溃。是的，我尝试了 ignore_user_abort(false); 但没有任何变化。有可能我应该在 Nginx 中改变一些东西吗？

  location ~ \.php$ {    
    try_files $uri =404;
    include fastcgi_params;
    fastcgi_pass 127.0.0.1:9000;
    fastcgi_index index.php;
    fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;  
  }

最佳答案

坏消息是您几乎肯定无法按照您想要的方式解决问题。当客户端在收到请求之前关闭连接时发送的 FastCGI 信号是 FCGI_ABORT_REQUEST

A Web server aborts a FastCGI request when an HTTP client closes its transport connection while the FastCGI request is running on behalf of that client. The situation may seem unlikely; most FastCGI requests will have short response times, with the Web server providing output buffering if the client is slow. But the FastCGI application may be delayed communicating with another system, or performing a server push.

不幸的是，它看起来既不像原来的 fast-cgi implementation也不PHP-FPM支持FCGI_ABORT_REQUEST信号，不能中断。

好消息是有更好的方法可以解决这个问题。基本上你不应该有需要很长时间来处理的请求。相反，如果请求需要很长时间来处理，您应该:

  • 将其推送到需要处理的任务队列中。
  • 将“任务 ID”返回给客户。
  • 让客户端定期轮询以查看该“任务”是否已完成，并在完成时显示结果。

除了这 3 项基本内容之外 - 如果您担心当客户端不再对请求的结果感兴趣时会浪费系统资源，您应该添加:

  • 将任务分解成小块工作，如果客户仍然要求结果，则只将任务从一个工作“状态”转移到下一个工作“状态”。

您没有说明长期运行的任务是什么 - 让我们假设它是从另一台服务器下载一个大图像文件，处理该图像，然后将其存储在 S3 中。所以这个任务的状态是这样的:

TASK_STATE_QUEUED
TASK_STATE_DOWNLOADING //Moves to next state when finished download
TASK_STATE_DOWNLOADED
TASK_STATE_PROCESSING  //Moves to next state when processing finished
TASK_STATE_PROCESSED
TASK_STATE_UPLOADING_TO_S3 //Moves to next state when uploaded
TASK_STATE_FINISHED

因此，当客户端发送初始请求时，它会返回一个 taskID，然后当它查询该任务的状态时，可以:

  • 服务器报告任务仍在处理中

或

  • 如果它处于以下状态之一，客户端请求会将其跳转到下一个状态。

即

TASK_STATE_QUEUED => TASK_STATE_DOWNLOADING
TASK_STATE_DOWNLOADED => TASK_STATE_PROCESSING
TASK_STATE_PROCESSED => TASK_STATE_UPLOADING_TO_S3

所以只有客户感兴趣的请求才会继续处理。

顺便说一句，我强烈建议使用旨在高效工作的东西作为队列来保存任务队列(例如 Rabbitmq 、 Redis 或 Gearman )，而不是仅仅使用 MySQL 或任何数据库。基本上，SQL 在充当队列方面并不是那么出色，您最好从一开始就使用适当的技术，而不是使用错误的技术开始，然后在数据库变得紧急时不得不将其换掉当它试图每秒执行数百次插入、更新以管理任务时重载。

作为一个附带的好处，通过将长时间运行的流程分解为任务，它变得非常容易:

  1. 查看处理时间花在了哪些地方。
  2. 查看并检测处理时间的波动(例如，如果 CPUS 达到 100% 的利用率，那么调整图像大小会突然花费更长的时间)。
  3. 在缓慢的步骤上投入更多资源。
  4. 您可以向客户提供状态更新消息，这样他们就可以看到任务的进展情况，这样可以提供更好的用户体验，而不是坐在那里“什么都不做”。

关于php - Nginx + PHP : stop process at canceled request，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/20251224/

canceledprocessSTATETASK长时phpnginxlong-polling

有关php - Nginx + PHP : stop process at canceled request的更多相关文章

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

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

  2. 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.你能做的最好的事情是:

  3. ruby - 如何计算 Liquid 中的变量 +1 - 2

    我对如何计算通过{%assignvar=0%}赋值的变量加一完全感到困惑。这应该是最简单的任务。到目前为止，这是我尝试过的:{%assignamount=0%}{%forvariantinproduct.variants%}{%assignamount=amount+1%}{%endfor%}Amount:{{amount}}结果总是0。也许我忽略了一些明显的东西。也许有更好的方法。我想要存档的只是获取运行的迭代次数。 最佳答案 因为{{incrementamount}}将输出您的变量值并且不会影响{%assign%}定义的变量，我

  4. ruby-on-rails - 如何用不同的用户运行nginx主进程 - 2

    A/ctohttp://wiki.nginx.org/CoreModule#usermaster进程曾经以root用户运行，是否可以以不同的用户运行nginxmaster进程？ 最佳答案 只需以非root身份运行init脚本(即/etc/init.d/nginxstart)，就可以用不同的用户运行nginxmaster进程。如果这真的是你想要做的，你将需要确保日志和pid目录(通常是/var/log/nginx&/var/run/nginx.pid)对该用户是可写的，并且您所有的listen调用都是针对大于1024的端口(因为绑定(

  5. arrays - Ruby 数组 += vs 推送 - 2

    我有一个数组数组，想将元素附加到子数组。+=做我想做的，但我想了解为什么push不做。我期望的行为(并与+=一起工作):b=Array.new(3,[])b[0]+=["apple"]b[1]+=["orange"]b[2]+=["frog"]b=>[["苹果"],["橙子"],["Frog"]]通过推送，我将推送的元素附加到每个子数组(为什么？):a=Array.new(3,[])a[0].push("apple")a[1].push("orange")a[2].push("frog")a=>[[“苹果”、“橙子”、“Frog”]、[“苹果”、“橙子”、“Frog”]、[“苹果”、“

  6. += 的 Ruby 方法 - 2

    有没有办法让Ruby能够做这样的事情？classPlane@moved=0@x=0defx+=(v)#thisiserror@x+=v@moved+=1enddefto_s"moved#{@moved}times,currentxis#{@x}"endendplane=Plane.newplane.x+=5plane.x+=10putsplane.to_s#moved2times,currentxis15 最佳答案 您不能在Ruby中覆盖复合赋值运算符。任务在内部处理。您应该覆盖+，而不是+=。plane.a+=b与plane.a=

  7. ruby - Sinatra + Heroku + Datamapper 使用 dm-sqlite-adapter 部署问题 - 2

    出于某种原因，heroku尝试要求dm-sqlite-adapter，即使它应该在这里使用Postgres。请注意，这发生在我打开任何URL时-而不是在gitpush本身期间。我构建了一个默认的Facebook应用程序。gem文件:source:gemcuttergem"foreman"gem"sinatra"gem"mogli"gem"json"gem"httparty"gem"thin"gem"data_mapper"gem"heroku"group:productiondogem"pg"gem"dm-postgres-adapter"endgroup:development,:t

  8. ruby - Ruby 中字符串运算符 + 和 << 的区别 - 2

    我是Ruby和这个网站的新手。下面两个函数是不同的，一个在函数外修改变量，一个不修改。defm1(x)x我想确保我理解正确-当调用m1时，对str的引用被复制并传递给将其视为x的函数。运算符当调用m2时，对str的引用被复制并传递给将其视为x的函数。运算符+创建一个新字符串，赋值x=x+"4"只是将x重定向到新字符串，而原始str变量保持不变。对吧？谢谢 最佳答案 String#+::str+other_str→new_strConcatenation—ReturnsanewStringcontainingother_strconc

  9. ruby - rails 3.2.2(或 3.2.1)+ Postgresql 9.1.3 + Ubuntu 11.10 连接错误 - 2

    我正在使用PostgreSQL9.1.3(x86_64-pc-linux-gnu上的PostgreSQL9.1.3，由gcc-4.6.real(Ubuntu/Linaro4.6.1-9ubuntu3)4.6.1，64位编译)和在ubuntu11.10上运行3.2.2或3.2.1。现在，我可以使用以下命令连接PostgreSQLsupostgres输入密码我可以看到postgres=#我将以下详细信息放在我的config/database.yml中并执行“railsdb”，它工作正常。开发:adapter:postgresqlencoding:utf8reconnect:falsedat

  10. ruby - 在 Ruby + Chef 中检查现有目录失败 - 2

    这是我在ChefRecipe中的一blockRuby:#ifdatadirdoesn'texist,moveoverthedefaultoneif!File.exist?("/vol/postgres/data")execute"mv/var/lib/postgresql/9.1/main/vol/postgres/data"end结果是:Executingmv/var/lib/postgresql/9.1/main/vol/postgres/datamv:inter-devicemovefailed:`/var/lib/postgresql/9.1/main'to`/vol/post

随机推荐