代码拉取完成,页面将自动刷新
<?php
class UnitTest extends \Zan\Framework\Testing\UnitTest {}
class TcpServer extends \Zan\Framework\Network\Tcp\Server {}
if (!function_exists("nova_encode")) {
/**
* @param string $service_name
* @param string $method_name
* @param int $ip
* @param int $port
* @param int $seq_no
* @param string $attach_data
* @param string $in_data
* @param string $out_buffer
* @return bool
*/
function nova_encode($service_name, $method_name, $ip, $port, $seq_no, $attach_data, $in_data, &$out_buffer) {
return false;
}
}
if (function_exists("nova_decode")) {
/**
* @param string $in_buffer
* @param string $service_name
* @param string $method_name
* @param int $ip
* @param int $port
* @param int $seq_no
* @param string $attach_data
* @param string $out_data
* @return bool
*/
function nova_decode($in_buffer, &$service_name, &$method_name, &$ip, &$port, &$seq_no, &$attach_data, &$out_data) {
return false;
}
}
class swoole_connpool
{
/**
* 连接正常
*/
const SWOOLE_CONNNECT_OK = 1;
/**
* 连接异常
*/
const SWOOLE_CONNNECT_ERR = 2;
/**
* TCP 连接池
*/
const SWOOLE_CONNPOOL_TCP = 1;
/**
* redis 连接池
*/
const SWOOLE_CONNPOOL_REDIS = 2;
/**
* mysql 连接池
*/
const SWOOLE_CONNPOOL_MYSQL = 3;
/**
* http 连接池
*/
const SWOOLE_CONNPOOL_HTTP = 4;
/**
* \swoole_connpool constructor.
* @param int $connPoolType
*/
public function __construct(int $connPoolType) { }
/**
* createConnPool
* 创建连接池,接口内部对所有已经设置的参数进行校验
*
* @param int $minPoolnum 连接池最小对象个数
* @param int $maxPoolnum 连接池最大对象个数
* @return bool
*/
public function createConnPool(int $minPoolnum, int $maxPoolnum){ }
/**
* setCfg 连接配置,支持重置
* @param array $cfg
* @param array $cfg 连接池连接配置信息, 参见mysql/redis 连接信息,createConnpool 会对该参数进行校验
* @return bool
*
* hbTimeout
* connectTimeout
* hbIntervalTime 默认500
*
* 心跳需要同时配置:
* hbIntervalTime
* on hbConstruct
* on hbCheck
*/
public function setConfig(array $cfg){ }
/**
* on 回调设置
*
* @param string $hbCbName 回调名称
* ```
* [
* "hbConstruct" #string 心跳消息构造
* "hbCheck" #string 心跳回复校验
* ]
* ```
* @param callable $hbCallback 回调函数,参见hbConstruct/hbCheck,
* @return bool
*/
public function on(string $hbCbName, callable $hbCallback){ }
/**
* get 获取连接对象
*
* @param callable $objCall 对象回调,参见@objectCallback
* @param int $timeout 超时时间
* @return int 请求ID,false:接口调用失败
*/
public function get(int $timeout, callable $objCall){ }
/**
* release
* 释放连接对象,会对用户参数进行校验
*
* @param \swoole_client|\swoole_redis|\swoole_mysql|\swoole_http_client $connObj
* @param int $conStatus [option] 连接状态,可选,默认为SWOOLE_CONNOBJ_CONNECTED
* @return bool
*/
public function release($connObj, int $conStatus = self::SWOOLE_CONNNECT_OK){}
/**
* destroy 释放连接池对象,调用此接口前,需要将连接对象全部释放
*/
public function destroy() { }
/**
* @return array
* [
* "all_conn_obj" => 0,
* "idle_conn_obj" => 0,
* ]
*/
public function getStatInfo() { }
}
/**
* hbConstruct
* 心跳信息构造
*
* @return array 发送心跳参数
*/
function hbConstruct() {
return [
// "method" => "query",
// "args" => [$sql],
];
}
/**
* hbCheck
* 心跳回复内容检测
*
* @param \swoole_connpool $pool 连接池对象
* @param |swoole_client|swoole_http_client|swoole_mysql|swoole_redis $conn 连接对象
* @param mixed $data 心跳回复内容
* @return true :连接正常,false:连接异常
*/
function hbCheck(\swoole_connpool $pool, $conn, $data) { }
/**
* objectCallback
* 异步获取对象回调接口
*
* @param \swoole_connpool $pool 连接池对象
* @param |swoole_client|swoole_http_client|swoole_mysql|swoole_redis|null $conn 连接对象
* 获取对象失败时,返回空
*/
function objectCallback(\swoole_connpool $pool, $conn) {
// 说明: 使用$connObj前需判断$connObj是否为空
if (empty($conn)) {
return;
}
// to do something
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。