Laravel 结合 GatewayWorker 推送消息

时间 2019-11-08

标签 laravel 结合 gatewayworker 推送消息繁體版

原文原文链接

1、简述

GatewayWorker基于 Workerman开发的一个项目框架，用于快速开发 TCP长链接应用，例如app推送服务端、即时IM服务端、游戏服务端、物联网、智能家居等等
GatewayWorker使用经典的Gateway和Worker进程模型。Gateway进程负责维持客户端链接，并转发客户端的数据给BusinessWorker进程处理，BusinessWorker进程负责处理实际的业务逻辑（默认调用Events.php处理业务），并将结果推送给对应的客户端。Gateway服务和BusinessWorker服务能够分开部署在不一样的服务器上，实现分布式集群。php

GatewayWorker提供很是方便的API，能够全局广播数据、能够向某个群体广播数据、也能够向某个特定客户端推送数据。配合Workerman的定时器，也能够定时推送数据。html

2、安装

GatewayWorker 安装在LInux服务器上：nginx

下载地址：GatewayWorkerlaravel

一、下载 demogit

二、命令行运行 unzip GatewayWorker.zip 解压缩GatewayWorker.zipgithub

三、命令行运行 cd GatewayWorker 进入GatewayWorker目录web

四、命令行运行 php start.php start 启动 GatewayWorkerredis

五、新开几个命令行窗口运行 telnet 127.0.0.1 8282，输入任意字符便可聊天（非本机测试请将127.0.0.1替换成实际ip）。chrome

注意：若是 telnet超时请检查服务器防火墙( iptables)

这里启动的是GatewayWorker的默认端口，要是须要更改要改如下三个文件：
GatewayWorker/Applications/YourApp/start_register.phpapache

// register 必须是text协议；这个端口要保持一致，根据项目自定义
$register = new Register('text://0.0.0.0:1238');

GatewayWorker/Applications/YourApp/start_businessworker.php

// bussinessWorker 进程
$worker = new BusinessWorker();
// worker名称,根据不一样的项目自定义
$worker->name = 'YourAppBusinessWorker';
// bussinessWorker进程数量
$worker->count = 4;
// 服务注册地址; 注意这个端口要保持一致，不一样的项目能够自定义
$worker->registerAddress = '127.0.0.1:1238';

GatewayWorker/Applications/YourApp/start_gateway.php

// gateway 进程，这里使用Text协议，能够用telnet测试
$gateway = new Gateway("tcp://0.0.0.0:8282");
// gateway名称，status方便查看
$gateway->name = 'YourAppGateway';
// gateway进程数
$gateway->count = 4;
// 本机ip，分布式部署时使用内网ip
$gateway->lanIp = '127.0.0.1';
// 内部通信起始端口，假如$gateway->count=4，起始端口为4000
// 则通常会使用4000 4001 4002 4003 4个端口做为内部通信端口 ，不一样项目开启不一样端口
$gateway->startPort = 2900;
// 服务注册地址；端口保持一致，项目自定义
$gateway->registerAddress = '127.0.0.1:1238';

// 服务端向客户端发送心跳数据的时间间隔 单位：秒。若是设置为0表明不发送心跳检测
//$gateway->pingInterval = 10;
//客户端连续$pingNotResponseLimit次$pingInterval时间内不回应心跳则断开连接。
//若是设置为0表明客户端不用发送回应数据，即经过TCP层面检测链接的连通性（极端状况至少10分钟才能检测到）
//$gateway->pingNotResponseLimit = 2;
// 要发送的心跳请求数据，心跳数据是任意的，只要客户端能识别便可
//$gateway->pingData = '{"type":"ping"}';

注意：须要客户端与服务端保持链接不被断开,能够开启心跳检查定时发送心跳数据。

服务管理

在GatewayWorker根目录下有一个start.php文件：

php start.php  start   启动服务 （php start.php  start  -d   以daemon启动）

php start.php  stop    中止服务

php start.php restart  从新启动 （-d 以daemon启动）

php start.php reload   平滑重启

php start.php  status  服务状态

vagrant@homestead:~/code/GatewayWorker$ php start.php status

Workerman[start.php] status 
----------------------------------------------GLOBAL STATUS----------------------------------------------------
Workerman version:3.5.10          PHP version:7.2.3-1+ubuntu16.04.1+deb.sury.org+1
start time:2018-06-08 14:00:54   run 0 days 2 hours   
load average: 0, 0, 0            event-loop:\Workerman\Events\Select
3 workers       9 processes
worker_name       exit_status      exit_count
YourAppBusinessWorker 0                0
YourAppGateway        0                0
Register          0                0
----------------------------------------------PROCESS STATUS---------------------------------------------------
pid    memory  listening             worker_name       connections send_fail timers  total_request qps    status
4693    2M      none                YourAppBusinessWorker 5           0         0       3             0      [idle]
4694    2M      none                YourAppBusinessWorker 5           0         0       3             0      [idle]
4695    2M      none                YourAppBusinessWorker 5           0         0       156           0      [idle]
4696    2M      none                YourAppBusinessWorker 5           0         0       3             0      [idle]
4697    2M      tcp://0.0.0.0:8282  YourAppGateway        8           0         0       226           0      [idle]
4698    2M      tcp://0.0.0.0:8282  YourAppGateway        8           0         0       226           0      [idle]
4699    2M      tcp://0.0.0.0:8282  YourAppGateway        8           0         0       226           0      [idle]
4700    2M      tcp://0.0.0.0:8282  YourAppGateway        8           0         0       378           0      [idle]
4701    2M      text://0.0.0.0:1238     Register          8           0         0       51            0      [idle]
----------------------------------------------PROCESS STATUS---------------------------------------------------
Summary    18M     -                   -                 60          0         0       1272          0      [Summary]

注意：修改代码要重启服务。

GatewayClient安装下项目中

原则：
现有 mvc框架项目与 GatewayWorker独立部署互不干扰
全部的业务逻辑都由网站页面post/get到mvc框架中完成

GatewayWorker不接受客户端发来的数据，即GatewayWorker不处理任何业务逻辑，GatewayWorker仅仅当作一个单向的推送通道

仅当mvc框架须要向浏览器主动推送数据时才在mvc框架中调用Gateway的API(GatewayClient)完成推送

固然，这只是官方推荐的结合方式，也不是绝对的。开发者能够自由变化选择结合方式以适应本身的业务需求。固然也能够采用客户端与GatewayWorker直接双向通信的方式完成业务通信。更多参考官方手册。

下载地址：GatewayClient。项目中执行如下命令便可：

composer require workerman/gatewayclient

3、应用

在laravel中结合redis 消息队列（可参考laravel/lumen 使用 redis队列）来完成消息推送。

在controller中使用dispatch触发队列

dispatch(new YourJob($data));

在Jobs中示例：

<?php

namespace App\Jobs;


use GatewayClient\Gateway;

class YourJob extends Job
{
    /**
     * Create a new job instance.
     *
     * @return void
     */
    protected $id;


    public function __construct($id) 
    {
        $this->id = $id;
    }

    public function handle()
    {
        //业务逻辑
        Gateway::sendToAll(json_encode(['id' => xxx, 'name' => xxx]));
    }
}

每次改动代码重启队列。 supervisorctl reload

4、调试

服务器端打开Telnet，不可执行Telnet命令须要安装。
如：

vagrant@homestead:~/code/GatewayWorker$ telnet 127.0.0.1 8282
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
Hello 7f0000010b5600000001
7f0000010b5600000001 login
hello
7f0000010b5600000001 said hello

{"id":"35","name":"xxx"}

正常状况，会输出你想发送的消息。
Escape character is '^]'.是 Ctrl + ] 调出Telnet，输入quit能够退出。

5、配置wss

Workerman如何建立一个wss服务，使得客户端能够用过wss协来链接通信，好比在微信小程序中链接服务端。

wss协议实际是 websocket+ SSL，就是在 websocket协议上加入 SSL层，相似 https(http+SSL)。因此只须要在 websocket协议的基础上开启 SSL便可支持 wss协议。

配置方式一：直接用Workerman开启SSL：

准备工做：

一、Workerman版本不小于3.3.7

二、PHP安装了openssl扩展

三、已经申请了证书（pem/crt文件及key文件）放在磁盘任意目录

start_gateway.php中设置如下代码

<?php
require_once __DIR__ . '/Workerman/Autoloader.php';
use Workerman\Worker;

// 证书最好是申请的证书
$context = array(
    // 更多ssl选项请参考手册 http://php.net/manual/zh/context.ssl.php
    'ssl' => array(
        // 请使用绝对路径
        'local_cert'                 => '磁盘路径/server.pem', // 也能够是crt文件
        'local_pk'                   => '磁盘路径/server.key',
        'verify_peer'                => false,
        // 'allow_self_signed' => true, //若是是自签名证书须要开启此选项
    )
);
// 这里设置的是websocket协议（端口任意，可是须要保证没被其它程序占用）
$worker = new Worker('websocket://0.0.0.0:443', $context);
$worker->name = xxx //配置名称便于监控
// 设置transport开启ssl，websocket+ssl即wss
$worker->transport = 'ssl';
$worker->onMessage = function($con, $msg) {
    $con->send('ok');
};

Worker::runAll();

经过以上的代码，Workerman就监听了wss协议，客户端就能够经过wss协议来链接workerman实现安全即时通信了。

测试
打开chrome浏览器，按F12打开调试控制台，在Console一栏输入(或者把下面代码放入到html页面用js运行)

// 证书是会检查域名的，请使用域名链接

ws = new WebSocket("wss://域名");
ws.onopen = function() {
    alert("链接成功");
    ws.send('tom');
    alert("给服务端发送一个字符串：tom");
};
ws.onmessage = function(e) {
    alert("收到服务端的消息：" + e.data);
};

注意：
一、若是没法启动，则通常是443端口被占用，请改为其它端口，注意改为其它端口后客户端链接时须要带上端口号，客户端链接时地址相似wss://domain.com:xxx ，xxx为端口号。若是必须使用443端口请使用方法二代理的方式实现wss。

二、wss端口只能经过wss协议访问，ws没法访问wss端口。

三、证书通常是与域名绑定的，因此测试的时候客户端请使用域名链接，不要使用ip去连。

四、若是出现没法访问的状况，请检查服务器防火墙。

五、此方法要求PHP版本>=5.6，由于微信小程序要求tls1.2，而PHP5.6如下版本不支持tls1.2。

六、微信小程序要求链接wss时不带端口号，也就是wss端口只能是443。可是443端口通常被nginx/apache占用，此时能够考虑方法二。

配置方式二：利用nginx/apache代理wss

利用 nginx/apache做为 wss代理转发给 workerman（ 注意此方法workerman部分千万不要设置ssl，不然将没法链接）。

通信原理及流程是：
一、客户端发起wss链接连到nginx/apache

二、nginx/apache将wss协议的数据转换成ws协议数据并转发到Workerman的websocket协议端口

三、Workerman收到数据后作业务逻辑处理

四、Workerman给客户端发送消息时，则是相反的过程，数据通过nginx/apache转换成wss协议而后发给客户端

nginx配置参考

前提条件及准备工做：
一、假设Workerman监听的是8282端口(websocket协议,不要用tcp)
二、已经申请了证书（pem/crt文件及key文件）放在了/etc/nginx/conf.d/ssl下
三、打算利用nginx开启443端口对外提供wss代理服务（端口能够根据须要修改）
四、nginx通常做为网站服务器运行着其它服务，为了避免影响原来的站点使用，这里使用地址域名/wss 做为wss的代理入口。也就是客户端链接地址为 wss://域名/wss

nginx配置相似以下：

server {
  listen 443;

  ssl on;
  ssl_certificate /etc/ssl/server.pem;
  ssl_certificate_key /etc/ssl/server.key;
  ssl_session_timeout 5m;
  ssl_session_cache shared:SSL:50m;
  ssl_protocols SSLv3 SSLv2 TLSv1 TLSv1.1 TLSv1.2;
  ssl_ciphers ALL:!ADH:!EXPORT56:RC4+RSA:+HIGH:+MEDIUM:+LOW:+SSLv2:+EXP;

  location /wss
  {
    proxy_pass http://127.0.0.1:8282;
    proxy_http_version 1.1;
    proxy_set_header Upgrade $http_upgrade;
    proxy_set_header Connection "Upgrade";
    proxy_set_header X-Real-IP $remote_addr;
  }

  # location / {} 站点的其它配置...
}

测试

// 证书是会检查域名的，请使用域名链接

ws = new WebSocket("wss://域名/wss");

ws.onopen = function() {
    alert("链接成功");
    ws.send('tom');
    alert("给服务端发送一个字符串：tom");
};
ws.onmessage = function(e) {
    alert("收到服务端的消息：" + e.data);
};

另外为了方便测试，你们也可使用在线测试工具，如 websocket在线测试