neiyou_user_web/app/Jobs/VNet/reloadNode.php

<?php

namespace App\Jobs\VNet;

use GuzzleHttp\Client;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Log;

class reloadNode implements ShouldQueue
{

    use Dispatchable;
    use InteractsWithQueue;
    use Queueable;
    use SerializesModels;

    private $nodes;

    public function __construct($nodes)
    {
        $this->nodes = $nodes;
    }

    public function handle(): bool
    {
        $allSuccess = true;
        foreach ($this->nodes as $node) {
            $ret = $this->send(
                ($node->server ?: $node->ip) . ':' . $node->push_port,
                $node->auth->secret,
                [
                    'id'             => $node->id,
                    'port'           => (string)$node->port,
                    'passwd'         => $node->passwd ?: '',
                    'method'         => $node->method,
                    'protocol'       => $node->protocol,
                    'obfs'           => $node->obfs,
                    'protocol_param' => $node->protocol_param,
                    'obfs_param'     => $node->obfs_param ?: '',
                    'push_port'      => $node->push_port,
                    'single'         => $node->single,
                    'secret'         => $node->auth->secret,
                    //			'is_udp'         => $node->is_udp,
                    //			'speed_limit'    => $node->speed_limit,
                    //			'client_limit'   => $node->client_limit,
                    //			'redirect_url'   => (string) sysConfig('redirect_url')
                ]
            );

            if ( ! $ret) {
                $allSuccess = false;
            }
        }

        return $allSuccess;
    }

    public function send($host, $secret, $data): bool
    {
        $client = new Client(
            [
                'base_uri' => $host,
                'timeout'  => 15,
                'headers'  => ['secret' => $secret],
            ]
        );

        $ret = $client->post('api/v2/node/reload', ['json' => $data]);
        if ($ret->getStatusCode() == 200) {
            $message = json_decode($ret->getBody(), true);
            if (array_key_exists('success', $message) && array_key_exists(
                    'content',
                    $message
                )) {
                if ($message['success']) {
                    return true;
                }
                Log::error('重载节点失败：' . $host . ' 反馈：' . $message['content']);
            }
        }
        Log::error('重载节点失败url: ' . $host);

        return false;
    }

}