workman使用手册1.0

workman官网地址：高性能PHP应用容器 workerman

1：把workman项目放到linux服务器后，需要启动你的php文件，才可以使用

        定位到项目根目录：例：cd /mnt/workman

        启动代码：php outin.php start -d

        停止代码：php outin.php stop

        以debug（调试）方式启动： php outin.php start

2：workman服务端写法

<?phpuse Workerman\Worker;
use Workerman\Timer;
use Workerman\MySQL\Connection;
use procedure\Attendance;require_once __DIR__ . '/vendor/autoload.php';$worker = new Worker('websocket://0.0.0.0:8088');
Worker::$logFile = '/mnt/workman/log/outin.log';    //日志地址$worker->uidConnetions = [];
$worker->onConnect = function($connection) use ($worker)
{$connection->onWebSocketConnect = function($connection , $httpBuffer) use ($worker){// 可以在这里判断连接来源是否合法，不合法就关掉连接// $_SERVER['HTTP_ORIGIN']标识来自哪个站点的页面发起的websocket连接
//        if($_SERVER['HTTP_ORIGIN'] != 'https://www.workerman.net')
//        {
//            $connection->close();
//        }// onWebSocketConnect 里面$_GET $_SERVER是可用的// var_dump($_GET, $_SERVER);//前端传入的参数，可以根据type，company_uuid判断需要显示的链接有哪些$worker->uidConnetions[$connection->id]["connection"] = $connection;$worker->uidConnetions[$connection->id]["type"] = $_GET["type"];$worker->uidConnetions[$connection->id]["company_uuid"] = $_GET["company_uuid"];};
};$worker->onClose = function ($connection) use ($worker)
{if (isset($connection->id)) {unset($worker->uidConnetions[$connection->id]);}
};// 进程启动后定时推送数据给客户端
$worker->onWorkerStart = function($worker){//查表，有需要的，// file_put_contents("/mnt/workman/log/" .date("Ymd"). ".txt", date("Y-m-d H:i:s") . ":jin"  .PHP_EOL, FILE_APPEND);$db = new Connection('mysql地址','3306', 'root', 'password', '表名');    //mysql链接信息$attend = new Attendance();Timer::add(1, function()use($worker, $db, $attend){//10s之内的数据$time = time() - 10;$time = date("Y-m-d H:i:s",$time);//$time = date("Y-m-d 00:00:00",$time);$infos = $db->query("SELECT student_userid,class_name,student_name,sign_time,id,company_uuid,status,photo_url FROM sign WHERE tui = '1' AND is_delete = '0' AND sign_time > '$time' GROUP BY student_userid ORDER BY id desc");//获取信息$attend_data = $attend->getAttendanceData($db);foreach($worker->connections as $connection) {$res = $worker->uidConnetions[$connection->id];file_put_contents("/mnt/workman/log/" .date("Ymd"). ".txt", date("Y-m-d H:i:s") . "type1:".$res["type"]  .PHP_EOL, FILE_APPEND);//outin类型的，使用本回调if ($res["type"] == 'outin') {foreach ($infos as $v) {$company_uuid = $v["company_uuid"];$student_userid = $v["student_userid"];$imgurl = $db->single("SELECT imgurl FROM stu_face WHERE company_uuid = '$company_uuid' AND student_userid = '$student_userid'");if ($v["company_uuid"] == $res["company_uuid"]) {$arr = ["class_name"=>$v["class_name"],"student_name"=>$v["student_name"],"status"=>$v["status"],"photo_url"=>$imgurl,"sign_time"=>$v["sign_time"]];//打印输出查询的数据file_put_contents("/mnt/workman/log/" .date("Ymd"). ".txt", date("Y-m-d H:i:s") . "xinxi:".json_encode($arr, true)  .PHP_EOL, FILE_APPEND);//根据数据为已推送$db->query("UPDATE sign SET tui = '2' WHERE tui = '1' AND company_uuid = '$company_uuid' AND student_userid = '$student_userid'");$connection->send(json_encode($arr));}}}if ($res["type"] == 'banji') {$attend->banji($res, $attend_data["ban_infos"],$db,$connection);}}});
};
Worker::runAll();

2：自动加载问题，参考：自动加载-workerman手册

        注：1：文件名是小写的，在使用命名空间的时候，也是使用小写

2：在需要使用的时候，引入是这样的：