中文在线一区二区_欧美在线综合_久久久久久综合_欧美一区二区三区视频_国产免费看_国产福利精品一区

Tracker

EasySwoole 提供了一個基礎的追蹤組件，方便用戶實現基礎的服務器狀態監控，與調用鏈記錄。

組件要求

  • php: >=7.1.0
  • ext-swoole: ^4.4.0
  • easyswoole/component: ^2.0

安裝方法

composer require easyswoole/tracker

倉庫地址

easyswoole/tracker

調用鏈結構說明

EasySwoole 的調用鏈跟蹤是一個以類似有序的樹狀鏈表的解構實現的，解構如下：

struct Point{
    struct Point* nextPoint;
    struct Point[] subPoints;
    const END_SUCCESS = 'success';
    const END_FAIL = 'fail';
    const END_UNKNOWN = 'unknown';
    int startTime;
    mixed startArg;
    int endTime;
    string pointName;
    string endStatus = self::END_UNKNOWN;
    mixed endArg;
    string pointId;
    string parentId;
    int depth = 0;
    bool isNext
}

基本使用

<?php
/**
 * This file is part of EasySwoole.
 *
 * @link http://www.jrrswxmm.cn
 * @document http://www.jrrswxmm.cn
 * @contact http://www.jrrswxmm.cn/Preface/contact.html
 * @license https://github.com/easy-swoole/easyswoole/blob/3.x/LICENSE
 */

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

use EasySwoole\Tracker\Point;
use EasySwoole\Component\WaitGroup;
use EasySwoole\Tracker\PointContext;

/*
 * 假設我們的調用鏈是這樣的
 * onRequest  ->> actionOne ->> actionOne call remote Api(1,2)  ->>  afterAction
 */

go(function (){
    /*
     * 創建入口
     */
    $onRequest = new Point('onRequest');
    //記錄請求參數，并模擬access log
    \co::sleep(0.01);
    $onRequest->setStartArg([
        'requestArg' => 'requestArgxxxxxxxx',
        'accessLogId'=>'logIdxxxxxxxxxx'
    ]);
    //onRequest完成
    $onRequest->end();
    //進入 next actionOne
    $actionOne = $onRequest->next('actionOne');
        //action one 進入子環節調用
        $waitGroup = new WaitGroup();
        //sub pointOne
        $waitGroup->add();
        $subOne = $actionOne->appendChild('subOne');
        go(function ()use($subOne,$waitGroup){
                \co::sleep(0.1);
                $subOne->end();
                $waitGroup->done();
        });
        //sub pointTwo,并假設失敗
        $waitGroup->add();
        $subTwo = $actionOne->appendChild('subTwo');
            go(function ()use($subTwo,$waitGroup){
                \co::sleep(1);
                $subTwo->end($subTwo::END_FAIL,['failMsg'=>'timeout']);
                $waitGroup->done();
            });
        $waitGroup->wait();
    $actionOne->end();
    //actionOne結束，進入afterAction
    $afterAction = $actionOne->next('afterAction');
    //模擬響應記錄
    \co::sleep(0.01);
    $afterAction->end($afterAction::END_SUCCESS,['log'=>'success']);
    /*
     * 從入口開始打印調用鏈
     */
    echo Point::toString($onRequest);
});
// 以上代碼等價于如下
go(function () {
    PointContext::getInstance()->createStart('onRequest')->next('actionOne')->next('afterAction');
    // 記錄請求參數，并模擬access log
    \co::sleep(0.01);
    PointContext::getInstance()->find('onRequest')->setStartArg([
        'requestArg' => 'requestArgxxxxxxxx',
        'accessLogId' => 'logIdxxxxxxxxxx'
    ])->end();
    $subOne = PointContext::getInstance()->find('actionOne')->appendChild('subOne');
    $subTwo = PointContext::getInstance()->find('actionOne')->appendChild('subTwo');
    $waitGroup = new WaitGroup();
    $waitGroup->add();
    go(function () use ($subOne, $waitGroup) {
        \co::sleep(0.1);
        $subOne->end();
        $waitGroup->done();
    });
    // sub pointTwo，并假設失敗
    $waitGroup->add();
    go(function () use ($subTwo, $waitGroup) {
        \co::sleep(1);
        $subTwo->end($subTwo::END_FAIL, ['failMsg' => 'timeout']);
        $waitGroup->done();
    });
    $waitGroup->wait();
    PointContext::getInstance()->find('actionOne')->end();
    // 模擬響應記錄
    \co::sleep(0.01);
    PointContext::getInstance()->find('afterAction')->end(Point::END_SUCCESS, ['log' => 'success']);
    /*
     * 從入口開始打印調用鏈
     */
    echo Point::toString(PointContext::getInstance()->startPoint());
});

以上代碼輸出結果：

##
PointName:onRequest
ServiceName:default
Status:success
PointId:df56bbcf-c1ce-f536-ab8f-31f243721d76
ParentId:
Depth:0
IsNext:false
Start:1625313762.7221
StartArg:{"requestArg":"requestArgxxxxxxxx","accessLogId":"logIdxxxxxxxxxx"}
End:1625313762.7352
EndArg:null
ChildCount:0
Children:None
NextPoint:
    ##
    PointName:actionOne
    ServiceName:default
    Status:success
    PointId:c341da3e-809c-5a6b-e8c6-ab8aba29e336
    ParentId:df56bbcf-c1ce-f536-ab8f-31f243721d76
    Depth:0
    IsNext:true
    Start:1625313762.7352
    StartArg:null
    End:1625313763.7381
    EndArg:null
    ChildCount:2
    Children:
        ##
        PointName:subOne
        ServiceName:default
        Status:success
        PointId:4a66dc47-8c30-a4e4-bf8d-7b1fc334ce4b
        ParentId:c341da3e-809c-5a6b-e8c6-ab8aba29e336
        Depth:1
        IsNext:false
        Start:1625313762.7354
        StartArg:null
        End:1625313762.838
        EndArg:null
        ChildCount:0
        Children:None
        NextPoint:None
        ##
        PointName:subTwo
        ServiceName:default
        Status:fail
        PointId:326ca214-155b-d9f9-ad7a-8d8cbd479cdf
        ParentId:c341da3e-809c-5a6b-e8c6-ab8aba29e336
        Depth:1
        IsNext:false
        Start:1625313762.7355
        StartArg:null
        End:1625313763.7381
        EndArg:{"failMsg":"timeout"}
        ChildCount:0
        Children:None
        NextPoint:None
    NextPoint:
        ##
        PointName:afterAction
        ServiceName:default
        Status:success
        PointId:2f6d29b9-a100-fc69-2f64-f51a28a870eb
        ParentId:c341da3e-809c-5a6b-e8c6-ab8aba29e336
        Depth:0
        IsNext:true
        Start:1625313763.7382
        StartArg:null
        End:1625313763.7502
        EndArg:{"log":"success"}
        ChildCount:0
        Children:None
        NextPoint:None

如果想以自己的格式記錄到數據庫，可以具體查看 Point 實現的方法，每個 Point 都有自己的 Id。

進階使用

HTTP API 請求追蹤

在 EasySwoole 全局事件（即項目根目錄的 EasySwooleEvent.php）中注冊 Tracker。

在 EasySwoole 3.4.x 中注冊示例代碼如下：

<?php
/**
 * This file is part of EasySwoole.
 *
 * @link http://www.jrrswxmm.cn
 * @document http://www.jrrswxmm.cn
 * @contact http://www.jrrswxmm.cn/Preface/contact.html
 * @license https://github.com/easy-swoole/easyswoole/blob/3.x/LICENSE
 */

namespace EasySwoole\EasySwoole;

use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\EasySwoole\Swoole\EventRegister;

class EasySwooleEvent implements Event
{
    public static function initialize()
    {
        date_default_timezone_set('Asia/Shanghai');

        \EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::HTTP_GLOBAL_ON_REQUEST, function (\EasySwoole\Http\Request $request, \EasySwoole\Http\Response $response): bool {
            $point = \EasySwoole\Tracker\PointContext::getInstance()->createStart('onRequest');
            $point->setStartArg([
                'uri' => $request->getUri()->__toString(),
                'get' => $request->getQueryParams()
            ]);
            return true;
        });

        \EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::HTTP_GLOBAL_AFTER_REQUEST, function (\EasySwoole\Http\Request $request, \EasySwoole\Http\Response $response): void {
            $point = \EasySwoole\Tracker\PointContext::getInstance()->startPoint();
            $point->end();
            echo \EasySwoole\Tracker\Point::toString($point);
            $array = \EasySwoole\Tracker\Point::toArray($point);
        });
    }

    public static function mainServerCreate(EventRegister $register)
    {

    }
}

如果 EasySwoole 框架版本低于 3.4.x時，請使用如下方式進行注冊：

<?php
/**
 * This file is part of EasySwoole.
 *
 * @link http://www.jrrswxmm.cn
 * @document http://www.jrrswxmm.cn
 * @contact http://www.jrrswxmm.cn/Preface/contact.html
 * @license https://github.com/easy-swoole/easyswoole/blob/3.x/LICENSE
 */

namespace EasySwoole\EasySwoole;

use EasySwoole\EasySwoole\Swoole\EventRegister;
use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\Http\Request;
use EasySwoole\Http\Response;

class EasySwooleEvent implements Event
{
    public static function initialize()
    {
        // TODO: Implement initialize() method.
        date_default_timezone_set('Asia/Shanghai');
    }

    public static function mainServerCreate(EventRegister $register)
    {

    }

    public static function onRequest(Request $request, Response $response): bool
    {
        $point = \EasySwoole\Tracker\PointContext::getInstance()->createStart('onRequest');
        $point->setStartArg([
            'uri'=>$request->getUri()->__toString(),
            'get'=>$request->getQueryParams()
        ]);
        return true;
    }

    public static function afterRequest(Request $request, Response $response): void
    {
        $point = \EasySwoole\Tracker\PointContext::getInstance()->startPoint();
        $point->end();
        echo \EasySwoole\Tracker\Point::toString($point);
        $array = \EasySwoole\Tracker\Point::toArray($point);
    }
}

在 App\HttpController\Index.php 中：

<?php
/**
 * This file is part of EasySwoole.
 *
 * @link http://www.jrrswxmm.cn
 * @document http://www.jrrswxmm.cn
 * @contact http://www.jrrswxmm.cn/Preface/contact.html
 * @license https://github.com/easy-swoole/easyswoole/blob/3.x/LICENSE
 */

namespace App\HttpController;

use EasySwoole\Component\WaitGroup;
use EasySwoole\Http\AbstractInterface\Controller;
use EasySwoole\Tracker\PointContext;

class Index extends Controller
{
    protected function onRequest(?string $action): ?bool
    {
        /*
         * 調用關系  HttpRequest->OnRequest
         */
        $point = PointContext::getInstance()->next('ControllerOnRequest');
        // 假設這里進行了權限驗證，并模擬數據庫耗時
        \co::sleep(0.01);
        $point->setEndArg([
            'userId'=>'xxxxxxxxxxx'
        ]);
        $point->end();
        return true;
    }

    function index()
    {
        // 模擬調用第三方Api，調用關系  OnRequest->sub(subApi1,subApi2)
        $actionPoint = PointContext::getInstance()->next('indexAction');
        $wait = new WaitGroup();
        $subApi = $actionPoint->appendChild('subOne');
        $wait->add();
        go(function ()use($wait,$subApi){
            \co::sleep(1);
            $subApi->end();
            $wait->done();
        });

        $subApi = $actionPoint->appendChild('subTwo');
        $wait->add();
        go(function ()use($wait,$subApi){
            \co::sleep(0.3);
            $subApi->end($subApi::END_FAIL);
            $wait->done();
        });

        $wait->wait();

        $actionPoint->end();
        $this->response()->write('hello world');
    }
}

以上每次請求會輸出如下格式：

##
PointName:onRequest
ServiceName:default
Status:success
PointId:2ea751d4-13a7-8a27-932e-6671da6d6586
ParentId:
Depth:0
IsNext:false
Start:1625315058.3513
StartArg:{"uri":"http://192.168.1.107:9501/","get":[]}
End:1625315059.3694
EndArg:null
ChildCount:0
Children:None
NextPoint:
    ##
    PointName:ControllerOnRequest
    ServiceName:default
    Status:success
    PointId:13a0ccda-18ef-c90c-d9db-6e3a1cc70511
    ParentId:2ea751d4-13a7-8a27-932e-6671da6d6586
    Depth:0
    IsNext:true
    Start:1625315058.3535
    StartArg:null
    End:1625315058.3656
    EndArg:{"userId":"xxxxxxxxxxx"}
    ChildCount:0
    Children:None
    NextPoint:
        ##
        PointName:indexAction
        ServiceName:default
        Status:success
        PointId:a0295b8f-c02c-7ef3-afae-da5dce2764d0
        ParentId:13a0ccda-18ef-c90c-d9db-6e3a1cc70511
        Depth:0
        IsNext:true
        Start:1625315058.3656
        StartArg:null
        End:1625315059.3694
        EndArg:null
        ChildCount:2
        Children:
            ##
            PointName:subOne
            ServiceName:default
            Status:success
            PointId:d06855e1-0571-c829-121e-3467f7309598
            ParentId:a0295b8f-c02c-7ef3-afae-da5dce2764d0
            Depth:1
            IsNext:false
            Start:1625315058.3658
            StartArg:null
            End:1625315059.3694
            EndArg:null
            ChildCount:0
            Children:None
            NextPoint:None
            ##
            PointName:subTwo
            ServiceName:default
            Status:fail
            PointId:b47b32d6-f96f-9a00-1244-e16faab3d790
            ParentId:a0295b8f-c02c-7ef3-afae-da5dce2764d0
            Depth:1
            IsNext:false
            Start:1625315058.3658
            StartArg:null
            End:1625315058.6685
            EndArg:null
            ChildCount:0
            Children:None
            NextPoint:None
        NextPoint:None

Api 調用鏈記錄

$array = \EasySwoole\Tracker\Point::toArray($point);

可以把一個入口點轉為一個數組。例如我們可以在 MYSQL 數據庫中存儲以下關鍵結構：

CREATE TABLE `api_tracker_point_list` (
  `pointd` varchar(18) NOT NULL,
  `pointName` varchar(45) DEFAULT NULL,
  `parentId` varchar(18) DEFAULT NULL,
  `depth` int(11) NOT NULL DEFAULT '0',
  `isNext` int(11) NOT NULL DEFAULT '0',
  `startTime` varchar(14) NOT NULL,
  `endTime` varchar(14) DEFAULT NULL,
  `status` varchar(10) NOT NULL,
  PRIMARY KEY (`pointd`),
  UNIQUE KEY `trackerId_UNIQUE` (`pointd`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

其余請求參數可以自己記錄。

核心字段在 pointId、parentId、isNext、status 這四個字段，例如，我想得到哪次調用鏈超時，那么就是直接

where status = fail

如果想看哪次調用耗時多少，那么可以

where spendTime > 3

spendTime 是通過 startTime 和 endTime 計算得出

相關知識鏈接

EasySwoole 之鏈路追蹤 簡單demo

主站蜘蛛池模板： 免费啪啪网站 | 久久九九国产 | 成人免费视频在线观看 | 成人理论片 | 成人午夜精品一区二区三区 | 国产99精品 | 日韩和欧美的一区二区 | 日韩有码在线视频 | 免费 成 人 黄 色 | 成人精品在线观看 | av久草| 激情综合在线 | 久久久亚洲精品视频 | 北条麻妃在线一区二区三区 | 麻豆一区 | 高清一区二区在线观看 | 国产又色又爽又黄 | 性色网| 26uuu成人免费毛片 | 午夜天 | 午夜私人影院 | 久久国产一区二区 | 久久亚洲国产精品 | 高清视频一区二区三区 | 久久久免费 | 欧美一级免费 | 青青草原亚洲 | 国产精品99久久久久久宅男 | 精品天堂| 国产91短视频 | 一区二区在线影院 | 日韩精品一区二区三区免费视频 | 日韩精品一区二区三区中文 | 黄色小视频免费 | 亚洲视频中文字幕 | 日韩免费视频 | 亚洲成人高清 | 国产精品免费观看 | 影音先锋男人网 | 色在线免费 | 久精品视频 |