tinywan/think-arms

ThinkPHP 6.0 arms plugin

v1.2.0 2023-07-11 03:17 UTC

Requires

• php: >=7.4
• ext-json: *
• openzipkin/zipkin: >=3.0

Requires (Dev)

• friendsofphp/php-cs-fixer: ^3.6
• phpstan/phpstan: ^1.4
• topthink/framework: ^6.0

MIT

README

ARMS 阿里云应用监控链路追踪 library for ThinkPHP6.0 plugin library

安装

composer require tinywan/think-arms

配置

发布配置

php think tinywan:arms

这将自动生成 config/arms.php 配置文件。

配置中间件

全局中间件在app目录下面middleware.php文件中定义，使用下面的方式：

return [
	\tinywan\middleware\ArmsMiddleware::class,
];

全局路由中间件config/route.php文件中定义，使用下面的方式：

return [
    // 路由中间件全局执行
    'middleware'     => [
        \tinywan\middleware\ArmsMiddleware::class
    ]
];

使用案例

GuzzleHttp\Client

public function requestHandle(string $method, string $uri, array $body = [], array $header = [])
{
    $config = self::_appConfig();
    if (empty($config)) {
        return self::setError(false, '请先在创培服务中心，开通站点配置');
    }

    $client = new Client(['base_uri' => $config['app_base_uri']]);
    try {
        $options = ['json' => $body];
        $tracingHeader = [];
        /* Injects the context into the wire */
        $injector = request()->tracing->getPropagation()->getInjector(new \Zipkin\Propagation\Map());
        $injector(request()->childSpan->getContext(), $tracingHeader);
        $headers = array_merge($tracingHeader, $header);
        if ($uri !== '/oauth/token') {
            $_accessToken = self::_issueAccessToken($config);
            if (false === $_accessToken) {
                return self::setError(false, self::getMessage());
            }
            $headers = array_merge(['Authorization' => 'Bearer ' . $_accessToken], $headers);
        }
        $options = array_merge(['headers' => $headers], $options);
        /* Creates the span for getting Ucenter */
        request()->zipKin->addChildSpan('ucenter:'.$uri, [
            'uri' => $uri,
            'method' => $method,
            'headers' => json_encode($headers),
            'body' => json_encode($body),
        ]);
        /* HTTP Request to the Ucenter */
        request()->childSpan->annotate('request.started', now());
        $resp = $client->request($method, $uri, $options);
    } catch (RequestException | GuzzleException $e) {
        if ($e->hasResponse()) {
            if (200 != $e->getResponse()->getStatusCode()) {
                $jsonStr = $e->getResponse()->getBody()->getContents();
                $content = json_decode($jsonStr, true);
                return self::setError(false, '温馨提示：' . $content['msg'] ?? '未知的错误信息');
            }
        }
        return self::setError(false, '系统中心提示：' . $e->getMessage());
    }
    request()->childSpan->annotate('request.finished', now());
    request()->childSpan->finish();
    request()->zipKin->endRootSpan();
    $jsonStr = $resp->getBody()->getContents();
    $data = json_decode($jsonStr, true);
    if (!isset($data['code']) || 0 != $data['code']) {
        return self::setError(false, $data['msg'] ?? '响应数据结构异常');
    }
    return $data;
}