Yii2结合Workerman的websocket

栏目: Html5 · 发布时间: 5年前

内容简介：创建commands/WorkermanWebSocketController.php文件创建actionIndex()函数，用来启动，代码如下修改console.php并添加如下代码

1、安装workerman

composer require workerman/workerman

2、启动workerman

创建commands/WorkermanWebSocketController.php文件

创建actionIndex()函数，用来启动，代码如下

public function actionIndex()
{
    if ('start' == $this->send) {
        try {
            $this->start($this->daemon);
        } catch (\Exception $e) {
            $this->stderr($e->getMessage() . "\n", Console::FG_RED);
        }
    } else if ('stop' == $this->send) {
        $this->stop();
    } else if ('restart' == $this->send) {
        $this->restart();
    } else if ('reload' == $this->send) {
        $this->reload();
    } else if ('status' == $this->send) {
        $this->status();
    } else if ('connections' == $this->send) {
        $this->connections();
    }
}

添加初始化模块

public function initWorker()
{
    $ip = isset($this->config['ip']) ? $this->config['ip'] : $this->ip;
    $port = isset($this->config['port']) ? $this->config['port'] : $this->port;
    $wsWorker = new Worker("websocket://{$ip}:{$port}");

    // 4 processes
    $wsWorker->count = 4;

    // Emitted when new connection come
    $wsWorker->onConnect = function ($connection) {
        echo "New connection\n";
    };

    // Emitted when data received
    $wsWorker->onMessage = function ($connection, $data) {
        // Send hello $data
        $connection->send('hello ' . $data);
    };

    // Emitted when connection closed
    $wsWorker->onClose = function ($connection) {
        echo "Connection closed\n";
    };
}

添加启动模块

/**
 * workman websocket start
 */
public function start()
{
    $this->initWorker();
    // 重置参数以匹配Worker
    global $argv;
    $argv[0] = $argv[1];
    $argv[1] = 'start';
    if ($this->daemon) {
        $argv[2] = '-d';
    }

    // Run worker
    Worker::runAll();
}

添加停止模块

/**
 * workman websocket stop
 */
public function stop()
{
    $this->initWorker();
    // 重置参数以匹配Worker
    global $argv;
    $argv[0] = $argv[1];
    $argv[1] = 'stop';
    if ($this->gracefully) {
        $argv[2] = '-g';
    }

    // Run worker
    Worker::runAll();
}

添加重启模块

/**
 * workman websocket restart
 */
public function restart()
{
    $this->initWorker();
    // 重置参数以匹配Worker
    global $argv;
    $argv[0] = $argv[1];
    $argv[1] = 'restart';
    if ($this->daemon) {
        $argv[2] = '-d';
    }

    if ($this->gracefully) {
        $argv[2] = '-g';
    }

    // Run worker
    Worker::runAll();
}

添加重载模块

/**
 * workman websocket reload
 */
public function reload()
{
    $this->initWorker();
    // 重置参数以匹配Worker
    global $argv;
    $argv[0] = $argv[1];
    $argv[1] = 'reload';
    if ($this->gracefully) {
        $argv[2] = '-g';
    }

    // Run worker
    Worker::runAll();
}

添加状态模块

/**
 * workman websocket status
 */
public function status()
{
    $this->initWorker();
    // 重置参数以匹配Worker
    global $argv;
    $argv[0] = $argv[1];
    $argv[1] = 'status';
    if ($this->daemon) {
        $argv[2] = '-d';
    }

    // Run worker
    Worker::runAll();
}

添加链接数模块

/**
 * workman websocket connections
 */
public function connections()
{
    $this->initWorker();
    // 重置参数以匹配Worker
    global $argv;
    $argv[0] = $argv[1];
    $argv[1] = 'connections';

    // Run worker
    Worker::runAll();
}

3、前端调用

<script>
  // Create WebSocket connection.
  const ws = new WebSocket('ws://{{ app.request.hostName }}:2347/'); // 这里是获取的网站的域名，测试的时候可以改为自己的本地的ip地址

  // Connection opened
  ws.addEventListener('open', function (event) {
      ws.send('Hello Server!');
  });

  // Listen for messages
  ws.addEventListener('message', function (event) {
      console.log('Message from server ', event.data);
  });

  setTimeout(function() {
    ws.send('ssssss');
  }, 10000);

</script>

4、config参数配置

修改console.php并添加如下代码

'controllerMap' => [
    'workerman-web-socket' => [
        'class' => 'app\commands\WorkermanWebSocketController',
        'config' => [
            'ip' => '127.0.0.1',
            'port' => '2346',
            'daemonize' => true,
        ],
    ],
],

5、nginx配置

为什么会用 nginx，我们正常部署上线是不可能直接使用ip的，这个户存在安全隐患，最好是绑定一个域名

server {
    charset utf-8;
    client_max_body_size 128M;

    listen 2347;

    server_name www.gowhich.com; # 这里改为自己的域名

    access_log   /xxx.workerman.access.log; # 换成自己服务器的nginx日志路径
    error_log    /xxx.workerman.error.log; # 换成自己服务器的nginx日志路径

     location / {
        proxy_pass http://127.0.0.1:2346; # 代理2346 也可以根据项目配置为自己的端口

        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header Host $host;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;

        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
    }
}

重新nginx

nginx -s relad 或者 sudo nginx -s reload

然后将第3步的代码加入自己做的视图中，如果没有问题的话，websocket启动后就能正常通讯了。

6、启动workerman websocket

// 启动
./yii workerman-web-socket -s start -d

如果没有问题的话会得到类似如下的结果

$ ./yii workerman-web-socket -s start -d
Workerman[workerman-web-socket] start in DAEMON mode
----------------------- WORKERMAN -----------------------------
Workerman version:3.5.13          PHP version:7.1.16
------------------------ WORKERS -------------------------------
user          worker        listen                      processes status
durban        none          websocket://127.0.0.1:2346   4         [OK] 
----------------------------------------------------------------
Input "php workerman-web-socket stop" to stop. Start success.

7、其他

commands/WorkermanWebSocketController.php 完整代码如下

<?php
/**
 * WorkmanWebSocket 服务相关
 */

namespace app\commands;

use Workerman\Worker;
use yii\console\Controller;
use yii\helpers\Console;

/**
 *
 * WorkermanWebSocket
 *
 * @author durban.zhang <durban.zhang@gmail.com>
 */

class WorkermanWebSocketController extends Controller
{
    public $send;
    public $daemon;
    public $gracefully;

    // 这里不需要设置，会读取配置文件中的配置
    public $config = [];
    private $ip = '127.0.0.1';
    private $port = '2346';

    public function options($actionID)
    {
        return ['send', 'daemon', 'gracefully'];
    }

    public function optionAliases()
    {
        return [
            's' => 'send',
            'd' => 'daemon',
            'g' => 'gracefully',
        ];
    }

    public function actionIndex()
    {
        if ('start' == $this->send) {
            try {
                $this->start($this->daemon);
            } catch (\Exception $e) {
                $this->stderr($e->getMessage() . "\n", Console::FG_RED);
            }
        } else if ('stop' == $this->send) {
            $this->stop();
        } else if ('restart' == $this->send) {
            $this->restart();
        } else if ('reload' == $this->send) {
            $this->reload();
        } else if ('status' == $this->send) {
            $this->status();
        } else if ('connections' == $this->send) {
            $this->connections();
        }
    }

    public function initWorker()
    {
        $ip = isset($this->config['ip']) ? $this->config['ip'] : $this->ip;
        $port = isset($this->config['port']) ? $this->config['port'] : $this->port;
        $wsWorker = new Worker("websocket://{$ip}:{$port}");

        // 4 processes
        $wsWorker->count = 4;

        // Emitted when new connection come
        $wsWorker->onConnect = function ($connection) {
            echo "New connection\n";
        };

        // Emitted when data received
        $wsWorker->onMessage = function ($connection, $data) {
            // Send hello $data
            $connection->send('dddd hello ' . $data);
        };

        // Emitted when connection closed
        $wsWorker->onClose = function ($connection) {
            echo "Connection closed\n";
        };
    }

    /**
     * workman websocket start
     */
    public function start()
    {
        $this->initWorker();
        // 重置参数以匹配Worker
        global $argv;
        $argv[0] = $argv[1];
        $argv[1] = 'start';
        if ($this->daemon) {
            $argv[2] = '-d';
        }

        // Run worker
        Worker::runAll();
    }

    /**
     * workman websocket restart
     */
    public function restart()
    {
        $this->initWorker();
        // 重置参数以匹配Worker
        global $argv;
        $argv[0] = $argv[1];
        $argv[1] = 'restart';
        if ($this->daemon) {
            $argv[2] = '-d';
        }

        if ($this->gracefully) {
            $argv[2] = '-g';
        }

        // Run worker
        Worker::runAll();
    }

    /**
     * workman websocket stop
     */
    public function stop()
    {
        $this->initWorker();
        // 重置参数以匹配Worker
        global $argv;
        $argv[0] = $argv[1];
        $argv[1] = 'stop';
        if ($this->gracefully) {
            $argv[2] = '-g';
        }

        // Run worker
        Worker::runAll();
    }

    /**
     * workman websocket reload
     */
    public function reload()
    {
        $this->initWorker();
        // 重置参数以匹配Worker
        global $argv;
        $argv[0] = $argv[1];
        $argv[1] = 'reload';
        if ($this->gracefully) {
            $argv[2] = '-g';
        }

        // Run worker
        Worker::runAll();
    }

    /**
     * workman websocket status
     */
    public function status()
    {
        $this->initWorker();
        // 重置参数以匹配Worker
        global $argv;
        $argv[0] = $argv[1];
        $argv[1] = 'status';
        if ($this->daemon) {
            $argv[2] = '-d';
        }

        // Run worker
        Worker::runAll();
    }

    /**
     * workman websocket connections
     */
    public function connections()
    {
        $this->initWorker();
        // 重置参数以匹配Worker
        global $argv;
        $argv[0] = $argv[1];
        $argv[1] = 'connections';

        // Run worker
        Worker::runAll();
    }
}

workerman websocket支持的其他命令

重启

$ ./yii workerman-web-socket -s restart -d
Workerman[workerman-web-socket] restart 
Workerman[workerman-web-socket] is stopping ...
Workerman[workerman-web-socket] stop success
----------------------- WORKERMAN -----------------------------
Workerman version:3.5.13          PHP version:7.1.16
------------------------ WORKERS -------------------------------
user          worker        listen                      processes status
durban        none          websocket://127.0.0.1:2346   4         [OK] 
----------------------------------------------------------------
Input "php workerman-web-socket stop" to stop. Start success.

重载

$ ./yii workerman-web-socket -s reload   
Workerman[workerman-web-socket] reload

状态

$ ./yii workerman-web-socket -s status -g
Workerman[workerman-web-socket] status 
----------------------------------------------GLOBAL STATUS----------------------------------------------------
Workerman version:3.5.13          PHP version:7.1.16
start time:2018-09-10 11:22:15   run 0 days 0 hours   
load average: 1.79, 2, 2         event-loop:\Workerman\Events\Swoole
1 workers       4 processes
worker_name  exit_status      exit_count
none         0                12
----------------------------------------------PROCESS STATUS---------------------------------------------------
pid    memory  listening                  worker_name  connections send_fail timers  total_request qps    status
8283    4M      websocket://127.0.0.1:2346 none         0           0         0       0             0      [idle]
8284    4M      websocket://127.0.0.1:2346 none         0           0         0       0             0      [idle]
8285    4M      websocket://127.0.0.1:2346 none         0           0         0       0             0      [idle]
8286    4M      websocket://127.0.0.1:2346 none         0           0         0       0             0      [idle]
----------------------------------------------PROCESS STATUS---------------------------------------------------
Summary    16M     -                          -            0           0         0       0             0      [Summary]

连接数

 ./yii workerman-web-socket -s connections
Workerman[workerman-web-socket] connections 
--------------------------------------------------------------------- WORKERMAN CONNECTION STATUS --------------------------------------------------------------------------------
PID      Worker          CID       Trans   Protocol        ipv4   ipv6   Recv-Q       Send-Q       Bytes-R      Bytes-W       Status         Local Address          Foreign Address

我这里暂时连接的，所以没有连接的信息

停止

$ ./yii workerman-web-socket -s stop          
Workerman[workerman-web-socket] stop 
Workerman[workerman-web-socket] is stopping ...
Workerman[workerman-web-socket] stop success

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

六度分隔

邓肯·J·瓦茨 / 陈禹 / 中国人民大学出版社 / 2011-3 / 46.00元

正如副标题所表明的，《六度分隔:一个相互连接的时代的科学》的基本内容是介绍一门正在形成中的新科学——关于网络的一般规律的科学。有这样一门科学吗？它的内容和方法是什么？近年来，这门学科有什么实质性的进展吗？在《六度分隔:一个相互连接的时代的科学》中，作者根据自己的亲身经历娓娓道来，用讲故事的方式，对于这些问题给出了令人信服的回答除了简要的背景和总结以外，《六度分隔:一个相互连接的时代的科学》......一起来看看《六度分隔》这本书的介绍吧!

码农工具