php-msf
2017-09-09 21:29:22 3 举报
开源php分布式微服务框架php-msf uml类图
作者其他创作
大纲/内容
\\PG\\MSF\\Base\\Core
$__useCount$__genTime$__isContruct$stdClass$reflections$__isDestroy$redisPools$mysqlPools$redisProxies
setContext()destroy()__construct()__sleep()__unsleep()getServerInstance()getConfig()getPack()getRedisPool()getMysqlPool()getRedisProxy()setRedisPools()setRedisProxies()isUse()getIsDestroy()
check()handle()startCheck()
\\PG\\MSF\\Pools\\Miner
$mysqlPool$activeConfig$PdoConnection$autoQuote$option$select$insert$replace$update$delete$set$from$join$where$groupBy$having$orderBy$limit$setPlaceholderValues$wherePlaceholderValues$havingPlaceholderValues$isInto$intoColums$intoValuesINNER_JOINLEFT_JOINRIGHT_JOINLOGICAL_ANDLOGICAL_OREQUALSNOT_EQUALSLESS_THANLESS_THAN_OR_EQUALGREATER_THANGREATER_THAN_OR_EQUALINNOT_INLIKENOT_LIKEILIKEREGEXNOT_REGEXBETWEENNOT_BETWEENISIS_NOTORDER_BY_ASCORDER_BY_DESCBRACKET_OPENBRACKET_CLOSE
__construct()calcFoundRows()option()distinct()values()set()intoColumns()intoValues()innerJoin()join()leftJoin()rightJoin()andWhere()orWhere()whereIn()whereNotIn()whereBetween()whereNotBetween()andHaving()orHaving()havingIn()havingNotIn()havingBetween()havingNotBetween()insertInto()insert()replaceInto()replace()updateInto()update()__toString()getStatement()isSelect()getSelectString()getOptionsString()getFromString()getFrom()getFromAlias()getJoinString()isUpdate()getUpdate()getWhereString()getAutoQuote()setAutoQuote()autoQuote()quote()getPdoConnection()setPdoConnection()getGroupByString()getHavingString()getOrderByString()getLimitString()isInsert()getInsertString()getInsert()getIntoString()getSetString()isReplace()getReplaceString()getReplace()getUpdateString()isDelete()getDeleteString()go()mergeInto()mergeSelectInto()mergeOptionsInto()select()mergeFromInto()from()mergeJoinInto()mergeWhereInto()openWhere()closeWhere()where()mergeGroupByInto()groupBy()mergeHavingInto()openHaving()closeHaving()having()mergeOrderByInto()orderBy()mergeLimitInto()limit()getLimit()getLimitOffset()mergeInsertInto()mergeSetInto()mergeReplaceInto()mergeUpdateInto()mergeDeleteInto()delete()clear()pdoCommitTrans()pdoBeginTrans()pdoRollBackTrans()pdoQuery()pdoConnect()getPlaceholderValues()getSetPlaceholderValues()getWherePlaceholderValues()getHavingPlaceholderValues()pdoInsertId()pdoExecute()isJoinUnique()criteria()orCriteria()criteriaIn()criteriaNotIn()criteriaBetween()criteriaNotBetween()getSelectStatement()getJoinCriteriaUsingPreviousTable()getCriteriaString()getInsertStatement()getReplaceStatement()getUpdateStatement()getDeleteStatement()isDeleteTableFrom()openCriteria()closeCriteria()
\\PG\\MSF\\Coroutine\\Task
$destroy$routine$stack$controller$id$exception$callBack
__construct()resetRoutine()getCallBack()resetCallBack()getController()setException()run()handleTaskTimeout()handleTaskException()isFinished()getRoutine()destroy()
\\PG\\MSF\\Proxy\\RedisProxyCluster
$name$pools$goodPools$keyPrefix$hashKey$isRandom
__construct()startCheck()handle()evalMock()check()dispatch()syncCheck()generateUniqueKey()random()single()multi()
\\PG\\MSF\\Coroutine\\CTask
$maxTimeout$request$result$timeout$requestTime$responseTime$ioBack$ioBackKey$isBreak$requestId$id$taskProxyData
Properties Constants__construct()getResult()throwTimeOutException()isTimeout()nextRun()destroy()__unsleep()breakx()setTimeout()send()
\\PG\\MSF\\Base\\Child
$reflections
setContext()destroy()
\\PG\\MSF\\Base\\HttpServer
$processType$daemonize$pidFile$scheduler$name$user$workerNum$taskNum$tickTime$pack$onErrorHandle$server$config$log$sysCache$sysTimers$MSFSrcDir$objectPool$httpSocketName$httpPort$httpEnable$templateEngine$instance$_masterPid$logFile$_startFile$_worker$route$stdClass$reflectionsversionmode
__construct()getTimerContext()getInstance()setConfig()run()setProcessTitle()setServerSet()beforeSwooleStart()onStart()onWorkerStart()onClose()onWorkerStop()onTask()onFinish()onPipeMessage()onWorkerError()onManagerStart()onManagerStop()__call()registerTimer()displayErrorHandler()checkErrors()isTaskWorker()close()onErrorHandle()setContext()destroy()start()setTemplateEngine()onRequest()genLogId()init()parseCommand()initWorkers()getCurrentUser()displayUI()startSwooles()
\\PG\\MSF\\Pools\\AsynPool
$configNo protected methods found $commands$pool$callBacks$workerId$server$swooleServer$token$waitConnectNum$asynManagerMAX_TOKEN
__construct()addTokenCallback()distribute()serverInit()workerInit()pushToPool()getSync()
\\PG\\MSF\\Coroutine\\Dns
$maxTimeout$request$result$timeout$requestTime$responseTime$ioBack$ioBackKey$isBreak$requestId$client$headers
__construct()getResult()throwTimeOutException()isTimeout()nextRun()destroy()__unsleep()breakx()setTimeout()send()
isTimeout()send()getResult()
\\PG\\MSF\\Coroutine\\MySql
$maxTimeout$request$result$timeout$requestTime$responseTime$ioBack$ioBackKey$isBreak$requestId$mysqlAsynPool$bindId$sql
\\PG\\MSF\\Coroutine\\Base
$maxTimeout$request$result$timeout$requestTime$responseTime$ioBack$ioBackKey$isBreak$requestId
\\PG\\MSF\\Pools\\AsynPoolManager
$swooleServer$process$registerDir$notEventAdd
__construct()eventAdd()noEventAdd()getPipeMessage()distribute()registerAsyn()writePipe()sendMessageToWorker()
\\PG\\MSF\\Proxy\\RedisProxyFactory
$redisCoroutines
makeProxy()
\\PG\\MSF\\Coroutine\\Redis
$maxTimeout$request$result$timeout$requestTime$responseTime$ioBack$ioBackKey$isBreak$requestId$name$arguments$keyPrefix$hashKey$phpSerialize$redisSerialize$redisAsynPool
__construct()getResult()throwTimeOutException()isTimeout()nextRun()destroy()__unsleep()breakx()setTimeout()send()unSerializeHandler()canUnserialize()realUnserialize()
\\PG\\MSF\\Base\\MSFServer
$httpSocketName$httpPort$httpEnable$templateEngine$processType$daemonize$pidFile$scheduler$name$user$workerNum$taskNum$tickTime$pack$onErrorHandle$server$config$log$sysCache$sysTimers$MSFSrcDir$objectPool$objectPoolBuckets$taskAtomic$tidPidTable$instance$_masterPid$logFile$_startFile$_worker$route$stdClass$reflections$redisProxyManager$asynPools$asynPoolManagerversionmodeSERVER_NAME
__construct()setConfig()start()onWorkerStart()setTemplateEngine()onRequest()genLogId()getTimerContext()getInstance()run()setProcessTitle()setServerSet()beforeSwooleStart()onStart()onClose()onWorkerStop()onTask()onFinish()onPipeMessage()onWorkerError()onManagerStart()onManagerStop()__call()registerTimer()displayErrorHandler()checkErrors()isTaskWorker()close()onErrorHandle()setContext()destroy()initAsynPools()initRedisProxies()addAsynPool()getAsynPool()addRedisProxy()getRedisProxy()setRedisProxy()getRedisProxies()statistics()onInitTimer()getAllTaskMessage()init()parseCommand()initWorkers()getCurrentUser()displayUI()startSwooles()
\\PG\\MSF\\Base\\Input
$__useCount$__genTime$__isContruct$stdClass$request$__serializeRequest$__isDestroy$redisPools$mysqlPools$redisProxies$reflections
__construct()__sleep()__unsleep()getServerInstance()getConfig()getPack()getRedisPool()getMysqlPool()getRedisProxy()setRedisPools()setRedisProxies()destroy()isUse()getIsDestroy()setContext()__wakeup()set()reset()postGet()post()get()getPost()getAllPostGet()getAllPost()getAllGet()getAllHeader()getAllServer()getRawContent()setPost()setGet()setAllPost()setAllGet()getCookie()getFile()getServer()getRequestMethod()getRequestUri()getPathInfo()getRemoteAddr()getHeader()
Pool
$__wrapper$map$instance
getInstance()get()push()__construct()applyNewPool()
\\PG\\MSF\\Coroutine\\Http
$maxTimeout$request$result$timeout$requestTime$responseTime$ioBack$ioBackKey$isBreak$requestId$client$data$path$method
\\PG\\MSF\\Base\\Server
$processType$daemonize$pidFile$scheduler$name$user$workerNum$taskNum$tickTime$pack$onErrorHandle$server$config$log$sysCache$sysTimers$MSFSrcDir$objectPool$reflections$instance$_masterPid$logFile$_startFile$_worker$route$stdClassversionmode
setContext()destroy()__construct()getTimerContext()getInstance()setConfig()run()setProcessTitle()setServerSet()beforeSwooleStart()onStart()onWorkerStart()onClose()onWorkerStop()onTask()onFinish()onPipeMessage()onWorkerError()onManagerStart()onManagerStop()__call()registerTimer()displayErrorHandler()checkErrors()isTaskWorker()close()onErrorHandle()init()parseCommand()initWorkers()getCurrentUser()displayUI()startSwooles()
\\PG\\MSF\\Coroutine\\Scheduler
$IOCallBack$taskMap
__construct()schedule()start()
\\PG\\MSF\\Proxy\\RedisProxyMasterSlave
$name$pools$master$slaves$goodPools$readOperation
__construct()startCheck()handle()check()
getAsynName()distribute()execute()serverInit()workerInit()pushToPool()prepareOne()addTokenCallback()getSync()
\\PG\\MSF\\Pools\\MysqlAsynPool
$config$dbQueryBuilder$bindPool$commands$pool$callBacks$workerId$server$swooleServer$token$waitConnectNum$asynManager$mysqlMaxCount$active$mysqlClientMAX_TOKENASYN_NAME
__construct()addTokenCallback()distribute()serverInit()workerInit()pushToPool()getSync()getDBQueryBuilder()execute()prepareOne()reconnect()freeBind()onClose()getAsynName()begin()bind()query()coroutineBegin()commit()coroutineCommit()rollback()coroutineRollback()
\\PG\\MSF\\Base\\MSFCli
$objectPoolBuckets$taskAtomic$tidPidTable$httpSocketName$httpPort$httpEnable$templateEngine$processType$daemonize$pidFile$scheduler$name$user$workerNum$taskNum$tickTime$pack$onErrorHandle$server$config$log$sysCache$sysTimers$MSFSrcDir$objectPool$redisProxyManager$asynPools$asynPoolManager$instance$_masterPid$logFile$_startFile$_worker$route$stdClass$reflectionsSERVER_NAMEversionmode
__construct()start()setConfig()beforeSwooleStart()initAsynPools()initRedisProxies()setServerSet()onTask()onPipeMessage()addAsynPool()getAsynPool()addRedisProxy()getRedisProxy()setRedisProxy()getRedisProxies()onWorkerStart()statistics()onInitTimer()onClose()getAllTaskMessage()setTemplateEngine()onRequest()genLogId()getTimerContext()getInstance()run()setProcessTitle()onStart()onWorkerStop()onFinish()onWorkerError()onManagerStart()onManagerStop()__call()registerTimer()displayErrorHandler()checkErrors()isTaskWorker()close()onErrorHandle()setContext()destroy()onConsoleRequest()init()parseCommand()initWorkers()getCurrentUser()displayUI()startSwooles()
\\PG\\MSF\\Base\\Output
$__useCount$__genTime$__isContruct$stdClass$codes$response$request$__isDestroy$redisPools$mysqlPools$redisProxies$reflections$controller
__construct()__sleep()__unsleep()getServerInstance()getConfig()getPack()getRedisPool()getMysqlPool()getRedisProxy()setRedisPools()setRedisProxies()destroy()isUse()getIsDestroy()setContext()set()setStatusHeader()setContentType()setHeader()setCookie()output()outputJson()outputView()end()
\\PG\\MSF\\Coroutine\\CNull
$instance
__construct()getInstance()
\\PG\\MSF\\Pools\\CoroutineRedisProxy
$config$connect$redisClient$keyPrefix$hashKey$phpSerialize$redisSerialize$commands$pool$callBacks$workerId$server$swooleServer$token$waitConnectNum$asynManager$redisMaxCount$active$coroutineRedisHelp
__construct()cache()evalMock()__call()generateUniqueKey()serializeHandler()unSerializeHandler()canUnserialize()realUnserialize()
\\PG\\MSF\\Pools\\RedisAsynPool
$config$connect$redisClient$keyPrefix$hashKey$phpSerialize$redisSerialize$commands$pool$callBacks$workerId$server$swooleServer$token$waitConnectNum$asynManager$redisMaxCount$active$coroutineRedisHelpMAX_TOKENASYN_NAME
__construct()addTokenCallback()distribute()serverInit()workerInit()pushToPool()getSync()__call()go()getCoroutine()execute()prepareOne()reconnect()onClose()getAsynName()
0 条评论
下一页