欢迎各位兄弟 发布技术文章

这里的技术是共享的

You are here

Laravel中用GuzzleHttp Guzzle 最上面的代码是我自己亲自做的 有大用 有大用

最上面的代码是我自己亲自做的 有大用

下面的代码是我自己亲自做的 有大用

<?php

 

namespace App\Http\Controllers\Admin;

 

use Illuminate\Http\Request;

 

use App\Http\Requests;
use App\Http\Controllers\Controller;
use GuzzleHttp\Client;
use Redirect;

 

class ToGongxaingController extends AdminController
{
    //
    //
    public function login()
    {
        $gongxiang_email = config('custommyconfig.gongxiang_email');
        $gongxiang_password = config('custommyconfig.gongxiang_password');
        $client = new Client();
        $response = $client->request('POST', 'http://'.config('custommyconfig.domain_gongxiang').'/api/login', [
            'form_params' => [
                'email' => $gongxiang_email,
                'password' => $gongxiang_password,
            ]
        ]);
        $result = $response->getBody()->getContents();
        $result = json_decode($result,true);
        $result = $result['result'];

 

        if($result=='error'){
            return '有错误,可能用户名密码不对';
        }
        else {
            return Redirect::to('http://'.config('custommyconfig.domain_gongxiang').'/api/wendas?token='.$result);
        }

 

    }
}

  


今天项目中用到GuzzleHttp,开始不知道怎么用,其实还是很简单的。 

直接在项目根目录,输入以下命令

composer require guzzlehttp/guzzle(现在默认是 6.3 的版本,也许以后 版本会有变化哟)

等下载安装好,在vendor文件夹下,有一个guzzle目录,此文件夹就是guzzlehttp的package了。 
如何使用,可以参考官方文档http://docs.guzzlephp.org/en/latest/ 
下面这段代码就是官网文档中的一段

image.png

$client = new GuzzleHttp\Client();
$res = $client->request('GET', 'https://api.github.com/user', ['auth' => ['user', 'pass']
]);
echo $res->getStatusCode();// "200"echo 
$res->getHeader('content-type');// 'application/json; charset=utf8'
echo $res->getBody();// {"type":"User"...'// Send an asynchronous request.$request = new \GuzzleHttp\Psr7\Request('GET', 'http://httpbin.org');$promise = $client->sendAsync($request)->then(function ($response) {echo 'I completed! ' . $response->getBody();
});
$promise->wait();


下面这段代码就是官网文档中的一段

我在项目中,已经使用了form表单post,异步请求等等。

在 git 里面 使用 
$ curl --request POST 'http://myapp/api/authenticate' --data "email=myemail@domain.tld" --data "password=password"
可以得到正确的返回值

我在项目中,已经使用了form表单post,异步请求等等。 
这篇文章还是挺有意思的《Laravel 下使用 Guzzle 编写多线程爬虫实战》,代码啥都有,虽然是个小玩意,但能学到很多东西。 
比如:

  1. 在Laravel中如何创建命令

  2. 怎么用多线程

贴一下代码

image.png

image.png

image.png

贴一下代码

<?php namespace App\Console\Commands;use GuzzleHttp\Client;use GuzzleHttp\Pool;use GuzzleHttp\Psr7\Request;use GuzzleHttp\Exception\ClientException;use Illuminate\Console\Command;class MultithreadingRequest extends Command{
    private $totalPageCount;    private $counter        = 1;    private $concurrency    = 7;  // 同时并发抓取

    private $users = ['CycloneAxe', 'appleboy', 'Aufree', 'lifesign',                        'overtrue', 'zhengjinghua', 'NauxLiu'];    protected $signature = 'test:multithreading-request';    protected $description = 'Command description';    public function __construct()
    {
        parent::__construct();
    }    public function handle()
    {
        $this->totalPageCount = count($this->users);        $client = new Client();        $requests = function ($total) use ($client) {
            foreach ($this->users as $key => $user) {                $uri = 'https://api.github.com/users/' . $user;                yield function() use ($client, $uri) {
                    return $client->getAsync($uri);
                };
            }
        };        $pool = new Pool($client, $requests($this->totalPageCount), [            'concurrency' => $this->concurrency,            'fulfilled'   => function ($response, $index){

                $res = json_decode($response->getBody()->getContents());                $this->info("请求第 $index 个请求,用户 " . $this->users[$index] . " 的 Github ID 为:" .$res->id);                $this->countedAndCheckEnded();
            },            'rejected' => function ($reason, $index){
                $this->error("rejected" );                $this->error("rejected reason: " . $reason );                $this->countedAndCheckEnded();
            },
        ]);        // 开始发送请求
        $promise = $pool->promise();        $promise->wait();
    }    public function countedAndCheckEnded()
    {
        if ($this->counter < $this->totalPageCount){            $this->counter++;            return;
        }        $this->info("请求结束!");
    }
}123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172

运行结果如下:

$ php artisan test:multithreading-request
请求第 5 个请求,用户 zhengjinghua 的 Github ID 为:3413430请求第 6 个请求,
用户 NauxLiu 的 Github ID 为:9570112请求第 0 个请求,
用户 CycloneAxe 的 Github ID 为:6268176请求第 1 个请求,
用户 appleboy 的 Github ID 为:21979请求第 2 个请求,
用户 Aufree 的 Github ID 为:5310542请求第 3 个请求,
用户 lifesign 的 Github ID 为:2189610请求第 4 个请求,
用户 overtrue 的 Github ID 为:1472352请求结束!123456789

版权声明:本文为博主原创文章,未经博主允许不得转载。




来自  http://blog.csdn.net/xhanfei/article/details/51908629?locationNum=14&fps=1



普通分类: