代码出处:https://git.oschina.net/afrxprojs/xgame-code_server ZooKeeper ?php//// 首先, 执行 zkCli.sh 进入 ZooKeeper 命令行工具界面,// 在命令行中可以执行以下操作 ://// 新建 Kev/Value// $ create /xgame 0// $ create /xgame/S00 0// $ create /xg
代码出处:https://git.oschina.net/afrxprojs/xgame-code_server ZooKeeper
<?php // // 首先, 执行 zkCli.sh 进入 ZooKeeper 命令行工具界面, // 在命令行中可以执行以下操作 : // // 新建 Kev/Value // $ create /xgame 0 // $ create /xgame/S00 0 // $ create /xgame/S00/conf/maintenanceTimeStr 0 // $ create /xgame/S00/conf/whiteList 0 // $ create /xgame/S00/conf/blackList 0 // // 之后执行 PHP 命令启动监听服务 : // // $ php ZkServ.php // // 注意 : 请事先确认是否已经安装 php-zookeeper 扩展? // 回到 ZooKeeper 界面, 尝试修改维护时间字符串 : // // $ set /xgame/S00/conf/maintenanceTimeStr [20150101000000,20151231235959] // // @import require_once("MyLog.php"); require_once("etc/AppName.php"); require_once("etc/ServerName.php"); require_once("etc/ZooKeeper.php"); /** * ZooKeeper 服务 * * @auth jinhaijiang * @since 2015/6/28 * @see https://git.oschina.net/afrxprojs/xgame-code_server * */ class ZkServ extends Zookeeper { /** * 应用名称 * * @var String * */ public $_appName; /** * 服务器名称 * * @var String * */ public $_serverName; /** * ZooKeeper 路径字典 * * @var Array * */ private $_zkPathMap; /** * 启动服务 * */ public function startUp() { // 获取应用名称和服务器名称 $appName = $this->_appName; $serverName = $this->_serverName; // 初始化路径字典 $this->_zkPathMap = array( "/${appName}/${serverName}/conf/maintenanceTimeStr" => "updateMaintenanceTime", "/${appName}/${serverName}/conf/whiteList" => "updateWhiteList", "/${appName}/${serverName}/conf/blackList" => "updateBlackList", ); foreach ($this->_zkPathMap as $key => $val) { // 输出调试日志 MyLog::LOG()->debug("准备监听 : $key"); // 设置监听 $this->get($key, array($this, "watch")); } } /** * 监听数据变化 * * @param $eventType * @param $eventState * @param $eventKey * */ public function watch($eventType, $eventState, $eventKey) { // 记录日志信息 MyLog::LOG()->info("接到数据"); // 输出调试信息 MyLog::LOG()->debug("eventType = ${eventType}, eventState = ${eventState}, eventKey = ${eventKey}"); // 获取数据 $data = $this->get($eventKey); // 获取函数引用并调用 $funcRef = $this->_zkPathMap[$eventKey]; $this->$funcRef($data); // 循环监听 $this->get($eventKey, array($this, "watch")); } /** * 更新停服维护时间, * 注意这是一个回调函数! 会在 watch 函数中被间接调用 * * @param String $value * @return void * */ private function updateMaintenanceTime($value) { // 记录日志信息 MyLog::LOG()->info("维护时间 = $value"); // 获取 JSON 数组 $jsonArr = json_decode($value); $startTimeStr = $jsonArr[0]; $endTimeStr = $jsonArr[1]; $text = <<< __EOF <?php \$GLOBALS["MAINTENANCE_START_TIME"] = $startTimeStr; \$GLOBALS["MAINTENANCE_END_TIME"] = $endTimeStr; __EOF; // 目标文件 $targetFile = dirname(__FILE__) . "/etc/MaintenanceTime.php"; // 写出目标文件 self::writeToFile($targetFile, $text); } /** * 更新白名单 * 注意这是一个回调函数! 会在 watch 函数中被间接调用 * * @param String $value * @return void * */ private function updateWhiteList($value) { // 记录日志信息 MyLog::LOG()->info("白名单 = ${value}"); // 获取 JSON 数组 $jsonArr = json_decode($value); $text = <<< __EOF <?php \$GLOBALS["WHITE_LIST"] = array( __EOF; foreach ($jsonArr as $json) { // 获取平台 UUId $platformUUId = $json; // 添加到文本 $text .= "\n\t\"${platformUUId}\" => 1, "; } $text .= "\n);"; // 目标文件 $targetFile = dirname(__FILE__) . "/etc/WhiteList.php"; // 写出目标文件 self::writeToFile($targetFile, $text); } /** * 更新黑名单 * 注意这是一个回调函数! 会在 watch 函数中被间接调用 * * @param String $value * @return void * */ private function updateBlackList($value) { // 记录日志信息 MyLog::LOG()->info("白名单 = ${value}"); // 获取 JSON 数组 $jsonArr = json_decode($value); $text = <<< __EOF <?php \$GLOBALS["BLACK_LIST"] = array( __EOF; foreach ($jsonArr as $json) { // 获取平台 UUId $platformUUId = $json; // 添加到文本 $text .= "\n\t\"${platformUUId}\" => 1, "; } $text .= "\n);"; // 目标文件 $targetFile = dirname(__FILE__) . "/etc/BlackList.php"; // 写出目标文件 self::writeToFile($targetFile, $text); } /** * 写出目标文件 * * @param $targetFile 目标文件的完整路径 * @param $text 文本内容 * @return void * */ private static function writeToFile($targetFile, $text) { // 打开文件 $fp = fopen($targetFile, "w"); if (!$fp) { // 如果打开文件失败, // 则直接退出! MyLog::LOG()->error("打开文件 ${targetFile} 失败!!"); return; } // 写出文件内容 $result = fwrite($fp, $text); if (!$result) { // 如果写出文件失败, // 则记录错误日志 MyLog::LOG()->error( "写出文件 ${targetFile} 失败!!" ); } fflush($fp); fclose($fp); } } // 获取服务器名称 $appName = $GLOBALS["APP_NAME"]; $serverName = $GLOBALS["SERVER_NAME"]; // ZooKeeper 配置 $zkHost = $GLOBALS["ZK_SERVER_HOST"]; $zkPort = $GLOBALS["ZK_SERVER_PORT"]; // 创建服务对象 $servObj = new ZkServ("${zkHost}:${zkPort}"); $servObj->_appName = $appName; $servObj->_serverName = $serverName; // 启动服务 $servObj->startUp(); while (true) { MyLog::LOG()->info("live"); sleep(60); }
陳述
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress
人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool
免費脫衣圖片

Clothoff.io
AI脫衣器

Video Face Swap
使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章
刺客信條陰影:貝殼謎語解決方案
3 週前ByDDD
Windows 11 KB5054979中的新功能以及如何解決更新問題
3 週前ByDDD
在哪裡可以找到原子中的起重機控制鑰匙卡
3 週前ByDDD
<🎜>:死鐵路 - 如何完成所有挑戰
4 週前ByDDD
Atomfall指南:項目位置,任務指南和技巧
1 個月前ByDDD

熱工具

ZendStudio 13.5.1 Mac
強大的PHP整合開發環境

Dreamweaver Mac版
視覺化網頁開發工具

VSCode Windows 64位元 下載
微軟推出的免費、功能強大的一款IDE編輯器

Atom編輯器mac版下載
最受歡迎的的開源編輯器

SecLists
SecLists是最終安全測試人員的伙伴。它是一個包含各種類型清單的集合,這些清單在安全評估過程中經常使用,而且都在一個地方。 SecLists透過方便地提供安全測試人員可能需要的所有列表,幫助提高安全測試的效率和生產力。清單類型包括使用者名稱、密碼、URL、模糊測試有效載荷、敏感資料模式、Web shell等等。測試人員只需將此儲存庫拉到新的測試機上,他就可以存取所需的每種類型的清單。