ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

Swoole的webSocket部分服务端封装

2020-09-14 15:35:21  阅读:211  来源: 互联网

标签:function webSocket Swoole self private server fd public 服务端


//封装单例模式(三私一公)
class SwooleWebSocket
{
private static $instance; //存放当前对象属性
private static $server; //存放webSocket对象属性

private $dir = 'swooleLogs/swoole.log';

private function __construct() {
//创建webSocket对象
self::$server = new Swoole\WebSocket\Server('0.0.0.0', 9505);
//设置参数
self::$server->set([
'daemonize' => 1, // 作为守护进程运行,需同时设置log_file
'log_file' => $this->dir, // 指定标准输出和错误日志文件
]);
//注册事件
self::$server->on('open',[$this,'onOpen']); //将当前类中的onOpen方法作为open的事件处理函数
self::$server->on('message',[$this,'onMessage']);
self::$server->on('close',[$this,'onClose']);
}

private function __clone() {
// TODO: Implement __clone() method.
trigger_error('Clone is not allowed !');
}

public static function getInstance() {
if ( !(self::$instance instanceof self) ){
self::$instance = new self();
}
return self::$instance;
}

//当前客户端连接之后要执行的方法
public function onOpen($server,$request) {
echo "client: {$request->fd}\n";
$server->push($request->fd, "hello, welcome\n");
}

//当客户端向服务器发送消息时要执行的方法
public function onMessage($server,$frame) {
//处理业务逻辑
echo "client: {$frame->data}\n";
$server->push($frame->fd, "server: {$frame->data}");
}

//当客户端和服务端断开连接时要执行的方法
public function onClose($server,$fd) {
echo "client-{$fd} is closed\n";
}

//启动webSocket方法
public static function start(){
self::$server->start();
}
}

SwooleWebSocket::getInstance()->start();

标签:function,webSocket,Swoole,self,private,server,fd,public,服务端
来源: https://www.cnblogs.com/luoqinghui/p/13666971.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有