reloadNode.php 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. <?php
  2. namespace App\Jobs\VNet;
  3. use Arr;
  4. use Http;
  5. use Illuminate\Bus\Queueable;
  6. use Illuminate\Contracts\Queue\ShouldQueue;
  7. use Illuminate\Foundation\Bus\Dispatchable;
  8. use Illuminate\Queue\InteractsWithQueue;
  9. use Illuminate\Queue\SerializesModels;
  10. use Log;
  11. class reloadNode implements ShouldQueue
  12. {
  13. use Dispatchable;
  14. use InteractsWithQueue;
  15. use Queueable;
  16. use SerializesModels;
  17. private $nodes;
  18. public function __construct($nodes)
  19. {
  20. $this->nodes = $nodes;
  21. }
  22. public function handle(): bool
  23. {
  24. $allSuccess = true;
  25. foreach ($this->nodes as $node) {
  26. $ret = $this->send(($node->server ?: $node->ip).':'.$node->push_port, $node->auth->secret, [
  27. 'id' => $node->id,
  28. 'port' => (string) $node->port,
  29. 'passwd' => $node->passwd ?: '',
  30. 'method' => $node->method,
  31. 'protocol' => $node->protocol,
  32. 'obfs' => $node->obfs,
  33. 'protocol_param' => $node->protocol_param,
  34. 'obfs_param' => $node->obfs_param ?: '',
  35. 'push_port' => $node->push_port,
  36. 'single' => $node->single,
  37. 'secret' => $node->auth->secret,
  38. // 'is_udp' => $node->is_udp,
  39. // 'speed_limit' => $node->speed_limit,
  40. // 'client_limit' => $node->client_limit,
  41. // 'redirect_url' => (string) sysConfig('redirect_url')
  42. ]);
  43. if (!$ret) {
  44. $allSuccess = false;
  45. }
  46. }
  47. return $allSuccess;
  48. }
  49. public function send($host, $secret, $data): bool
  50. {
  51. $client = Http::baseUrl($host)->timeout(15)->withHeaders(['secret' => $secret]);
  52. $response = $client->post('api/v2/node/reload', $data);
  53. if ($response->ok()) {
  54. $message = $response->json();
  55. if (Arr::has($message, ['success', 'content'])) {
  56. if ($message['success']) {
  57. return true;
  58. }
  59. Log::error('重载节点失败:'.$host.' 反馈:'.$message['content']);
  60. }
  61. }
  62. Log::error('重载节点失败url: '.$host);
  63. return false;
  64. }
  65. }