問題描述

情況是這樣的，我希望通過某些控制器發(fā)送消息到用戶，然后我就用gateway創(chuàng)建了一個(gè)websocket，然后前臺(tái)連接這個(gè)websockt，然后我希望是能后臺(tái)點(diǎn)擊一個(gè)按鈕就發(fā)送消息到用戶？

<?php

namespace App\Console\Commands;

require_once __DIR__ . '/../../../vendor/autoload.php';

use App\Http\Controllers\Admin\EventsController;
use Illuminate\Console\Command;
use GatewayWorker\BusinessWorker;
use Workerman\Worker;
use GatewayWorker\Gateway;
use GatewayWorker\Register;

class GatewayWorkerServer extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'workerman
                            {action : action}
                            {--start=all : start}
                            {--d : daemon mode}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Start a Workerman server.';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle() {
        global $argv;
        $action = $this->argument('action');
        /**
         * 針對(duì) Windows 一次執(zhí)行，無(wú)法注冊(cè)多個(gè)協(xié)議的特殊處理
         */
        if ($action === 'single') {
            $start = $this->option('start');
            if ($start === 'register') {
                $this->startRegister();
            } elseif ($start === 'gateway') {
                $this->startGateWay();
            } elseif ($start === 'worker') {
                $this->startBusinessWorker();
            }
            if(!defined('GLOBAL_START')) {
                Worker::runAll();
            }
            return;
        }
        /**
         * argv[0] 默認(rèn)是，當(dāng)前文件，可以不修改
         */
        $argv[1] = $action;
        // 控制是否進(jìn)入 daemon 模式
        $argv[2] = $this->option('d') ? '-d' : '';
        $this->start();
    }
    private function start()
    {
        $this->startGateWay();
        $this->startBusinessWorker();
        $this->startRegister();
        if(!defined('GLOBAL_START')) {
            Worker::runAll();
        }
    }
    private function startBusinessWorker()
    {
        $worker                  = new BusinessWorker();
        $worker->name            = 'BusinessWorker';
        $worker->count           = 1;
        $worker->registerAddress = '127.0.0.1:8034';
        $worker->eventHandler    = EventsController::class;
    }
    private function startGateWay()
    {
        $gateway = new Gateway("websocket://0.0.0.0:8035");
        $gateway->name                 = 'Gateway';
        $gateway->count                = 1;
        $gateway->lanIp                = '127.0.0.1';
        $gateway->startPort            = 3000;
        $gateway->pingInterval         = 30;
        $gateway->pingNotResponseLimit = 0;
        $gateway->pingData             = '{"type":"ping"}';
        $gateway->registerAddress      = '127.0.0.1:8034';
    }
    private function startRegister()
    {
        new Register('text://0.0.0.0:8034');
    }
}

我啟動(dòng)8035，websocket端口，然后我系統(tǒng)請(qǐng)求某個(gè)接口時(shí)候能發(fā)送消息到用戶？