Parlons de la façon d'accéder à Workman dans Laravel-Workerman-php.cn

Parlons de la façon d'accéder à Workman dans Laravel

青灯夜游

Libérer： 2022-12-07 19:21:43

avant

2045 Les gens l'ont consulté

laravel+websocket est un outil essentiel pour le développement de messagerie instantanée, alors comment accéder à workerman dans Laravel ? L'article suivant vous expliquera comment accéder rapidement à Websocket dans Laravel. J'espère qu'il vous sera utile.

Parlons de la façon d'accéder à Workman dans Laravel

Avant-propos : Ici, nous utilisons GatewayWorker développé sur la base de Workererman comme composant principal de socket, car Workererman est une bibliothèque de classes de socket pure, qui est de niveau inférieur à GatewayWorker et nécessite plus de connaissances de la part des développeurs en matière de programmation de processus. et la plupart de nos développeurs utilisent Workerman pour la messagerie instantanée, les jeux, etc., qui est directement développé sur la base de Gateway Worker, qui est plus rapide et plus puissant.

1. Installez gateway-worker

composer require workerman/gateway-worker -vvv

Copier après la connexion

2. Créez un fichier de démarrage Workerman

Utilisez la commande suivante pour créer un fichier de ligne de commande sous AppConsoleCommands et copiez le code ci-dessous dans le fichier. [Recommandations associées : "workerman Tutorial"]

php artisan make:command WorkermanCommand

Copier après la connexion

<?php
 
namespace App\Console\Commands;
 
use GatewayWorker\BusinessWorker;
use GatewayWorker\Gateway;
use GatewayWorker\Register;
use Illuminate\Console\Command;
use Workerman\Worker;
 
class WorkermanCommand extends Command
{
 
    protected $signature = &#39;workman {action} {--d}&#39;; //执行该命令的方式
 
    protected $description = &#39;Start a Workerman server.&#39;;
 
    public function handle()
    {
        global $argv;
        $action = $this->argument(&#39;action&#39;);
 
        $argv[0] = &#39;wk&#39;;
        $argv[1] = $action;
        $argv[2] = $this->option(&#39;d&#39;) ? &#39;-d&#39; : &#39;&#39;; 
      // -d守护模式，不会因为关闭系统命令页面而被杀掉进程。 没有-d则关闭命令页面直接退出进程
 
        $this->start();
    }
 
    private function start()
    {
        $this->startGateWay();
        $this->startBusinessWorker();
        $this->startRegister();
        Worker::runAll();
    }
 
    private function startBusinessWorker()
    {
        $worker                  = new BusinessWorker();
        $worker->name            = &#39;BusinessWorker&#39;;
        $worker->count           = 1;
        $worker->registerAddress = &#39;127.0.0.1:1236&#39;;
        $worker->eventHandler    = \App\Events::class; //用作监听事件的文件
    }
 
    private function startGateWay()
    {
//因为小程序等一些平台，要求使用wss进行socket,所以，这里需要配置下wss
//此处的cert.pem和key.key是域名的证书文件
       $content = array(
            &#39;ssl&#39; => array(
                &#39;local_cert&#39; => public_path(&#39;cert.pem&#39;),
                &#39;local_pk&#39; => public_path(&#39;key.key&#39;),
                &#39;verify_peer&#39; => false
            )
        );
        $gateway = new Gateway("websocket://0.0.0.0:2346", $content);
        //如果不需要wss，则不用加入content这个参数
        $gateway->transport = &#39;ssl&#39;;//不需要wss，也不用加入这个参数。
        $gateway->name                 = &#39;Gateway&#39;;
        $gateway->count                = 1;
        $gateway->lanIp                = &#39;127.0.0.1&#39;;
        $gateway->startPort            = 2300;
        $gateway->pingInterval         = 30;
        $gateway->pingNotResponseLimit = 0;
         $data = array(
            &#39;type&#39; => &#39;heart&#39;
        );
        $gateway->pingData = json_encode($data, true);
        $gateway->registerAddress      = &#39;127.0.0.1:1236&#39;;
    }
 
    private function startRegister()
    {
        new Register(&#39;text://0.0.0.0:1236&#39;);
    }
}

Copier après la connexion

3. Créer des événements d'écoute

Créez un fichier app/Events.php pour écouter et traiter divers événements Workman

<?php
 
namespace App\Workerman;
 
class Events
{
 
    public static function onWorkerStart($businessWorker)
    {
    }
 
    public static function onConnect($client_id)
    {
    }
 
    public static function onWebSocketConnect($client_id, $data)
    {
    }
 
    public static function onMessage($client_id, $message)
    {
    }
 
    public static function onClose($client_id)
    {
    }
}

Copier après la connexion