98 lines
2.5 KiB
PHP
98 lines
2.5 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers\Admin;
|
|
|
|
use App\Console\Commands\Cluster\Monitor;
|
|
use App\Http\Controllers\Controller;
|
|
use App\Support\ClusterSupport;
|
|
use Illuminate\Contracts\View\View;
|
|
use Illuminate\Http\JsonResponse;
|
|
use Illuminate\Http\RedirectResponse;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\Artisan;
|
|
use Symfony\Component\HttpFoundation\StreamedResponse;
|
|
|
|
class NodeController extends Controller
|
|
{
|
|
/**
|
|
* Display a listing of the resource.
|
|
*/
|
|
public function index(): View
|
|
{
|
|
$nodes = ClusterSupport::nodes();
|
|
|
|
return view('admin.cluster.nodes', compact('nodes'));
|
|
}
|
|
|
|
/**
|
|
* Update the specified resource in storage.
|
|
*/
|
|
public function update(Request $request, string $node): JsonResponse
|
|
{
|
|
$request->validate([
|
|
'weight' => 'sometimes|integer|min:0|max:100',
|
|
]);
|
|
|
|
ClusterSupport::update($node, [
|
|
'weight' => $request->input('weight'),
|
|
]);
|
|
|
|
return $this->success('Updated');
|
|
}
|
|
|
|
public function event(Request $request): RedirectResponse
|
|
{
|
|
$request->validate([
|
|
'restart' => 'nullable|string|max:10|in:web,queue',
|
|
]);
|
|
|
|
if ($service = $request->input('restart')) {
|
|
if ($service === 'web') {
|
|
ClusterSupport::publish('cluster.restart.'.$service);
|
|
} elseif ($service === 'queue') {
|
|
Artisan::call('queue:restart');
|
|
}
|
|
}
|
|
|
|
return back()->with('success', '已经向集群广播命令。');
|
|
}
|
|
|
|
public function stream(): StreamedResponse
|
|
{
|
|
$response = new StreamedResponse(function () {
|
|
ClusterSupport::publish('monitor.started');
|
|
|
|
ClusterSupport::listen('*', function ($event, $message) {
|
|
$monitor = new Monitor();
|
|
if (connection_aborted()) {
|
|
return;
|
|
}
|
|
|
|
$msg = $monitor->format($event, $message, false);
|
|
|
|
echo 'data: '.$msg."\n\n";
|
|
|
|
ob_flush();
|
|
flush();
|
|
}, false);
|
|
});
|
|
|
|
$response->headers->set('Content-Type', 'text/event-stream');
|
|
$response->headers->set('X-Accel-Buffering', 'no');
|
|
$response->headers->set('Cache-Control', 'no-cache');
|
|
|
|
return $response;
|
|
}
|
|
|
|
// /**
|
|
// * Remove the specified resource from storage.
|
|
// *
|
|
// * @param int $id
|
|
// * @return Response
|
|
// */
|
|
// public function destroy($id)
|
|
// {
|
|
// //
|
|
// }
|
|
}
|