做django后台网站,域名注册的网站,企业标志设计,vi设计公司北京一、安装thinkphp5
1、宝塔删除php禁用函数putenv、pcntl_signal_dispatch、pcntl_wai、pcntl_signal、pcntl_alarm、pcntl_fork#xff0c;执行安装命令。
composer create-project topthink/think5.0.* tp5 --prefer-dist 2、配置好站点之后#xff0c;浏览器打开访问成…
一、安装thinkphp5
1、宝塔删除php禁用函数putenv、pcntl_signal_dispatch、pcntl_wai、pcntl_signal、pcntl_alarm、pcntl_fork执行安装命令。
composer create-project topthink/think5.0.* tp5 --prefer-dist 2、配置好站点之后浏览器打开访问成功。 二、tp5安装GatewayWorker
1、进入tp5目录安装GatewayWorker
composer require workerman/gateway-worker
如果报错安装指定版本 2、安装workman
composer require workerman/workerman
如果报错安装指定版本 3、安装gatewayclient
composer require workerman/gatewayclient
如果报错安装指定版本 三、使用GatewayWorker
注:我已修改默认端口号,在宝塔开启端口号 1、创建文件 tp5/public/start.php
?php
/*** run with command* php start.php start*/ini_set(display_errors, on);
use Workerman\Worker;if(strpos(strtolower(PHP_OS), win) 0)
{exit(start.php not support windows, please use start_for_win.bat\n);
}// 检查扩展
if(!extension_loaded(pcntl))
{exit(Please install pcntl extension. See http://doc3.workerman.net/appendices/install-extension.html\n);
}if(!extension_loaded(posix))
{exit(Please install posix extension. See http://doc3.workerman.net/appendices/install-extension.html\n);
}// 标记是全局启动
define(GLOBAL_START, 1);require_once __DIR__ . /../vendor/autoload.php;
// 加载所有Applications/*/start.php以便启动所有服务 application更改为自己文件夹名字,我的为websocket
foreach(glob(__DIR__./../api/websocket/start*.php) as $start_file)
{require_once $start_file;
}
// 运行所有服务
Worker::runAll(); 2、创建文件 tp5/api/Socket/Events.php (创建php文件,或者下载demo复制过去即可)
?php
/*** This file is part of workerman.** Licensed under The MIT License* For full copyright and license information, please see the MIT-LICENSE.txt* Redistributions of files must retain the above copyright notice.** author walkorwalkorworkerman.net* copyright walkorwalkorworkerman.net* link http://www.workerman.net/* license http://www.opensource.org/licenses/mit-license.php MIT License*//*** 用于检测业务代码死循环或者长时间阻塞等问题* 如果发现业务卡死可以将下面declare打开去掉//注释并执行php start.php reload* 然后观察一段时间workerman.log看是否有process_timeout异常*/
//declare(ticks1);use \GatewayWorker\Lib\Gateway;/*** 主逻辑* 主要是处理 onConnect onMessage onClose 三个方法* onConnect 和 onClose 如果不需要可以不用实现并删除*/
class Events
{/*** 当客户端连接时触发* 如果业务不需此回调可以删除onConnect* * param int $client_id 连接id*/public static function onConnect($client_id){echo 【新的客户端链接】client_id.$client_id.PHP_EOL;// 向当前client_id发送数据 Gateway::sendToClient($client_id, Hello $client_id\r\n);// 向所有人发送Gateway::sendToAll($client_id login\r\n);}/*** 当客户端发来消息时触发* param int $client_id 连接id* param mixed $message 具体消息*/public static function onMessage($client_id, $message){// 向所有人发送 Gateway::sendToAll($client_id said $message\r\n);}/*** 当用户断开连接时触发* param int $client_id 连接id*/public static function onClose($client_id){// 向所有人发送 GateWay::sendToAll($client_id logout\r\n);}
} 3、创建文件tp5/application/Socket/start_businessworker.php
?php
/*** This file is part of workerman.** Licensed under The MIT License* For full copyright and license information, please see the MIT-LICENSE.txt* Redistributions of files must retain the above copyright notice.** author walkorwalkorworkerman.net* copyright walkorwalkorworkerman.net* link http://www.workerman.net/* license http://www.opensource.org/licenses/mit-license.php MIT License*/
use Workerman\Worker;
use Workerman\WebServer;
use GatewayWorker\Gateway;
use GatewayWorker\BusinessWorker;
use Workerman\Autoloader;// 自动加载类
require_once __DIR__ . /../../vendor/autoload.php;
require_once __DIR__ . /Events.php;// bussinessWorker 进程
$worker new BusinessWorker();
// worker名称
$worker-name YourAppBusinessWorker;
// bussinessWorker进程数量
$worker-count 4;
// 服务注册地址
$worker-registerAddress 127.0.0.1:23222;//这行代码防止出现报错Waring: Events::onMessage is not callable
$worker-eventHandler Events;// 如果不是在根目录启动则运行runAll方法
if(!defined(GLOBAL_START))
{Worker::runAll();
} 4、创建文件tp5/application/Socket/start_gateway.php ?php
/*** This file is part of workerman.** Licensed under The MIT License* For full copyright and license information, please see the MIT-LICENSE.txt* Redistributions of files must retain the above copyright notice.** author walkorwalkorworkerman.net* copyright walkorwalkorworkerman.net* link http://www.workerman.net/* license http://www.opensource.org/licenses/mit-license.php MIT License*/
use \Workerman\Worker;
use \Workerman\WebServer;
use \GatewayWorker\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Autoloader;// 自动加载类
require_once __DIR__ . /../../vendor/autoload.php;// gateway 进程这里使用Text协议可以用telnet测试
$gateway new Gateway(websocket://0.0.0.0:24222);
// gateway名称status方便查看
$gateway-name moods;
// gateway进程数
$gateway-count 4;
// 本机ip分布式部署时使用内网ip
$gateway-lanIp 127.0.0.1;
// 内部通讯起始端口假如$gateway-count4起始端口为4000
// 则一般会使用4000 4001 4002 4003 4个端口作为内部通讯端口
$gateway-startPort 2900;
// 服务注册地址
$gateway-registerAddress 127.0.0.1:23222;// 心跳间隔
//$gateway-pingInterval 1;
// 心跳数据
//$gateway-pingData {type:ping};/*
// 当客户端连接上来时设置连接的onWebSocketConnect即在websocket握手时的回调
$gateway-onConnect function($connection)
{$connection-onWebSocketConnect function($connection , $http_header){// 可以在这里判断连接来源是否合法不合法就关掉连接// $_SERVER[HTTP_ORIGIN]标识来自哪个站点的页面发起的websocket链接if($_SERVER[HTTP_ORIGIN] ! http://kedou.workerman.net){$connection-close();}// onWebSocketConnect 里面$_GET $_SERVER是可用的// var_dump($_GET, $_SERVER);};
};
*/// 如果不是在根目录启动则运行runAll方法
if(!defined(GLOBAL_START))
{Worker::runAll();
} 5、创建文件tp5/application/Socket/start_register.php
?php
/*** This file is part of workerman.** Licensed under The MIT License* For full copyright and license information, please see the MIT-LICENSE.txt* Redistributions of files must retain the above copyright notice.** author walkorwalkorworkerman.net* copyright walkorwalkorworkerman.net* link http://www.workerman.net/* license http://www.opensource.org/licenses/mit-license.php MIT License*/
use \Workerman\Worker;
use \GatewayWorker\Register;// 自动加载类
require_once __DIR__ . /../../vendor/autoload.php;// register 必须是text协议
$register new Register(text://0.0.0.0:23222);// 如果不是在根目录启动则运行runAll方法
if(!defined(GLOBAL_START))
{Worker::runAll();
} 6、启动websocket程序
1、防火墙打开8282、1236端口执行下面命令
//运行php start.php start//linux运行php start.php start -d//停止php start.php stop//检测端口是否以被占用
netstat -an | grep 80//关闭某个进程
sudo kill -9 进程ID如果修改文件后一定要先停止在运行一下文件,否则不生效 四、使用GatewayWorker发布广播
1、创建文件tp5/application/index/controller/Index.php执行这个方法就可以向所有人发布广播了。 ?php
namespace app\index\controller;
use GatewayClient\Gateway;
class Index
{public function index(){Gateway::sendToAll( index发的消息 \r\n);}
} 后面逻辑,自己处理即可
测试发信息内容为 测试地址: http://www.jsons.cn/websocket/
用户1 用户2
