我的主机环境是windows,在这个环境下使用workerman你需要两个基本条件。一个是具备cli模式和comporser工具。如果没有的话先折腾好在进行下面的操作,也可以私信笔者。接着基于tp5框架下,我们使用comporser工具下载workerman。下载姿势请百度。
趟完以上的坑相信我你基本就完成70%的工作了,接下来的操作很简单。首先在根目录下创建一个server.php文件,内容如下。
<?php
define('APP_PATH', __DIR__ . '/application/');
define('BIND_MODULE','push/Worker');
// 加载框架引导文件
require __DIR__ . '/thinkphp/start.php';
接着我们可以创建push模块的Worker控制器,这个路径一定要和server.php的line3中的路径相同。Worker.php如下
<?php
namespace app\push\controller;
use think\worker\Server;
use Workerman\Lib\Timer;
class Worker extends Server
{
protected $socket = 'websocket://localhost:8082';
// protected $socket = 'websocket://ssf.c.chuankukeji.com:8080';
/**
* 收到信息
* @param $connection
* @param $data
*/
public function onMessage($connection, $data)
{
Timer::add(1, function()use($connection, $data)
{
$cache=cache('pk');
if(!$cache){
$cache='暂无动态!';
}
$connection->send('6666');
});
}
/**
* 当连接建立时触发的回调函数
* @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)
{
$handle = new Index();
$handle -> add_plan();//定时计划
}
}
在这里我们可以控制长连接会话和定时任务。前者需要前端使用websocket功能。今天我们值关注后者,也就是onWorkerStart方法,注意这个方法中实例化的对象是专门处理定时任务的/application/push/controller/index.php
<?php
namespace app\server\controller;
use Workerman\Lib\Timer;
class Index
{
public function add_timer(){
Timer::add(1, array($this, 'index'), array(), true);
}
public function index(){
//每天0点执行任务
if(time()/86400===0){
echo date("Y-m-d H:i:s");
}
//每天8点执行任务
if(time()/86400===28800){
echo date("Y-m-d H:i:s");
}
}
}
最后我们win&r,键入cmd然后回车,在命令行中输入php d:/www/item/server.php
要注意输入具体路径。其中‘php’要已经设置了环境变量。
这样我们就打开了workerman的服务,如果这个窗口关闭则服务关闭。
以上。