123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209 |
- <?php
- namespace App\Console\Commands;
- use App\Components\Helpers;
- use Illuminate\Console\Command;
- use App\Components\ServerChan;
- use App\Http\Models\SsNode;
- use App\Http\Models\SsNodeInfo;
- use App\Mail\nodeCrashWarning;
- use Cache;
- use Mail;
- use Log;
- class AutoCheckNodeTCP extends Command
- {
- protected $signature = 'autoCheckNodeTCP';
- protected $description = '自动检测节点是否被TCP阻断';
- protected static $systemConfig;
- public function __construct()
- {
- parent::__construct();
- self::$systemConfig = Helpers::systemConfig();
- }
- public function handle()
- {
- $jobStartTime = microtime(true);
- if (self::$systemConfig['is_tcp_check']) {
- if (!Cache::has('tcp_check_time')) {
- $this->checkNodes();
- } elseif (Cache::get('tcp_check_time') <= time()) {
- $this->checkNodes();
- } else {
- Log::info('下次节点TCP阻断检测时间:' . date('Y-m-d H:i:s', Cache::get('tcp_check_time')));
- }
- }
- $jobEndTime = microtime(true);
- $jobUsedTime = round(($jobEndTime - $jobStartTime), 4);
- Log::info('执行定时任务【' . $this->description . '】,耗时' . $jobUsedTime . '秒');
- }
- // 监测节点状态
- private function checkNodes()
- {
- $title = "节点异常警告";
- $nodeList = SsNode::query()->where('is_transit', 0)->where('is_nat', 0)->where('status', 1)->where('is_tcp_check', 1)->get();
- foreach ($nodeList as $node) {
- $tcpCheck = $this->tcpCheck($node->ip);
- if (false !== $tcpCheck) {
- switch ($tcpCheck) {
- case 1:
- $text = '服务器宕机';
- break;
- case 2:
- $text = '海外不通';
- break;
- case 3:
- $text = 'TCP阻断';
- break;
- case 0:
- default:
- $text = '正常';
- }
- // 异常才发通知消息
- if ($tcpCheck) {
- if (self::$systemConfig['tcp_check_warning_times']) {
- // 已通知次数
- $cacheKey = 'tcp_check_warning_times_' . $node->id;
- if (Cache::has($cacheKey)) {
- $times = Cache::get($cacheKey);
- } else {
- Cache::put($cacheKey, 1, 725); // 最多设置提醒12次,12*60=720分钟缓存时效,多5分钟防止异常
- $times = 1;
- }
- if ($times < self::$systemConfig['tcp_check_warning_times']) {
- Cache::increment($cacheKey);
- $this->notifyMaster($title, "节点**{$node->name}【{$node->ip}】**:**" . $text . "**", $node->name, $node->server);
- } elseif ($times >= self::$systemConfig['tcp_check_warning_times']) {
- Cache::forget($cacheKey);
- SsNode::query()->where('id', $node->id)->update(['status' => 0]);
- $this->notifyMaster($title, "节点**{$node->name}【{$node->ip}】**:**" . $text . "**,节点自动进入维护状态", $node->name, $node->server);
- }
- } else {
- $this->notifyMaster($title, "节点**{$node->name}【{$node->ip}】**:**" . $text . "**", $node->name, $node->server);
- }
- }
- Log::info("【TCP阻断检测】" . $node->name . ' - ' . $node->ip . ' - ' . $text);
- }
- }
- // 随机生成下次检测时间
- $nextCheckTime = time() + mt_rand(1800, 3600);
- Cache::put('tcp_check_time', $nextCheckTime, 60);
- }
- /**
- * 用ipcheck.need.sh进行TCP阻断检测
- *
- * @param string $ip 被检测的IP
- *
- * @return bool|int
- */
- private function tcpCheck($ip)
- {
- try {
- $url = 'https://ipcheck.need.sh/api_v2.php?ip=' . $ip;
- $ret = $this->curlRequest($url);
- $ret = json_decode($ret);
- if (!$ret || $ret->result != 'success') {
- Log::warning("【TCP阻断检测】检测" . $ip . "时,接口返回异常");
- return false;
- }
- } catch (\Exception $e) {
- Log::warning("【TCP阻断检测】检测" . $ip . "时,接口请求超时");
- return false;
- }
- if (!$ret->data->inside_gfw->tcp->alive && !$ret->data->outside_gfw->tcp->alive) {
- return 1; // 服务器宕机或者检测接口挂了
- } elseif ($ret->data->inside_gfw->tcp->alive && !$ret->data->outside_gfw->tcp->alive) {
- return 2; // 国外访问异常
- } elseif (!$ret->data->inside_gfw->tcp->alive && $ret->data->outside_gfw->tcp->alive) {
- return 3; // 被墙
- } else {
- return 0; // 正常
- }
- }
- /**
- * 通知管理员
- *
- * @param string $title 消息标题
- * @param string $content 消息内容
- * @param string $nodeName 节点名称
- * @param string $nodeServer 节点域名
- *
- * @throws \GuzzleHttp\Exception\GuzzleException
- */
- private function notifyMaster($title, $content, $nodeName, $nodeServer)
- {
- $this->notifyMasterByEmail($title, $content, $nodeName, $nodeServer);
- ServerChan::send($title, $content);
- }
- /**
- * 发邮件通知管理员
- *
- * @param string $title 消息标题
- * @param string $content 消息内容
- * @param string $nodeName 节点名称
- * @param string $nodeServer 节点域名
- */
- private function notifyMasterByEmail($title, $content, $nodeName, $nodeServer)
- {
- if (self::$systemConfig['crash_warning_email']) {
- $logId = Helpers::addEmailLog(self::$systemConfig['crash_warning_email'], $title, $content);
- Mail::to(self::$systemConfig['crash_warning_email'])->send(new nodeCrashWarning($logId, $nodeName, $nodeServer));
- }
- }
- /**
- * 发起一个CURL请求
- *
- * @param string $url 请求地址
- * @param array $data POST数据,留空则为GET
- *
- * @return mixed
- */
- private function curlRequest($url, $data = [])
- {
- $data = json_encode($data, JSON_UNESCAPED_UNICODE);
- $ch = curl_init();
- curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
- curl_setopt($ch, CURLOPT_TIMEOUT, 10);
- curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
- curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
- curl_setopt($ch, CURLOPT_URL, $url);
- // curl_setopt($ch, CURLOPT_HTTPHEADER, [
- // 'Accept: application/json', // 请求报头
- // 'Content-Type: application/json', // 实体报头
- // 'Content-Length: ' . strlen($data)
- // ]);
- // 如果data有数据,则用POST请求
- if ($data) {
- curl_setopt($ch, CURLOPT_POST, 1);
- curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
- }
- $result = curl_exec($ch);
- curl_close($ch);
- return $result;
- }
- }
|