laravel 整合WorkerMan

我的開發環境是基於laravel官方推薦的homestead虛擬機

首先執行  composer require workerman/workerman  安裝workerman

artisan command實現

因為workerman服務啟動是基於cli命令行模式,所以我們得用laravel的artisan來實現.

創建command

php artisan make:command WorkermanHttpserver

注冊command

App\Console\Kernel.php文件添加剛才創建的command

protected $commands = [

　　Commands\WorkermanHttpServer::class

];

以下例子是創建一個簡單的httpserver.其他服務請查看官方文檔.

參考官方文檔，在WorkermanHttpServer.php 中寫如下內容：

1. <?php
3. namespace App\Console\Commands;
5. use Illuminate\Console\Command;
6. use Workerman\Worker;
7. use App;
8. class WorkermanHttpServer extends Command
9. {
10.  protected $httpserver;
11.  /**
12.  * The name and signature of the console command.
13.  *
14.  * @var string
15.  */
16.  protected $signature = 'workerman:httpserver {action} {--daemonize}';
18.  /**
19.  * The console command description.
20.  *
21.  * @var string
22.  */
23.  protected $description = 'workerman httpserver';
25.  /**
26.  * Create a new command instance.
27.  *
28.  * @return void
29.  */
30.  public function __construct()
31.  {
32.  parent::__construct();
33.  }
35.  /**
36.  * Execute the console command.
37.  *
38.  * @return mixed
39.  */
40.  public function handle()
41.  {
42.  //因為workerman需要帶參數 所以得強制修改
43.  global $argv;
44.  $action=$this->argument('action');
46.  if(!in_array($action,['start','stop'])){
47.  $this->error('Error Arguments');
48.  exit;
49.  }
51.  $argv[0]='workerman:httpserver';
52.  $argv[1]=$action;
53.  $argv[2]=$this->option('daemonize')?'-d':'';
55.  $this->httpserver=new Worker('http://0.0.0.0:8080');
57.  // App::instance('workerman:httpserver',$this->httpserver);
59.  $this->httpserver->onMessage=function($connection,$data){
60.  $connection->send('laravel workerman hello world');
61.  };
63.  Worker::runAll();
64.  }
65. }

運行command 

php artisan workerman:httpserver start

php artisan workerman:httpserver start --daemonize //常駐后台運行

 

 

 

整合gatewayworker

 

1.安裝 Gateway-worker

由於要使用客戶端點對點通訊，選擇了 workerman/gateway-worker 的擴展包，它已經引入了 workerman/workerman 。

$ composer require workerman/gateway-worker

 

2.創建 Workerman 啟動文件

創建一個 artisan 命令行工具來啟動 Socket 服務端，在 app/Console/Commands 目錄下建立命令行文件。

<?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 = 'workman {action} {--d}'; protected $description = 'Start a Workerman server.'; public function handle() { global $argv; $action = $this->argument('action'); $argv[0] = 'wk'; $argv[1] = $action; $argv[2] = $this->option('d') ? '-d' : ''; $this->start(); } private function start() { $this->startGateWay(); $this->startBusinessWorker(); $this->startRegister(); Worker::runAll(); } private function startBusinessWorker() { $worker = new BusinessWorker(); $worker->name = 'BusinessWorker'; $worker->count = 1; $worker->registerAddress = '127.0.0.1:1236'; $worker->eventHandler = \App\Workerman\Events::class; } private function startGateWay() { $gateway = new Gateway("websocket://0.0.0.0:2346"); $gateway->name = 'Gateway'; $gateway->count = 1; $gateway->lanIp = '127.0.0.1'; $gateway->startPort = 2300; $gateway->pingInterval = 30; $gateway->pingNotResponseLimit = 0; $gateway->pingData = '{"type":"@heart@"}'; $gateway->registerAddress = '127.0.0.1:1236'; } private function startRegister() { new Register('text://0.0.0.0:1236'); } }

 

3.創建事件監聽文件

創建一個 app/Workerman/Events.php 文件來監聽處理 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) { } }

 

4.啟動 Workerman 服務端

在命令行里面執行，支持的命令大概有 start|stop|restart，其中 -d 的意思是 daemon 模式。

$ php artisan workman start --d

當你看到如下結果的時候，workman已經啟動成功了。

Workerman[wk] start in DEBUG mode ----------------------- WORKERMAN ----------------------------- Workerman version:3.5.11 PHP version:7.1.11 ------------------------ WORKERS ------------------------------- user worker listen processes status root Gateway websocket://0.0.0.0:2346 1 [OK] root BusinessWorker none 1 [OK] root Register text://0.0.0.0:1236 1 [OK] ---------------------------------------------------------------- Press Ctrl+C to stop. Start success. onWorkerStart

前端代碼

<script>
    ws = new WebSocket("ws://"+document.domain+":2346");
    ws.onopen = function() {
        console.log("連接成功");

        var login_info = {
            "event":"login",
            "info":"{{auth()->id()??'游客'}}"
        };
        login_info = JSON.stringify(login_info);
        ws.send(login_info);
        console.log("{{auth()->user()?auth()->user()->name:'游客'}}" + "登錄");
    };
    ws.onmessage = function(e) {
        console.log(e);
    };

    function send() {
        var info = {
            "event":"say",
            "info":"hello world!!!"
        };
        info = JSON.stringify(info);
        ws.send(info);
    }

</script>

服務器通過gateway-worker-cli 向客戶端發送消息

\GatewayWorker\Lib\Gateway::$registerAddress = '127.0.0.1:1236';
\GatewayWorker\Lib\Gateway::sendToAll($word);