如何将ThinkPHP5与Workerman长连接实现长尾词的部署？
- 内容介绍
- 文章标签
- 相关推荐
本文共计1731个文字，预计阅读时间需要7分钟。
由于最近一个物联网项目，该项目需要将温度数据远程传输到服务器，再由服务器推送到web前端。硬件方面，可以使用TCP协议将数据上传到服务器。但由于服务器IP不固定，导致服务器找不到。
由于最近做一个物联网项目，该项目需要远程将温度推送到服务器，并由服务器推送到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包：
composerrequiretopthink/think-worker
如果windows服务器还要利用以下命令：
composerrequireworkerman/workerman-for-win
如运行出现错误PHP Fatal error: Call to undefined function Workerman\Lib\pcntl_signal()，需要删除vendor\workerman\workerman，防止命名覆盖。
当包引入完成后，我们会在项目根目录下的vendor文件夹下看到workerman文件夹，这样框架就引入了该项目，我们下一步需要配置服务的启动和引用。
第二步
在这一步中我们需要将启动服务文件放入到项目根目录中，在根目录中我们新建启动服务文件server.php
代码如下：
#!/usr/bin/envphp
<?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
namespaceapp\push\controller;
usethink\worker\Server;
classWorkerextendsServer{
protected$socket='websocket://push.app:2346';
/**
*收到信息
*@param$connection
*@param$data
*/
publicfunctiononMessage($connection,$data)
{
$connection->send('我收到你的信息了');
}
/**
*当连接建立时触发的回调函数
*@param$connection
*/
publicfunctiononConnect($connection)
{
}
/**
*当连接断开时触发的回调函数
*@param$connection
*/
publicfunctiononClose($connection)
{
}
/**
*当客户端的连接上发生错误时触发
*@param$connection
*@param$code
*@param$msg
*/
publicfunctiononError($connection,$code,$msg)
{
echo"error$code$msg\n";
}
/**
*每个进程启动
*@param$worker
*/
publicfunctiononWorkerStart($worker)
{
}
}
如果用tp5给出的方法，我们需要在其他的控制器中实例化该控制器类，而在我用到该框架时没有看出该用法，误以为实现功能直接在该控制器中调用即可，当我利用到tcp链接时出现了两个链接的同时调用，在tp5文档中的这个方法，我无法同时实例化两个链接，于是我放弃了该方法，想要研究的同学可以继续研究一下，下面给出我的方法。
workertest.php代码如下：
<?php
namespaceapp\push\controller;
useWorkerman\Worker;
useWorkerman\Lib\Timer;
useWorkerman\Connection\AsyncTcpConnection;
classWorkerTest
{
private$connections;
private$connection_to_ws;
publicfunctionindex()
{
//$connections=array();
$socket=newWorker('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->connectionsas$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=newWorker('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=newAsyncTcpConnection('ws://119.29.170.92:2346');
$this->connection_to_ws->connect();
}
$this->connection_to_ws->send($data);
//var_dump(count($this->connections));
//foreach($this->connectionsas$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查找并推送给对应的前端浏览器。
本文共计1731个文字，预计阅读时间需要7分钟。
由于最近一个物联网项目，该项目需要将温度数据远程传输到服务器，再由服务器推送到web前端。硬件方面，可以使用TCP协议将数据上传到服务器。但由于服务器IP不固定，导致服务器找不到。
由于最近做一个物联网项目，该项目需要远程将温度推送到服务器，并由服务器推送到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包：
composerrequiretopthink/think-worker
如果windows服务器还要利用以下命令：
composerrequireworkerman/workerman-for-win
如运行出现错误PHP Fatal error: Call to undefined function Workerman\Lib\pcntl_signal()，需要删除vendor\workerman\workerman，防止命名覆盖。
当包引入完成后，我们会在项目根目录下的vendor文件夹下看到workerman文件夹，这样框架就引入了该项目，我们下一步需要配置服务的启动和引用。
第二步
在这一步中我们需要将启动服务文件放入到项目根目录中，在根目录中我们新建启动服务文件server.php
代码如下：
#!/usr/bin/envphp
<?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
namespaceapp\push\controller;
usethink\worker\Server;
classWorkerextendsServer{
protected$socket='websocket://push.app:2346';
/**
*收到信息
*@param$connection
*@param$data
*/
publicfunctiononMessage($connection,$data)
{
$connection->send('我收到你的信息了');
}
/**
*当连接建立时触发的回调函数
*@param$connection
*/
publicfunctiononConnect($connection)
{
}
/**
*当连接断开时触发的回调函数
*@param$connection
*/
publicfunctiononClose($connection)
{
}
/**
*当客户端的连接上发生错误时触发
*@param$connection
*@param$code
*@param$msg
*/
publicfunctiononError($connection,$code,$msg)
{
echo"error$code$msg\n";
}
/**
*每个进程启动
*@param$worker
*/
publicfunctiononWorkerStart($worker)
{
}
}
如果用tp5给出的方法，我们需要在其他的控制器中实例化该控制器类，而在我用到该框架时没有看出该用法，误以为实现功能直接在该控制器中调用即可，当我利用到tcp链接时出现了两个链接的同时调用，在tp5文档中的这个方法，我无法同时实例化两个链接，于是我放弃了该方法，想要研究的同学可以继续研究一下，下面给出我的方法。
workertest.php代码如下：
<?php
namespaceapp\push\controller;
useWorkerman\Worker;
useWorkerman\Lib\Timer;
useWorkerman\Connection\AsyncTcpConnection;
classWorkerTest
{
private$connections;
private$connection_to_ws;
publicfunctionindex()
{
//$connections=array();
$socket=newWorker('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->connectionsas$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=newWorker('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=newAsyncTcpConnection('ws://119.29.170.92:2346');
$this->connection_to_ws->connect();
}
$this->connection_to_ws->send($data);
//var_dump(count($this->connections));
//foreach($this->connectionsas$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查找并推送给对应的前端浏览器。