laravel7开始加入了httpclient包，比guzzle库好用，如果是低于laravel7可以把Httpclient包手动引入到项目中
这里对httpclient做一些修改使得其可以自动记录成功以及错误日志

创建事件

  1. <?php
  3. namespace App\Light\HttpClient;
  6. use Illuminate\Contracts\Support\Arrayable;
  8. class HttpSendSuccessEvent implements \JsonSerializable,Arrayable
  9. {
  11.     public $request_id;           //请求标识
  12.     public $url;                  //url
  13.     public $params;               //请求参数
  14.     public $method;               //请求方法
  15.     public $created_at;           //请求时间
  16.     public $response;             //响应内容
  17.     public $response_header;      //响应头
  18.     public $request_header;       //请求头
  19.     public $handler_stats;        //请求信息
  20.     public $tag;                  //标签
  24.     public function toArray()
  25.     {
  26.         return [
  27.             'request_id'      => $this->request_id,
  28.             'url'             => $this->url,
  29.             'params'          => $this->params,
  30.             'method'          => $this->method,
  31.             'created_at'      => $this->created_at,
  32.             'response'        => $this->response,
  33.             'response_header' => $this->response_header,
  34.             'request_header'  => $this->request_header,
  35.             'handler_stats'   => $this->handler_stats,
  36.             'tag'             => $this->tag,
  37.         ];
  38.     }
  41.     public function jsonSerialize()
  42.     {
  44.         return $this->toArray();
  45.     }
  48.     public function __toString()
  49.     {
  50.         return json_encode($this, JSON_UNESCAPED_UNICODE);
  51.     }
  52. }
  1. <?php
  3. namespace App\Light\HttpClient;
  6. use Illuminate\Contracts\Support\Arrayable;
  8. class HttpSendFailEvent implements \JsonSerializable,Arrayable
  9. {
  11.     public $request_id;           //请求标识
  12.     public $url;                  //url
  13.     public $params;               //请求参数
  14.     public $method;               //请求方法
  15.     public $created_at;           //请求时间
  16.     public $error;                //错误信息
  17.     public $response_header;      //响应头
  18.     public $tag;                  //标签
  21.     public function toArray()
  22.     {
  23.         return [
  24.             'request_id'      => $this->request_id,
  25.             'url'             => $this->url,
  26.             'params'          => $this->params,
  27.             'method'          => $this->method,
  28.             'created_at'      => $this->created_at,
  29.             'error'           => $this->error,
  30.             'response_header' => $this->response_header,
  31.             'tag'             => $this->tag,
  32.         ];
  33.     }
  36.     public function jsonSerialize()
  37.     {
  39.         return $this->toArray();
  40.     }
  42.     public function __toString()
  43.     {
  44.         return json_encode($this, JSON_UNESCAPED_UNICODE);
  45.     }
  46. }

增加日志逻辑

修改httpclient包中PendingReques类中的send方法

  1.  public function send(string $method, string $url, array $options = [])
  2.     {
  3.         $url = ltrim(rtrim($this->baseUrl, '/') . '/' . ltrim($url, '/'), '/');
  5.         if (isset($options[$this->bodyFormat])) {
  6.             if ($this->bodyFormat === 'multipart') {
  7.                 $options[$this->bodyFormat] = $this->parseMultipartBodyFormat($options[$this->bodyFormat]);
  8.             } elseif ($this->bodyFormat === 'body') {
  9.                 $options[$this->bodyFormat] = $this->pendingBody;
  10.             }
  12.             if (is_array($options[$this->bodyFormat])) {
  13.                 $options[$this->bodyFormat] = array_merge(
  14.                     $options[$this->bodyFormat], $this->pendingFiles
  15.                 );
  16.             }
  17.         }
  19.         [$this->pendingBody, $this->pendingFiles] = [null, []];
  21.         return retry($this->tries ?? 1, function () use ($method, $url, $options) {
  22.             try {
  23.                 $laravelData = $this->parseRequestData($method, $url, $options);
  25.                 return tap(new Response($this->buildClient()->request($method, $url, $this->mergeOptions([
  26.                                                                                                              'laravel_data' => $laravelData,
  27.                                                                                                              'on_stats'     => function ($transferStats) {
  28.                                                                                                                  $this->transferStats = $transferStats;
  29.                                                                                                              },
  30.                                                                                                          ], $options))), function ($response) use ($method, $url, $options) {
  31.                     $response->cookies       = $this->cookies;
  32.                     $response->transferStats = $this->transferStats;
  33.                                           //新加入
  34.                         //生产事件
  35.                         $event                  = new HttpSendSuccessEvent();
  36.                         $event->url             = $url;
  37.                         $event->params          = $options;
  38.                         $event->method          = $method;
  39.                         $event->created_at      = Carbon::now()->toDateTimeString();
  40.                         $event->response        = $response->body();
  41.                         $event->request_header  = $response->transferStats->getRequest()->getHeaders();
  42.                         $event->response_header = $response->headers();
  43.                         $event->handler_stats   = $response->handlerStats();
  44.                         //发事件
  45.                         event($event);
  48.                     if ($this->tries > 1 && !$response->successful()) {
  49.                         $response->throw();
  50.                     }
  51.                 });
  52.             } catch (ConnectException $e) {
  53.                   //新加入
  54.                 //生产事件
  55.                 $event                 = new HttpSendFailEvent();
  56.                 $event->url            = $url;
  57.                 $event->params         = $options;
  58.                 $event->method         = $method;
  59.                 $event->created_at     = Carbon::now()->toDateTimeString();
  60.                 $event->error          = $e->getHandlerContext();
  61.                 $event->request_header = $e->getRequest()->getHeaders();
  62.                 //发事件
  63.                 event($event);
  66.                 throw new ConnectionException($e->getMessage(), 0, $e);
  68.             }
  69.         }, $this->retryDelay ?? 100);
  70.     }

创建事件处理器

这里使用了生成请求唯一标识和terminate中间件 参考laravel技巧—请求日志和laravel技巧-terminate延迟处理

  1. <?php
  3. namespace App\Light\HttpClient;
  6. use App\Light\RequestID\ResID;
  7. use App\Light\TerminateHandle\TerminateEvent;
  8. use App\Light\TerminateHandle\TerminateHandle;
  9. use Carbon\Carbon;
  10. use Illuminate\Support\Facades\DB;
  13. class HttpSendSuccessEventListener
  14. {
  15.     public function handle(HttpSendSuccessEvent $event)
  16.     {
  18.         //延迟记录
  19.         TerminateHandle::add(new TerminateEvent(function () use ($event) {
  21.             $event->request_id = ResID::get();           //请求标识
  22.             DB::connection('mongodb')
  23.                 ->collection('curl_' . Carbon::now()->format('Ym'))
  24.                 ->insert($event->toArray());
  26.         }));
  29.     }
  31. }
  1. <?php
  3. namespace App\Light\HttpClient;
  6. use App\Light\RequestID\ResID;
  7. use App\Light\TerminateHandle\TerminateEvent;
  8. use App\Light\TerminateHandle\TerminateHandle;
  9. use Carbon\Carbon;
  10. use Illuminate\Support\Facades\DB;
  13. class HttpSendFailEventListener
  14. {
  15.     public function handle(HttpSendFailEvent $event)
  16.     {
  18.         //延迟记录
  19.         TerminateHandle::add(new TerminateEvent(function () use ($event) {
  20.             try {
  21.                 $event->request_id = ResID::get();  //请求标识
  22.                 DB::connection('mongodb')
  23.                     ->collection('curl_error_' . Carbon::now()->format('Ym'))
  24.                     ->insert($event->toArray());
  25.             } catch (\Exception $exception) {
  27.             }
  28.         }));
  31.     }
  33. }

注册事件处理器

  1. class EventServiceProvider extends ServiceProvider
  2. {
  3.     /**
  4.      * The event listener mappings for the application.
  5.      *
  6.      * @var array
  7.      */
  8.     protected $listen = [
  9.                //新增
  10.         HttpSendSuccessEvent::class => [
  11.             HttpSendSuccessEventListener::class
  12.         ],
  13.         HttpSendFailEvent::class    => [
  14.             HttpSendFailEventListener::class
  15.         ],
  17.     ];

查看结果

成功结果
image.png
失败结果
image.png