3

我正在尝试使用 mojolicious 在 Perl 中创建一个松弛应用程序，并且我有以下用例：

Slack 从斜杠命令向我的 API 发送请求，并且需要在 3 秒的时间范围内做出响应。然而，Slack 也让我有机会在 30 分钟的时间内发送多达 5 个响应，但仍然需要在 3 秒内做出初始响应（它只是在初始回调中发送一个“late_response_url”，以便我可以发布一些内容到那个网址稍后）。就我而言，我想向 slack 发送一个初始响应，以通知用户该操作正在“运行”，并在一段时间后将我的慢速函数的实际结果发送给 Slack。

目前，我可以通过使用 fork() 生成第二个进程并使用一个进程按照 Slack 的指示立即响应，然后使用第二个进程完成其余工作并稍后响应来做到这一点。

我正在尝试使用 Mojolicious 的子进程来避免使用 fork()。但是我找不到办法让它工作....

我已经用 fork 做的示例代码是这样的：

sub withpath
{
     my $c = shift;

     my $user   = $c->param('user_name');

     my $response_body = {
                response_type => "ephemeral",
                text          => "Running for $user:",
                attachments   => [
                     { text => 'analyze' },
                 ],
             };
     my $pid = fork();
     if($pid != 0){
         $c->render( json => $response_body );
     }else{
         $output = do_time_consuming_things()
         $response_body = {
             response_type => "in-channel",
             text          => "Result for $user:",
             attachments   => [
                { text => $output },
             ],
         };

         my $ua = Mojo::UserAgent->new;
         my $tx = $ua->post(
               $response_url,
               { Accept => '*/*' },
               json => $response_body,
               );
        if( my $res = $tx->success )
        {
                print "\n success \n";
        }
        else
        {
                my $err = $tx->error;
                print "$err->{code} response: $err->{message}\n" if $err->{code};
                print "Connection error: $err->{message}\n";
        }
    }
}

所以问题是，无论我如何尝试，我都无法使用 Mojolicious 的子进程复制完全相同的代码。有任何想法吗？

提前致谢！

4

1 回答 1

3

实际上，我刚刚找到了解决问题的方法！

所以这是我的解决方案：

my $c = shift; #receive request

my $user   = $c->param('user_name'); #get parameters
my $response_url = $c->param('response_url');
my $text = $c->param('text');

my $response_body = { #create the imidiate response that Slack is waiting for
            response_type => "ephemeral",
            text          => "Running for $user:",
            attachments   => [
                { text => 'analyze' },
            ],
        };

my $subprocess = Mojo::IOLoop::Subprocess->new; #create the subprocesses
$subprocess->run(
sub {do_time_consuming_things($user,$response_url,$text)}, #this callback is the
#actuall subprocess that will run in background and contains the POST request
#from my "fork" code (with the output) that should send a late response to Slack
sub {# this is a dummy subprocess doing nothing as this is needed by Mojo.
    my ($subprocess, $err, @results) = @_;
    say $err if $err;
    say "\n\nok\n\n";
}
);
#and here is the actual imidiate response outside of the subprocesses in order
#to avoid making the server wait for the subprocess to finish before responding!
$c->render( json => $response_body );

所以我实际上只需将我的 do_time_sumption_things 代码放在第一个回调中（以便它作为子进程运行）并使用第二个回调（实际上链接到父进程）作为虚拟回调并保持我的“imidiate " 在整个函数的主体中响应，而不是将其放在子进程之一中。有关更多信息，请参阅代码注释！

于 2018-09-13T12:35:24.510 回答