代码拉取完成,页面将自动刷新
同步操作将从 莫小白/scheduledTask 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
<?php
/**
* Swoole Develop Structure
*
* Swoole 结构,便于开发过程中查看文档,以及屏蔽IDE undefined 提示,便于快速查看函数用法。
*
* 本文件使用方式
*
* 普通IDE:
* 开发Swoole项目同时,在IDE中打开/导入本文件即可。
* 如果IDE自带 Include Path 功能(如:PhpStorm),设置该文件路径即可。
*
* PhpStorm 另一种方法:
* WinRAR打开 <Phpstorm_Dir>/plugins/php/lib/php.jar 文件
* 复制 swoole.php 到路径:com\jetbrains\php\lang\psi\stubs\data\
* 保存文件,重启Phpstorm.
*
* PS:替换前请备份php.jar 若发生错误便于恢复 :)
*
* Author:EagleWu <eaglewudi@gmail.com>
* Date: 2014/01/17
*
*/
/**
* swoole_server_set函数用于设置swoole_server运行时的各项参数
*
* @param $serv
* @param $arguments
*/
function swoole_server_set($serv, array $arguments) {}
/**
* 创建一个swoole server资源对象
*
* @param string $host 参数用来指定监听的ip地址,如127.0.0.1,或者外网地址,或者0.0.0.0监听全部地址
* @param int $port 监听的端口,如9501,监听小于1024端口需要root权限,如果此端口被占用server-start时会失败
* @param int $mode 运行的模式,swoole提供了3种运行模式,默认为多进程模式
* @param string $sock_type 指定socket的类型,支持TCP/UDP、TCP6/UDP64种
* @return int
*/
function swoole_server_create($host, $port, $mode = SWOOLE_PROCESS, $sock_type = SWOOLE_SOCK_TCP) {}
/**
* 增加监听的端口
*
* 您可以混合使用UDP/TCP,同时监听内网和外网端口
* 业务代码中可以通过调用swoole_connection_info来获取某个连接来自于哪个端口
*
* @param object $serv
* @param string $host
* @param int $port
* @return void
*/
function swoole_server_addlisten($serv, $host = '127.0.0.1', $port = 9502) {}
/**
* 设置定时器
*
* 第二个参数是定时器的间隔时间,单位为毫秒。
* swoole定时器的最小颗粒是1毫秒,支持多个定时器。
* 此函数可以用于worker进程中。或者通过swoole_server_set设置timer_interval来调整定时器最小间隔。
*
* 增加定时器后需要为Server设置onTimer回调函数,否则会造成严重错误。
* 多个定时器都会回调此函数。
* 在这个函数内需要自行switch,根据interval的值来判断是来自于哪个定时器。
*
* @param object $serv
* @param int $interval
* @return bool
*/
function swoole_server_addtimer($serv, $interval) {}
/**
* 设置Server的事件回调函数
*
* 第一个参数是swoole的资源对象
* 第二个参数是回调的名称, 大小写不敏感,具体内容参考回调函数列表
* 第三个函数是回调的PHP函数,可以是字符串,数组,匿名函数。
*
* 设置成功后返回true。如果$event_name填写错误将返回false。
*
* onConnect/onClose/onReceive 这3个回调函数必须设置,其他事件回调函数可选。
* 如果设定了timer定时器,onTimer事件回调函数也必须设置
*
* @param object $serv
* @param string $event_name
* @param is_callable $event_callback_function
* @return bool
*/
function swoole_server_handler($serv, $event_name, $event_callback_function) {}
/**
* 启动server,监听所有TCP/UDP端口
*
* 启动成功后会创建worker_num+2个进程。主进程+Manager进程+n*Worker进程。
* 启动失败扩展内会抛出致命错误,请检查php error_log的相关信息。errno={number}是标准的Linux Errno,可参考相关文档。
* 如果开启了log_file设置,信息会打印到指定的Log文件中。
*
* 如果想要在开机启动时,自动运行你的Server,可以在/etc/rc.local文件中加入:
*
* /usr/bin/php /data/webroot/www.swoole.com/server.php
*
* 常见的错误有及拍错方法:
*
* 1、bind端口失败,原因是其他进程已占用了此端口
* 2、未设置必选回调函数,启动失败
* 3、php有代码致命错误,请检查php的错误信息
* 4、执行ulimit -c unlimited,打开core dump,查看是否有段错误
* 5、关闭daemonize,关闭log,使错误信息可以打印到屏幕
*
* @param object $serv
* @return bool
*/
function swoole_server_start($serv) {}
/**
* 平滑重启Server
*
* 一台繁忙的后端服务器随时都在处理请求,如果管理员通过kill进程方式来终止/重启服务器程序,可能导致刚好代码执行到一半终止。
* 这种情况下会产生数据的不一致。如交易系统中,支付逻辑的下一段是发货,假设在支付逻辑之后进程被终止了。
* 会导致用户支付了货币,但并没有发货,后果非常严重。
*
* Swoole提供了柔性终止/重启的机制,管理员只需要向SwooleServer发送特定的信号,Server的worker进程可以安全的结束。
*
* SIGTREM: 向主进程发送此信号服务器将安全终止
* SIGUSR1: 向管理进程发送SIGUSR1信号,将平稳地restart所有worker进程,在PHP代码中可以调用swoole_server_reload($serv)完成此操作
*
* @param object $serv
* @return void
*/
function swoole_server_reload($serv) {}
/**
* 关闭客户端连接
*
* Server主动close连接,也一样会触发onClose事件。
* 不要在close之后写清理逻辑,应当放置到onClose回调中处理。
*
* @param object $serv
* @param int $fd
* @param int $from_id
* @return bool
*/
function swoole_server_close($serv, $fd, $from_id = 0) {}
/**
* 向客户端发送数据
*
* $data的长度可以是任意的。扩展函数内会进行切分。
* 如果是UDP协议,会直接在worker进程内发送数据包。
* 发送成功会返回true,如果连接已被关闭或发送失败会返回false.
*
* @param object $serv
* @param int $fd
* @param string $data
* @param int $from_id
* @return bool
*/
function swoole_server_send($serv, $fd, $data, $from_id = 0) {}
/**
* 获取客户端连接的信息
*
* 返回数组含义:
* from_id 来自哪个poll线程
* from_fd 来自哪个server socket
* from_port 来自哪个Server端口
* remote_port 客户端连接的端口
* remote_ip 客户端连接的ip
*
* 以下 v1.6.10 增加
* connect_time 连接时间
* last_time 最后一次发送数据的时间
*
* @param object $serv
* @param int $fd
* @return array on success or false on failure.
*/
function swoole_connection_info($serv, $fd) {}
/**
* 遍历当前Server所有的客户端连接
*
* 此函数接受3个参数,第一个参数是server的资源对象,第二个参数是起始fd,第三个参数是每页取多少条,最大不得超过100。
* 调用成功将返回一个数字索引数组,元素是取到的$fd。
* 数组会按从小到大排序,最后一个$fd作为新的start_fd再次尝试获取。
*
* @param object $serv
* @param int $start_fd
* @param int $pagesize
* @return array on success or false on failure
*/
function swoole_connection_list($serv, $start_fd = 0, $pagesize = 10) {}
/**
* 设置进程的名称
*
* 修改进程名称后,通过ps命令看到的将不再是php your_file.php。而是设定的字符串。
* 此函数接受一个字符串参数。
* 此函数与PHP5.5提供的cli_set_process_title功能是相同的,但swoole_set_process_name可用于PHP5.2之上的任意版本。
*
* @param string $name
* @return void
*/
function swoole_set_process_name($name) {}
/**
* 将Socket加入到swoole的reactor事件监听中
*
* 此函数可以用在Server或Client模式下
*
* 参数1为socket的文件描述符;
* 参数2为回调函数,可以是字符串函数名、对象+方法、类静态方法或匿名函数,当此socket可读是回调制定的函数。
*
* Server程序中会增加到server socket的reactor中。
* Client程序中,如果是第一次调用此函数会自动创建一个reactor,并添加此socket,程序将在此处进行wait。
* swoole_event_add函数之后的代码不会执行。当调用swoole_event_exit才会停止wait,程序继续向下执行。
* 第二次调用只增加此socket到reactor中,开始监听事件
*
* @param int $sock
* @param is_callable $callback
* @return bool
*/
function swoole_event_add($sock, $read_callback = null, $write_callback = null, $flag = null) {}
/**
* 修改socket的事件设置
* 可以修改可读/可写事件的回调设置和监听的事件类型
*
* @param $sock
* @param $read_callback
* @param null $write_callback
* @param null $flag
*/
function swoole_event_set($sock, $read_callback = null, $write_callback = null, $flag = null) {}
/**
* 从reactor中移除监听的Socket
*
* swoole_event_del应当与 swoole_event_add 成对使用
*
* @param int $sock
* @return bool
*/
function swoole_event_del($sock) {}
/**
* 退出事件轮询
*
* @return void
*/
function swoole_event_exit() {}
/**
* 获取MySQLi的socket文件描述符
*
* 可将mysql的socket增加到swoole中,执行异步MySQL查询。
* 如果想要使用异步MySQL,需要在编译swoole时制定--enable-async-mysql
* swoole_get_mysqli_sock仅支持mysqlnd驱动,php5.4以下版本不支持此特性
*
* @param resource $db mysqli
* @return int
*/
function swoole_get_mysqli_sock($db) {}
/**
* 投递异步任务到task_worker池中
*
* 此函数会立即返回,worker进程可以继续处理新的请求。
* 此功能用于将慢速的任务异步地去执行,比如一个聊天室服务器,可以用它来进行发送广播。
* 当任务完成时,在task_worker中调用swoole_server_finish($serv, "finish");
* 告诉worker进程此任务已完成。当然swoole_server_finish是可选的。
*
* 发送的$data必须为字符串,如果是数组或对象,请在业务代码中进行serialize处理,并在onTask/onFinish中进行unserialize。
* $data可以为二进制数据,最大长度为8K。字符串可以使用gzip进行压缩。
*
* 使用swoole_server_task必须为Server设置onTask和onFinish回调,
* 否则swoole_server_start会失败。此回调函数会在task_worker进程中被调用。
*
* 函数会返回一个$task_id数字,表示此任务的ID。如果有finish回应,onFinish回调中会携带$task_id参数。
*
* task_worker的数量在swoole_server_set参数中调整,如task_worker_num => 64,表示启动64个进程来接收异步任务。
* swoole_server_task和swoole_server_finish可发送$data的长度最大不得超过8K,此参数受SW_BUFFER_SIZE宏控制。
*
* @param object $serv
* @param string $data
* @return int $task_id
*/
function swoole_server_task($serv, $data) {}
/**
* task_worker进程中通知worker进程,投递的任务已完成
*
* 此函数可以传递结果数据给worker进程
* 使用swoole_server_finish函数必须为Server设置onFinish回调函数。此函数只可用于task_worker进程的onTask回调中
* swoole_server_finish是可选的。如果worker进程不关心任务执行的结果,可以不调用此函数
*
* @param object $serv
* @param string $response
* @return void
*/
function swoole_server_finish($serv, $response) {}
/**
* 删除定时器
*
* $interval 参数为定时器的间隔时间
* 根据定时器时间区分不同的定时器
*
* @param object $serv
* @param int $interval
* @return void
*/
function swoole_server_deltimer($serv, $interval) {}
/**
* 关闭服务器
*
* 此函数可以用在worker进程内。
*
* @param object $serv
* @return void
*/
function swoole_server_shutdown($serv) {}
/**
* 投递堵塞任务到task进程池
*
* taskwait与task方法作用相同,用于投递一个异步的任务到task进程池去执行。
* 与task不同的是taskwait是阻塞等待的,直到任务完成或者超时返回。
* $result为任务执行的结果,由$serv->finish函数发出。如果此任务超时,这里会返回false。
*
* taskwait是阻塞接口,如果你的Server是全异步的请不要使用它
*
* @param string $task_data
* @param float $timeout
* @return string
*/
function swoole_server_taskwait($task_data, $timeout = 0.5) {}
/**
* 进行事件轮询
*
* PHP5.4之前的版本没有在ZendAPI中加入注册shutdown函数。所以swoole无法在脚本结尾处自动进行事件轮询。
* 低于5.4的版本,需要在你的PHP脚本结尾处加swoole_event_wait函数,使脚本开始进行事件轮询。
*
* 5.4或更高版本不需要加此函数。
*
* @return void
*/
function swoole_event_wait() {}
/**
* 添加定时器,可用于客户端环境和fpm中
* @param $interval
* @param $callback
*/
function swoole_timer_add($interval, $callback) {}
/**
* 删除定时器
* @param $interval
* @param $callback
*/
function swoole_timer_del($interval) {}
/**
* swoole_client
*/
class swoole_client {
/**
* 函数执行错误会设置该变量
*
* @var
*/
public $errCode;
/**
* socket的文件描述符
*
* PHP代码中可以使用:
* $sock = fopen("php://fd/".$swoole_client->sock);
*
* 将swoole_client的socket转换成一个stream socket。可以调用fread/fwrite/fclose等函数进程操作。
* swoole_server中的$fd不能用此方法转换,因为$fd只是一个数字,$fd文件描述符属于主进程
* $swoole_client->sock可以转换成int作为数组的key.
*
* @var int
*/
public $sock;
/**
* swoole_client构造函数
*
* @param int $sock_type 指定socket的类型,支持TCP/UDP、TCP6/UDP64种
* @param int $sync_type SWOOLE_SOCK_SYNC/SWOOLE_SOCK_ASYNC 同步/异步
*/
public function __construct($sock_type, $sync_type = SWOOLE_SOCK_SYNC) {}
/**
* 连接到远程服务器
*
* @param string $host 是远程服务器的地址 v1.6.10+ 支持填写域名 Swoole会自动进行DNS查询
* @param int $port 是远程服务器端口
* @param float $timeout 是网络IO的超时,单位是s,支持浮点数。默认为0.1s,即100ms
* @param int $flag 参数在UDP类型时表示是否启用udp_connect。设定此选项后将绑定$host与$port,此UDP将会丢弃非指定host/port的数据包。
* 在send/recv前必须使用swoole_client_select来检测是否完成了连接
* @return bool
*/
public function connect($host, $port, $timeout = 0.1, $flag = 0) {}
/**
* 向远程服务器发送数据
*
* 参数为字符串,支持二进制数据。
* 成功发送返回的已发数据长度
* 失败返回false,并设置$swoole_client->errCode
*
* @param string $data
* @return bool
*/
public function send($data) {}
/**
* 从服务器端接收数据
*
* 如果设定了$waitall就必须设定准确的$size,否则会一直等待,直到接收的数据长度达到$size
* 如果设置了错误的$size,会导致recv超时,返回 false
* 调用成功返回结果字符串,失败返回 false,并设置$swoole_client->errCode属性
*
* @param int $size 接收数据的最大长度
* @param bool $waitall 是否等待所有数据到达后返回
* @return string
*/
public function recv($size = 65535, $waitall = false) {}
/**
* 关闭远程连接
*
* swoole_client对象在析构时会自动close
*
* @return bool
*/
public function close() {}
/**
* 注册异步事件回调函数
*
* @return bool
*/
public function on($event_name, $callback_function){}
}
class swoole_server
{
/**
* 主进程PID
* @var int
*/
public $master_pid;
/**
* 管理进程PID
* @var int
*/
public $manager_pid;
function __construct($host, $port, $mode = 3, $tcp_or_udp = 1){}
/**
* 设置事件回调函数
* @param $event_name
* @param $callback_function
*/
function on($event_name, $callback_function){}
/**
* 设置运行时参数
* @param array $config
*/
function set(array $config){}
/**
* 启动服务器
*/
function start(){}
/**
* 发送数据到客户端连接
* @param int $fd
* @param $response
* @param int $from_id
* @return bool
*/
function send(int $fd, $response, $from_id = 0){}
/**
* 关闭连接
* @param int $fd
* @param int $from_id
*/
function close(int $fd, $from_id = 0){}
/**
* 投递任务到task_worker进程去执行,并阻塞等待结果返回
* @param string $task_data
* @param float $timeout
* @return string
*/
function taskwait(string $task_data, float $timeout = 0.5){}
/**
* 投递一个异步任务
* @param string $task_data
* @param float $timeout
* @return int
*/
function task(string $task_data, int $dst_worker_id = -1){}
/**
* 任务完成后发送结果到对应的worker进程
* @param string $task_data
*/
function finish(string $task_data){}
/**
* 进行心跳检查,返回心跳超过约定时间的连接
*/
function heartbeat(){}
/**
* 返回连接的信息,支持TCP/UDP
* array (
* 'from_id' => 0,
* 'from_fd' => 12,
* 'connect_time' => 1392895129,
* 'last_time' => 1392895137,
* 'from_port' => 9501,
* 'remote_port' => 48918,
* 'remote_ip' => '127.0.0.1',
* )
* @return array | bool
*/
public function connection_info($fd, $from_id = -1){}
/**
* 遍历所有Server的TCP连接,这个接口是基于共享内存的,可以得到所有worker进程内的连接
*
* @return array | bool
*/
public function connection_list($start_fd = -1, $pagesize = 100){}
/**
* 重启所有worker进程
* @return null
*/
public function reload(){}
/**
* 关闭服务器
* @return null
*/
public function shutdown(){}
/**
* 增加监听端口
* @param $host
* @param $port
* @param $type
*/
public function addlistener($host, $port, $type = SWOOLE_SOCK_TCP){}
/**
* 增加定时器
* @param $interval
*/
public function addtimer($interval){}
/**
* 删除定时器
* @param $interval
*/
public function deltimer($interval){}
}
/**
* Class swoole_lock
*/
class swoole_lock {
/**
* @param int $type 为锁的类型
* @param string $lockfile 当类型为SWOOLE_FILELOCK时必须传入,指定文件锁的路径
* 注意每一种类型的锁支持的方法都不一样。如读写锁、文件锁可以支持 $lock->lock_read()。
* 另外除文件锁外,其他类型的锁必须在父进程内创建,这样fork出的子进程之间才可以互相争抢锁。
*/
public function __construct($type, $lockfile = NULL) {}
/**
* 加锁操作
*
* 如果有其他进程持有锁,那这里将进入阻塞,直到持有锁的进程unlock。
*/
public function lock() {}
/**
* 加锁操作
*
* 与lock方法不同的是,trylock()不会阻塞,它会立即返回。
* 当返回false时表示抢锁失败,有其他进程持有锁。返回true时表示加锁成功,此时可以修改共享变量。
*
* SWOOlE_SEM 信号量没有trylock方法
*/
public function trylock() {}
/**
* 释放锁
*/
public function unlock() {}
/**
* 阻塞加锁
*
* lock_read方法仅可用在读写锁(SWOOLE_RWLOCK)和文件锁(SWOOLE_FILELOCK)中,表示仅仅锁定读。
* 在持有读锁的过程中,其他进程依然可以获得读锁,可以继续发生读操作。但不能$lock->lock()或$lock->trylock(),这两个方法是获取独占锁的。
*
* 当另外一个进程获得了独占锁(调用$lock->lock/$lock->trylock)时,$lock->lock_read()会发生阻塞,直到持有锁的进程释放。
*/
public function lock_read() {}
/**
* 非阻塞加锁
*
* 此方法与lock_read相同,但是非阻塞的。调用会立即返回,必须检测返回值以确定是否拿到了锁。
*/
public function trylock_read() {}
}
/**
* IO事件循环
*
*
* swoole_client的并行处理中用了select来做IO事件循环。为什么要用select呢?
* 因为client一般不会有太多连接,而且大部分socket会很快接收到响应数据。
* 在少量连接的情况下select比epoll性能更好,另外select更简单。
*
* $read,$write,$error分别是可读/可写/错误的文件描述符。
* 这3个参数必须是数组变量的引用。数组的元素必须为swoole_client对象。
* $timeout参数是select的超时时间,单位为秒,接受浮点数。
*
* 调用成功后,会返回事件的数量,并修改$read/$write/$error数组。
* 使用foreach遍历数组,然后执行$item->recv/$item->send来收发数据。
* 或者调用$item->close()或unset($item)来关闭socket。
*
*
* @param array $read 可读
* @param array $write 可写
* @param array $error 错误
* @param float $timeout
*/
function swoole_client_select(array &$read, array &$write, array &$error, float $timeout) {}
/**
* swoole进程管理类
* 内置IPC通信支持,子进程和主进程之间可以方便的通信
* 支持标准输入输出重定向,子进程内echo,会发送到管道中,而不是输出屏幕
* Class swoole_process
*/
class swoole_process
{
/**
* 进程的PID
* @var int
*/
public $pid;
/**
* 管道PIPE
* @var int
*/
public $pipe;
/**
* @param mixed $callback 子进程的回调函数
* @param bool $redirect_stdin_stdout 是否重定向标准输入输出
* @param bool $create_pipe 是否创建管道
*/
function __construct($callback, $redirect_stdin_stdout = false, $create_pipe = true){}
/**
* 向管道内写入数据
* @param string $data
*/
function write($data){}
/**
* 从管道内读取数据
* @param int $buffer_len 最大读取的长度
* @return string
*/
function read($buffer_len = 8192){}
/**
* 退出子进程,实际函数名为exit,IDE将exit识别为关键词了,会有语法错误,所以这里叫_exit
*/
function _exit($code = 0){}
/**
* 阻塞等待子进程退出,并回收
* 成功返回一个数组包含子进程的PID和退出状态码
* 如array('code' => 0, 'pid' => 15001),失败返回false
* @return false | array
*/
static function wait(){}
/**
* 启动子进程
* @return int
*/
function start(){}
}
define('SWOOLE_VERSION', '1.6.9'); //当前Swoole的版本号
/**
* new swoole_server 构造函数参数
*/
define('SWOOLE_BASE', 1); //使用Base模式,业务代码在Reactor中直接执行
define('SWOOLE_THREAD', 2); //使用线程模式,业务代码在Worker线程中执行
define('SWOOLE_PROCESS', 3); //使用进程模式,业务代码在Worker进程中执行
/**
* new swoole_client 构造函数参数
*/
define('SWOOLE_SOCK_TCP', 1); //创建tcp socket
define('SWOOLE_SOCK_TCP6', 3); //创建tcp ipv6 socket
define('SWOOLE_SOCK_UDP', 2); //创建udp socket
define('SWOOLE_SOCK_UDP6', 4); //创建udp ipv6 socket
define('SWOOLE_TCP', 1); //创建tcp socket
define('SWOOLE_TCP6', 2); //创建tcp ipv6 socket
define('SWOOLE_UDP', 3); //创建udp socket
define('SWOOLE_UDP6', 4); //创建udp ipv6 socket
define('SWOOLE_UNIX_DGRAM', 5);
define('SWOOLE_UNIX_STREAM', 6);
define('SWOOLE_SOCK_SYNC', 0); //同步客户端
define('SWOOLE_SOCK_ASYNC', 1); //异步客户端
define('SWOOLE_SYNC', 0); //同步客户端
define('SWOOLE_ASYNC', 1); //异步客户端
/**
* new swoole_lock构造函数参数
*/
define('SWOOLE_FILELOCK', 2); //创建文件锁
define('SWOOLE_MUTEX', 3); //创建互斥锁
define('SWOOLE_RWLOCK', 1); //创建读写锁
define('SWOOLE_SPINLOCK', 5); //创建自旋锁
define('SWOOLE_SEM', 4); //创建信号量
define('SWOOLE_EVENT_WRITE', 1);
define('SWOOLE_EVENT_READ', 2);
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。