本项目属于swoft的jaeger client,非侵入式地对项目环境进行跟踪并且异步上报到jaeger server,可以和其他的swoft项目或者其他语言(java,go)进行全链路监控,能监控mysql
,redis
,httpClient
的正常异常情况。并且上传是使用thrift
,udp 上传,效率较高。
目前新版本(v0.0.0.7以上)支持log记录,不使用udp,提高效率
之前我还写过zipkin的sdk,链接如下swoft-zipkin
- sockets ,因为上传需要用到udp传输,所以需要该扩展
"minimum-stability": "dev",
"prefer-stable": true,
先给composer.json添加如下语句,因为我们项目里引入的opentracing/opentracing
官方最新的也只是一个beta包,不加会导致无法引入
composer require extraswoft/jaeger
引入本项目的包
'beanScan' => [
"ExtraSwoft\\Jaeger\\",
],
'serverDispatcher' => [
'middlewares' => [
\Swoft\View\Middleware\ViewMiddleware::class,
JaegerMiddleware::class,
// \Swoft\Devtool\Middleware\DevToolMiddleware::class,
// \Swoft\Session\Middleware\SessionMiddleware::class,
]
],
#jaeger
JAEGER_RATE=1
JAEGER_SERVER_HOST=172.21.134.20:6831
JAEGER_OPEN=true
JAEGER_MODE=2
ENV=test
当我们使用swoft官方的httpClient的时候,需要使用我们客户端的adapter,挂上钩子
$client = new Client(['adapter' => new AddJaegerAdapter()]);
当然,你也可以看下我们适配器的源码放到自己的适配器里,比较简单
因为在mysql,redis和http的请求上没有钩子函数,所以我们需要自己实现,只要在请求开始和结束加上事件触发即可。建议自己或者公司项目直接fork官方的swoft-component,然后根据自己需要开发,并且隔一段时间同步最新代码,在swoft里面composer使用component这个仓库。
Log::profileStart($profileKey);
+ App::trigger('Mysql', 'start', $profileKey, $sql);
$connection->prepare($sql);
$params = self::transferParams($params);
$result = $connection->execute($params);
$this->release();
Log::profileEnd($this->profileKey);
+ App::trigger('Mysql', 'end', $this->profileKey, true);
return $result;
$connectPool = App::getPool($this->poolName);
/* @var ConnectionInterface $client */
$connection = $connectPool->getConnection();
+ App::trigger('Redis', 'start', $method, $params);
$result = $connection->$method(...$params);
$connection->release(true);
+ App::trigger('Redis', 'end', true);
return $result;
if ($query !== '') $path .= '?' . $query;
$client->setDefer();
+ App::trigger('HttpClient', 'start', $request, $options);
$client->execute($path);
App::profileEnd($profileKey);
$response = $this->createResponse()
->withBody(new SwooleStream($result ?? ''))
->withHeaders($headers ?? [])
->withStatus($this->deduceStatusCode($client));
App::trigger('HttpClient', 'end', $response);
return $response;
在全局的SwoftExceptionHandler.php
里面添加对MysqlException
和RedisException
异常的钩子,保证我们能把异常的情况也上报了
else if ($throwable instanceof MysqlException) {
App::trigger('Mysql', 'end', 'all', false, $throwable->getMessage());
} else if ($throwable instanceof RedisException) {
App::trigger('Redis', 'end' , false, $throwable->getMessage());
}
新版本支持将数据写入log,但由于原生字符串包含换行符,导致写入日志变成多行而不是一行,所以在写入日志时 会特殊处理, 变为: 'jaegerMsg:' . urlencode($thriftFile) . "\n"
因为链路传递是通过header来服务的,所以项目里面当有特殊的client时,想要获取header来传递可以使用下面方法
\Swoft::getBean(TracerManager::class)->getHeader();
我把我的搭建心得都放在了下面这篇文章里面了 全链路监控Jaeger搭建实战
但是如果你懒得看,也可以直接用下面的
docker run -d -e COLLECTOR_ZIPKIN_HTTP_PORT=9411 -p5775:5775/udp -p6831:6831/udp -p6832:6832/udp \
-p5778:5778 -p16686:16686 -p14268:14268 -p9411:9411 jaegertracing/all-in-one:latest
直接起就搭建完成了,默认client 接受端口是6831