我的博客文章网址：
http://www.jloongking.cn/tp50/public/blog/index/blog?blogid=93
由于最近做一个物联网项目，该项目需要远程将温度推送到服务器，并由服务器推送到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查找并推送给对应的前端浏览器。
