4

简而言之：
当我对 Hypnotoad 进行热部署时，有时新服务器会立即处理大量已由先前服务器处理的 HTTP 请求。

如果已呈现响应但线程仍在执行某些处理，Mojo/Hypnotoad 是否会保留请求直到处理停止？我是否需要告诉服务器 HTTP 请求已解决？

长版：
我有一个 Mojolicious::Lite 应用程序在 Hypnotoad 下运行。该应用程序的功能是接受来自另一个服务的 HTTP 请求。

我们正在处理通过一系列状态进行的作业。在每次作业状态更改时，都会通过 HTTP 请求通知应用程序。这是一个忙碌的小脚本——每小时接收超过 1000 个请求。

脚本的工作是操作一些数据.. 进行数据库更新、编辑文件、发送邮件。

为了保持进展，当它收到 HTTP 请求时，它会检查收到的数据。如果数据看起来不错，它会立即向调用者发送 200 响应，然后继续执行更耗时的任务。（我猜这是根本原因）

当我进行热部署时——通过重新运行启动脚本（运行'localperl/bin/hypnotoad $RELDIR/etc/bki/bki.pl'）——一些已经处理的请求被发送到新服务器并重新处理。

为什么这些旧交易仍然被原始服务器持有？许多早已完成！是否需要告诉 Mojolicious 请求在它发出并弄乱数据之前完成？（我考虑过 $c->finish() 但这仅适用于套接字？） Hypnotoad 如何决定应该将哪些请求传递给它的替换服务器？

这是我正在做的一些伪代码：

get '/jobStateChange/:jobId/:jobState/:jobCause' => sub {
    my $c =shift;

    my $jobId = $c->stash("jobId");
    return $c->render(text => "invalid jobId: $jobId", status => 400) unless $jobId=~/^\d+$/;

    my $jobState = $c->stash("jobState");
    return $c->render(text => "invalid jobState: $jobState", status => 400) unless $jobState=~/^\d+$/;

    my $jobCause = $c->stash("jobCause");
    return $c->render(text => "invalid jobCause: $jobCause", status => 400) unless $jobCause=~/^\d+$/;

    my $jobLocation = $c->req->param('jobLocation');
    if ($jobLocation){ $jobLocation = $ENV{'DATADIR'} . "/jobs/" . $jobLocation; }
    unless ( $jobLocation && -d $jobLocation ){
        app->log->debug("determining jobLocation because passed job jobLocation isn't useable");
        $jobLocation = getJobLocation($jobId);
        $c->stash("jobLocation", $jobLocation);
    }

    # TODO - more validation? would BKI lie to us?
    return if $c->tx->res->code && 400 == $c->tx->res->code; # return if we rendered an error above

    # tell BKI we're all set ASAP
    $c->render(text => 'ok');
    handleJobStatusUpdate($c, $jobId, $jobState, $jobCause, $jobLocation);

};

sub handleJobStatusUpdate{
    my ($c, $jobId, $jobState, $jobCause, $jobLocation) = @_;
    app->log->info("job $jobId, state $jobState, cause $jobCause, loc $jobLocation");

    # set the job states in jobs
    app->work_db->do($sql, undef, @params);


    if ($jobState == $SOME_JOB_STATE) { 
        ... do stuff ...
        ... uses $c->stash to hold data used by other functions
    }

    if ($jobState == $OTHER_JOB_STATE) { 
        ... do stuff ...
        ... uses $c->stash to hold data used by other functions
    }
}
4

1 回答 1

1

在请求处理程序返回之前，您的请求不会完成。例如，这个小应用程序需要 5 秒才能输出“test”：

# test.pl
use Mojolicious::Lite;
get '/test' => sub { $_[0]->render( text => "test" ); sleep 5 };
app->start;

您的应用程序的解决方法是handleJobStatusUpdate在后台进程中运行。

get '/jobStateChange/:jobId/:jobState/:jobCause' => sub {
    my $c =shift;    
    my $jobId = $c->stash("jobId");
    my $jobState = $c->stash("jobState");
    my $jobCause = $c->stash("jobCause");
    my $jobLocation = $c->req->param('jobLocation');
    ...
    $c->render(text => 'ok');
    if (fork() == 0) {
        handleJobStatusUpdate($c, $jobId, $jobState, $jobCause, $jobLocation);
        exit;
    }
于 2018-02-01T23:02:53.343 回答