blocks|key|2560466|text|我将使用React，因为我更了解这个库，但它们的工作方式相似。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2560467|编辑:已更新，请参阅注释|2560468|这将读取一个文件，并且每次收到数据块时，它将创建一个api调用并将数据发送出去|2560469|<?php

require_once+__DIR__+.+'/vendor/autoload.php';

function+async_send($config,+$file,+callable+$proccessor)
{

++++$config['ssl']+=+true+===+$config['ssl']+?+'s'+:+'';
++++$client+=+new+\GuzzleHttp\Client([
++++++++'base_uri'+=>+'http'+.+$config['ssl']+.+'://'+.+$config['domain']+.+'/rest/all/V1/',
++++++++'verify'+=>+false,
++++++++'http_errors'+=>+false
++++]);
++++$loop+=+\React\EventLoop\Factory::create();
++++$filesystem+=+\React\Filesystem\Filesystem::create($loop);
++++$filesystem->getContents($file)->then(function($contents)+use+($config,+$proccessor,+$client)+{
++++++++$contents+=+$proccessor($contents);
++++++++$client->post($config['uri'],+['body'+=>+$contents]);
++++});
}

$config+=+[
++++'domain'+=>+'example.com',
++++'ssl'+=>+true
];
//somewhere+later
$configp['uri']+=+'products';
async_send($configp,+__DIR__+.+'my.csv',+function+($contents)+{
++++return+json_encode($contents);
});|code-block|syntax|javascript|2560470|entityMap^0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|N|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|O|8|@]|9|@]|A|$]]|$1|F|3|G|5|H|7|P|8|@]|9|@]|A|$I|J]]|$1|K|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|L|$]]

I am going to use React as I know the library better but they work in similar ways.

EDIT: updated, see comments

This will read in a file and every time it recieves a chunk of data, it will create an api call and send the data off

<pre><code>&lt;?php

require_once __DIR__ . '/vendor/autoload.php';

function async_send($config, $file, callable $proccessor)
{

 $config['ssl'] = true === $config['ssl'] ? 's' : '';
 $client = new \GuzzleHttp\Client([
 'base_uri' =&gt; 'http' . $config['ssl'] . '://' . $config['domain'] . '/rest/all/V1/',
 'verify' =&gt; false,
 'http_errors' =&gt; false
 ]);
 $loop = \React\EventLoop\Factory::create();
 $filesystem = \React\Filesystem\Filesystem::create($loop);
 $filesystem-&gt;getContents($file)-&gt;then(function($contents) use ($config, $proccessor, $client) {
 $contents = $proccessor($contents);
 $client-&gt;post($config['uri'], ['body' =&gt; $contents]);
 });
}

$config = [
 'domain' =&gt; 'example.com',
 'ssl' =&gt; true
];
//somewhere later
$configp['uri'] = 'products';
async_send($configp, __DIR__ . 'my.csv', function ($contents) {
 return json_encode($contents);
});
</code></pre>

blocks|key|2560483|text|以防其他人试图解决类似的问题|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2560484|<?php

require_once+__DIR__+.+'/../vendor/autoload.php';

use+React\HttpClient\Client+as+ReactClient;

function+async_send($loop,+$filePath,+callable+$proccessor)
{
++++echo+"starting";
++++echo+"\n\r";

++++try+{

++++++++$filesystem+=+\React\Filesystem\Filesystem::create($loop);

++++++++$file+=+$filesystem->file($filePath);
++++++++$file->open('r')
++++++++++++->then(function+($stream)+use+($loop,+$proccessor){
++++++++++++++++$stream->on('data',+function+($chunk)+use+($loop,+$proccessor)+{
+++++++++++++++++++$proccessor($chunk);
++++++++++++++++});
++++++++++++});

++++}+catch+(\Exception+$e)+{
++++++++echo+"failed";
++++++++echo+"\n\r";
++++}
++++echo+"ending+reading";
++++echo+"\n\r";
}

function+callApiReal($loop,+$fileChunk+=+null)
{
++++echo+"ready+to+call+api".+PHP_EOL;

++++$uri+=+"https://testapi.com/";
++++try+{
++++++++$client+=+new+ReactClient($loop);
++++}+catch+(\Exception+$e)+{
++++++++echo+"Error";
++++}
++++echo+"ready+to+call+api";

++++$request+=+$client->request('POST',+$uri,+$fileChunk);

++++$request->on('response',+function+($response)+use+($uri)+{

++++++++$response->on('data',+function+($data_chunk)+{
++++++++++++echo+'data+chunk+from+api+received';
++++++++++++echo+"\n\r";
++++++++});

++++++++//+subscribe+to+listen+to+the+end+of+the+response
++++++++$response->on('end',+function+()+use+($uri)+{
++++++++++++echo+"operation+has+completed";
++++++++++++echo+"\n\r";
++++++++});
++++});

++++$request->on('error',+function+($error)+{
++++++++//+something+went+bad+in+the+request
++++++++echo+"Damm!";
++++++++echo+"\n\r";
++++});

++++$request->end();

}

//+main+loop
$loop+=+React\EventLoop\Factory::create();

//somewhere+later
async_send($loop,+__DIR__+.+'/my.csv',+function+($chunk)+use+($loop)+{
++++echo+"calling+api";
++++callApiReal($loop,+$chunk);
++++echo+"\n\r";
});

$loop->run();|code-block|syntax|javascript|2560485|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

In case someone else is trying to solve a similar problem

<pre><code>&lt;?php

require_once __DIR__ . '/../vendor/autoload.php';

use React\HttpClient\Client as ReactClient;

function async_send($loop, $filePath, callable $proccessor)
{
 echo "starting";
 echo "\n\r";

 try {

 $filesystem = \React\Filesystem\Filesystem::create($loop);

 $file = $filesystem-&gt;file($filePath);
 $file-&gt;open('r')
 -&gt;then(function ($stream) use ($loop, $proccessor){
 $stream-&gt;on('data', function ($chunk) use ($loop, $proccessor) {
 $proccessor($chunk);
 });
 });

 } catch (\Exception $e) {
 echo "failed";
 echo "\n\r";
 }
 echo "ending reading";
 echo "\n\r";
}

function callApiReal($loop, $fileChunk = null)
{
 echo "ready to call api". PHP_EOL;

 $uri = "https://testapi.com/";
 try {
 $client = new ReactClient($loop);
 } catch (\Exception $e) {
 echo "Error";
 }
 echo "ready to call api";

 $request = $client-&gt;request('POST', $uri, $fileChunk);

 $request-&gt;on('response', function ($response) use ($uri) {

 $response-&gt;on('data', function ($data_chunk) {
 echo 'data chunk from api received';
 echo "\n\r";
 });

 // subscribe to listen to the end of the response
 $response-&gt;on('end', function () use ($uri) {
 echo "operation has completed";
 echo "\n\r";
 });
 });

 $request-&gt;on('error', function ($error) {
 // something went bad in the request
 echo "Damm!";
 echo "\n\r";
 });

 $request-&gt;end();

}

// main loop
$loop = React\EventLoop\Factory::create();

//somewhere later
async_send($loop, __DIR__ . '/my.csv', function ($chunk) use ($loop) {
 echo "calling api";
 callApiReal($loop, $chunk);
 echo "\n\r";
});

$loop-&gt;run();
</code></pre>

I have a situation where I have a loop, that is going to read chunk of data from a file, send those chunk to a rest api, and continue until the EOF, but I want this to be async inside the loop, so, I don't have to wait until the API respond to read the next chunk.
I have been looking at Amphp and ReactPHP for I can't find a solution to this, or maybe I don't understand how are those libraries supposed to be used.
here is a pseudo of what I am doing.

<pre><code>&lt;?php

while($file.read()){

 $chunk = getNextChunk();

 sendChunkAsync($chunk);

}

function getNextChunk(){

 echo "reading next chunk";

 // read next chunk of data

}
</code></pre>

sample with amphp

<pre><code>function sendChunkAsync($chunk){

Loop::run(function () {

 $uri = "https://testapi.com/api";

 $client = new DefaultClient;

 try {

 $promises = $client-&gt;request($uri);


 $responses = yield $promises;

 echo "chunk processed";

 } catch (Amp\Artax\HttpException $error) {

 // log error

 // $error-&gt;getMessage() . PHP_EOL;
 }
});

}
</code></pre>

In this case I would expect (if reading chunk is faster than getting response from api) something like this, don't take this literary, I am trying to illustrate it for you. 

Reading next chunk

Reading next chunk

chunk processed

Reading next chunk

chunk processed

chunk processed

Async http call with php

我有一种情况，我有一个循环，它将从文件中读取数据块，将这些块发送到rest api，并继续到EOF，但我希望这在循环中是异步的，因此，我不必等待API响应来读取下一个块。我一直在研究Amphp和ReactPHP，因为我找不到一个解决方案，或者我不明白这些库应该如何使用。这是我正在做的一个伪代码。<?phpwhile($...

问使用php进行异步http调用
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用php进行异步http调用EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用php进行异步http调用
EN