让编程改变世界。

Change the world by program.

thinkphp5部署workerman长连接

由于最近做一个物联网项目,该项目需要远程将温度推送到服务器,并由服务器推送到web前台,硬件可以利用tcp协议将数据上传到到服务器,但是由于不固定ip的原因,服务器是找不到web前端的,而在这个时候我们就需要利用到长连接workerman,在之前我曾经利用workerman进行聊天软件的编写,实现多人在线聊天功能,而在这之前我没有将这个博客编写成功,本次趁着这个机会,我将长连接的知识进行了复习,正好博客完成时间没有多久,于是将这次经历记录在案,以备以后自己查看学习,也方便了看到这个博文并且可能需要用到该框架的同学们。最后,我需要感谢一位同学,他在这个项目中帮助了我很多,


在进行该教程之前,我们需要了解一下workerman这个框架和thinkphp这个框架,thinkphp框架是PHP几大框架之一,想要了解的同学们可以到ThinkPHP5.0完全开发手册上进行文档的阅读,以下简称tp5,tp5框架是国产为数不多的优秀框架之一,国产的哦!而workerman则是在workerman官网上有详细的介绍,同学们可以到该网站上进行手册的查看。


ThinkPHP5.0完全开发手册里面有一篇介绍他们两个融合的文章composer包workerman在这篇文章里介绍了tp5融合workerman的教程,但是介绍的过于简洁,我试验了两次并没有走通,而在这次的记录中我将我的融合过程和这个方法进行对比,分析以前没有走通的原因。


不论在哪个方法中,我们都需要将wokerman的包引入,我们需要用到composer,没有安装composer的同学需要自行安装。


第一步


导入workerman包:

composer require topthink/think-worker

 如果windows服务器还要利用以下命令:

composer require workerman/workerman-for-win

运行出现错误PHP Fatal error: Call to undefined function Workerman\Lib\pcntl_signal(),需要删除vendor\workerman\workerman,防止命名覆盖。

当包引入完成后,我们会在项目根目录下的vendor文件夹下看到workerman文件夹,这样框架就引入了该项目,我们下一步需要配置服务的启动和引用。


第二步


在这一步中我们需要将启动服务文件放入到项目根目录中,在根目录中我们新建启动服务文件server.php

代码如下:

#!/usr/bin/env php
<?php
define('APP_PATH', __DIR__ . '/application/');
//这是原来的代码
//define('BIND_MODULE','push/Worker');
//这是我修改后的代码
define('BIND_MODULE','push/Workertest/index');
// 加载框架引导文件
require __DIR__ . '/thinkphp/start.php';

这个代码的意思是绑定workerman的模块是/application/push/Worker这个控制器,但是由于我们没有用tp5这个框架的引用方式这里我们将代码改为如上所示,直接进入到控制器的index方法,在下一步我们会介绍为什么用这种方法。我们在下一步中就会定义模块,也就是实现功能的地方:/application/push/workertest.php


第三步

在这一步开始前我们来看一下tp5开发手册中的worker.php,需要声明的是我并没用利用该方法。

    一共有一个变量和5个方法,变量是定义端口和域名的,方法是分别为,连接上时,服务开始时,接到信息时,错误时,断开时的相应处理方法。

代码如下

<?php
namespace app\push\controller;
use think\worker\Server;
class Worker extends Server{    
    
    protected $socket = 'websocket://push.app:2346';  

     /**
     * 收到信息
     * @param $connection
     * @param $data
     */
    public function onMessage($connection, $data)
    {
        $connection->send('我收到你的信息了');
    }    
    
    /**
     * 当连接建立时触发的回调函数
     * @param $connection
     */
    public function onConnect($connection)
    {

    }    
    
    /**
     * 当连接断开时触发的回调函数
     * @param $connection
     */
    public function onClose($connection)
    {
        
    }    
    
    /**
     * 当客户端的连接上发生错误时触发
     * @param $connection
     * @param $code
     * @param $msg
     */
    public function onError($connection, $code, $msg)
    {       
         echo "error $code $msg\n";
    }    
    
    /**
     * 每个进程启动
     * @param $worker
     */
    public function onWorkerStart($worker)
    {

    }
}

如果用tp5给出的方法,我们需要在其他的控制器中实例化该控制器类,而在我用到该框架时没有看出该用法,误以为实现功能直接在该控制器中调用即可,当我利用到tcp链接时出现了两个链接的同时调用,在tp5文档中的这个方法,我无法同时实例化两个链接,于是我放弃了该方法,想要研究的同学可以继续研究一下,下面给出我的方法。

workertest.php代码如下:

<?php
namespace app\push\controller;
use Workerman\Worker;
use Workerman\Lib\Timer;
use Workerman\Connection\AsyncTcpConnection;
class WorkerTest
{
    private $connections;
    private $connection_to_ws;
    public function index()
    {
        // $connections = array(); 
        $socket = new Worker('websocket://0.0.0.0:2346');
        // 设置transport开启ssl,websocket+ssl即wss
        // $socket->transport = 'ssl';
        // 启动1个进程对外提供服务  
        $socket->count = 1;
        //给这个进程设置一个array()
        // 当有客户端连接时
        $socket->onConnect = function($connection)
        {
            var_dump(count($this->connections));
            $connection->send("lianjie");
            $this->connections[$connection->id]=$connection;
        };
        // 当有客户端连接时
        $socket->onMessage = function($connection,$data)
        {
            // var_dump($data);
            // var_dump(json_decode($data));
            $jdata = json_decode($data);
            if(isset($jdata->tem))
            {
                foreach($this->connections as $con){
                    if(isset($con->endno)&&isset($jdata->endno)&&$con->endno==$jdata->endno){
                        $con->send($jdata->tem);
                    }
                }
            }
            else
            {
                $connection->send("数据已接受");
                $connection->endno=$jdata->endno;
                $this->connections[$connection->id]=$connection;
            }
        };
        // 当有客户端连接断开时
        $socket->onClose = function($connection)
        {
            if(isset($connection->id))
            {
                // 连接断开时删除映射
                unset($this->connections[$connection->id]);
            }
        };
        $tcp = new Worker('tcp://0.0.0.0:8282');
        $tcp->onMessage = function($connection, $data)
        {
            if(is_null($this->connection_to_ws))
            {
                var_dump('connect');
                $this->connection_to_ws = new AsyncTcpConnection('ws://119.29.170.92:2346');
                $this->connection_to_ws->connect();
            }
            $this->connection_to_ws->send($data);
            // var_dump(count($this->connections));
            //  foreach($this->connections as $con){
            //      if($con->endno==json_decode($data)->endno){
            //          $con->send(json_decode($data)->tem);
            //      }
            //  }
            };
        // 运行worker  
        Worker::runAll();
        }
}

每当前端浏览器通过websoket上传给服务器对应终端号,workerman就会将本链接放入到队列,与此同时,我通过tcp获取到硬件的值,并经过AsyncTcpConnection这个workerman对象将由tcp端口获取的值转发给websoket端口,再由websoket进行遍历当前队列链接的前端浏览器,通过终端id查找并推送给对应的前端浏览器。


最新评论(0
<
>
点击登陆

点我登陆