6

我的目标是使用Guzzle 6创建一个 PUT json 数据的异步请求池。然后监控每个 $promise 成功/失败。

为了与我的 POOL 代码示例进行比较，以下对 $client->request() 的单个请求将第三个参数转换为编码的 json，然后添加 Content-type:application/json。**

$client = new Client([
    'base_uri' => BASE_URL . 'test/async/', // Base URI is used with relative requests
    'timeout'  => 0, // 0 no timeout for operations and watching Promises
]);

$response = $client->request('PUT', 'cool', ['json' => ['foo' => 'bar']]);

在接收 API 端点上，我可以通过执行以下操作从上面的单个请求中读取 json： 

$json = file_get_contents('php://input');
$json = json_decode($json, true);

使用文档中的并发请求示例，为了使用 new Request() 创建异步请求池，我希望可以使用相同的参数（方法、url 端点、json 标志），就像在单个 $client->request( ) 上面的例子。但是，yield new Request()不处理 3rd json 参数，如$client->request(). 从我的池代码调用正确设置 json 和内容类型的正确 Guzzle 函数是什么？或者有没有更好的方法来创建大量异步请求并监控它们的结果？

池代码示例：

$this->asyncRequests = [
    [
        'endpoint' => 'cool'
    ],
    [
        'endpoint' => 'awesome'
    ],
    [
        'endpoint' => 'crazy'
    ],
    [
        'endpoint' => 'weird'
    ]
];

$client = new Client([
    'base_uri' => BASE_URL, // Base URI is used with relative requests
    'timeout'  => 0 // 0 no timeout for operations and watching Promises
]);

$requests = function ($asyncRequests) {
    $uri = BASE_URL . 'test/async/';

    foreach ($asyncRequests as $key => $data) {
        yield new Request('PUT', "{$uri}{$data['endpoint']}", ['json' => ['foo' => 'bar']]);
    }
};

$pool = new Pool($client, $requests($this->asyncRequests), [
    'concurrency' => 10,
    'fulfilled' => function ($response, $index) {
        $this->handleSuccessPromises($response, $index);
    },
    'rejected' => function ($reason, $index) {
        $this->handleFailurePromises($reason, $index);
    },
]);

$promise = $pool->promise(); // Initiate the transfers and create a promise

$promise->wait(); // Force the pool of requests to complete.
4

2 回答 2

9

希望其他人会加入并让我知道是否有更正确的方法来实现我的目标，但是在查看 Guzzle 的引擎盖后，我意识到新 Request() 的第三个参数正在寻找标头信息，而第四个参数正在寻找一个身体。所以下面的代码使用池工作： 

foreach ($syncRequests as $key => $headers) {
    yield new Request('PUT', "{$uri}{$headers['endpoint']}", ['Content-type' => 'application/json'], json_encode(['json' => ['nonce' => $headers['json']]]));
}

也在 Psr7\Request 的文档中 在此处输入图像描述

于 2016-04-08T05:45:30.030 回答
1

如果您想要完全控制，请不要在您的池中使用 Request() 对象。相反，通过让池的生成器产生一个启动请求的可调用函数来自己启动请求。这使您可以完全控制所有选项。这是一个正确的代码示例：

https://stackoverflow.com/a/40622269/5562035

于 2016-11-16T20:59:14.157 回答