fixed: 恢复日志模块

Gameserver/Amfphp/test.php

@@ -10,25 +10,4 @@ echoLine("tsDay:" . tsDay());
 //set_time_limit(15);                                                           # 设置执行超时时间
 //
 //
-//var_dump(TimeUtil::Hour());
-//
-//var_dump(date('YmdH'));
-//$arr = (array) GameConfig::item_weapon();
-//var_dump($arr);
-//uksort($arr, function ($a, $b) {
-//    return intval($a) < intval($b);
-//});
-////var_dump($arr);
-//$wp = null;
-//$hero_typeId = 101005;
-//foreach ($arr as $id => $mo) {
-////            isEditor() and $mo = new \sm_item_weapon();
-//    $heroList = explode(',', $mo->hero_id);
-//    foreach ($heroList as $hero_id) {
-//        if ($hero_id == $hero_typeId) {
-//            $wp = $mo;
-//            break;
-//        }
-//    }
-//}
-//var_dump($wp);
+ 

Gameserver/Amfphp/util/CLog.php

@@ -48,14 +48,13 @@ class CLog {
     /**
      * @return string 日志目录
      */
-    private static function GetDir() {
-        // 线上版的时候会是linux系统, 单独指定目录, 测试的时候就放到代码旁边得了
-        static $dir = null;
-        if ($dir) {
-            return $dir;
+    private static function GetDir($subfolder = null) {
+        # 线上版的时候会是linux系统, 单独指定目录, 测试的时候就放到代码旁边得了
+        $dir = (GAME_ONLINE ? "/data/" : ROOTDIR . "/../" ) . "logs/" . PROJECTNAME . "/";
+        if (!empty($subfolder)) {                                               # 如果有子目录, 附加
+            $dir .= $subfolder . "/";
         }
-        $dir = (SDK_GAME_ONLINE ? "/data/" : ROOTDIR . "/../" ) . "logs/" . PROJECTNAME . "/";
-        if (is_dir($dir) || mkdir($dir, 0777, true)) {
+        if (is_dir($dir) || mkdir($dir, 0777, true)) {                          # 如果目录不存在, 创建
             return $dir;
         }
         exit("can not access log directory!");
@@ -74,7 +73,9 @@ class CLog {
     }
 
     /**
-     * 断言,
+     * 断言日志,注意此断言不是打断程序执行的那种.
+     * 如果断言失败,则会在日志里面留下一条Err记录,记录内容为errmsg.
+     * 如果判断成功,且设置了okmsg, 则会在日志里面留下一条info记录记录内容为OKmsg.
      * @param bool $condition 条件/条件表达式
      * @param string $errmsg 条件不成立时输出到日志中的信息, 日志级别err
      * @param string $okmsg  【可选】默认(null), 当条件成立时不记录任何消息, 除非特别指定了消息内容.日志级别info
@@ -123,19 +124,13 @@ class CLog {
      * 将缓存中的数据写入存储设备并清除缓存
      */
     public static function flush() {
-//        self::flush2File(enum_LogLevel::Info);                                  # 普通信息写到本地文件
-//        self::flush2File(enum_LogLevel::Warn);
-        self::flush2MySQL(enum_LogLevel::Info);
-        self::flush2MySQL(enum_LogLevel::Warn);
-        if (SDK_GAME_ONLINE) {
-//            self::flush2Redis(enum_LogLevel::Err);                              # 外网错误日志写入redis
-            self::flush2MySQL(enum_LogLevel::Err);
-        } else {
-//            self::flush2File(enum_LogLevel::Err);                               # 内网错误日志写入本地文件
-            self::flush2MySQL(enum_LogLevel::Err);
-        }
+        self::flush2Redis(enum_LogLevel::Info);
+        self::flush2Redis(enum_LogLevel::Warn);
+        self::flush2Redis(enum_LogLevel::Err);
     }
 
+// <editor-fold defaultstate="collapsed" desc="辅助方法">
+
     /**
      * 将日志写入文件
      * @global type $zoneid
@@ -153,12 +148,8 @@ class CLog {
             foreach ($arr as $msg) {
                 $n = fputs($fd, $msg . PHP_EOL);
                 if (false === $n) {                                             # 写入时失败
-                    throw new \Exception("写入 $fileName 时失败");
+                    throw new \Exception("写入 $fileName 时失败");               # 这种的就得靠查找系统(nginx/php-fpm)日志了
                 }
-                // todo: 其实写入日志也是有失败几率的, 当写入日志也失败的时候,
-                // 抛出异常, 让nginx来记录下些东西, 但是如果是在errorhandler
-                // 中写日志的时候出错呢......
-                //                              -wg 2017年8月5日 08:56:29
             }
             self::$$typename = array();                                         # 清空数据
         }
@@ -174,9 +165,12 @@ class CLog {
         $key = "log-" . $typename;
         $arr = self::$$typename;                                                # 取对应类型的数组
         if (count($arr) > 0) {
-            redis()->lpush($key, $arr);
-            if (redis()->llen($key) > self::redis_log_trim_max + self::redis_log_trim_once) {# 达到清理条件
-                redis()->ltrim($key, 0, -self::redis_log_trim_once);            # 缩减记录
+            if (null != req()) {
+                $arr[] = "" . req();
+            }
+            gMem()->lpush($key, $arr);
+            if (gMem()->llen($key) > self::redis_log_trim_max + self::redis_log_trim_once) {# 达到清理条件
+                gMem()->ltrim($key, 0, -self::redis_log_trim_once);             # 缩减记录
             }
             self::$$typename = array();                                         # 清空数据
         }
@@ -192,18 +186,16 @@ class CLog {
         $arr = self::$$typename;                                                # 取对应类型的数组
 
         if (count($arr) > 0) {
-            // 创建表
             $sql = "create table  if not exists `$key` (`row` INT(11) NOT NULL AUTO_INCREMENT COMMENT '自增行号', `msg` TEXT NULL COMMENT '错误消息内容',	PRIMARY KEY (`row`)) COLLATE='utf8_general_ci' ENGINE=InnoDB;";
-            daoInst()->exec($sql);
-            // 插入数据
+            daoInst()->exec($sql);                                              # 创建表
             $data = array();
-            array_map(function($v) use(&$data) {
-                $data[] = "(" . daoInst()->quote($v) . ")";
+            array_map(function ($v) use (&$data) {
+                $s = daoInst()->quote($v);
+                $data[] = "(" . $s . ")";
             }, $arr);
             $sql_insert = "insert into `$key` (`msg`) values " . implode(',', $data) . " ;";
-            daoInst()->exec($sql_insert);
-            // 检查表大小
-            $n = daoInst()->select()->from("`$key`")->count();                  # 查一下当前表大小  
+            daoInst()->exec($sql_insert);                                       # 执行插入操作
+            $n = daoInst()->select()->from("`$key`")->count();                  # 查一下当前表大小
             $max = 150000;                                                      # 最多保留15万条记录
             $del_once = 10000;                                                  # 超过15万,清理一次,一次删除1万条
             if ($n > $max) {
@@ -214,31 +206,102 @@ class CLog {
         }
     }
 
+    /**
+     * 生成日志,格式: [x区][时间][文件][tag]: msg
+     * @global \loyalsoft\type $zoneid
+     * @param type $msg
+     * @param type $tag
+     * @return string
+     */
+    private static function makeLogMsg($msg, $tag = null) {
+        global $zoneid;
+        $array = debug_backtrace();
+        while (isset($array[0]) && isset($array[0]['file']) && $array[0]['file'] == __FILE__) {
+            array_shift($array);
+        }
+        $row = $array[0];
+        $server_addr = isset($_SERVER['SERVER_ADDR']) ? $_SERVER['SERVER_ADDR'] : "-";
+        $client_addr = isset($_SERVER['REMOTE_ADDR']) ? $_SERVER['REMOTE_ADDR'] : "-";
+        $uid = empty(req()->uid) ? "-" : req()->uid;
+        $str = "[" . $server_addr . "][$zoneid 区][" . $uid . "]"                          # 请求主机ip地址、分区, uid
+                . "[" . date('Y-m-d H:i:s') . "][" . $client_addr . "]["                   # 时间, 客户端来源ip地址
+                . (isset($row['file']) ? CommUtil::str2UTF8(basename($row['file'])) : '-') # 所在文件名
+                . ":" . (isset($row['line']) ? $row['line'] : "???")#                      # 所在行
+                . "]" . (isset($tag) ? "[" . CommUtil::str2UTF8($tag) . "]" : "")          # 标签
+                . "=> " . var_export($msg, true)#                                          # 内容
+                . PHP_EOL;
+        return $str;
+    }
+
+// </editor-fold>
 //
-// 避免异常导致缓存丢失, 付费模块的日志直接写入文件
-// <editor-fold defaultstate="collapsed" desc=" 付费相关日志, 无缓存 ">
+// <editor-fold defaultstate="collapsed" desc="优化后的文件日志(引入cache)">
 
     /**
-     * 输出日志 到pay.log
-     * @param mixed $msg 参数是字符串则直接输出,否则调用json_encode
+     * 写入文件日志
+     * @global \loyalsoft\type $zoneid
+     * @param type $type
+     * @param type $msg
+     * @return type
      */
-    public static function pay($msg) {
-        if (SDK_GAME_ONLINE) {
-            self::Paylog2Mysql($msg);
-        } else {           
-            $fileName = self::GetDir() . "pay.log";          
-            self::Log2File($fileName, $msg);
+    private static function fileLog($type, $msg) {
+        $fileName = self::GetDir($type) . date('Ymd') . ".log";                 # 日志文件名(按天分割)
+        $fd = fopen($fileName, "a");
+        if (is_array($msg) || is_object($msg)) {
+            $msg = JsonUtil::encode($msg);
+        }
+        global $zoneid;
+        fputs($fd, "[" . self::dtCurrent() . "] $zoneid 区, " . $msg . "\r\n");
+        fclose($fd);
+    }
+
+    private static $cache = array();
+
+    private static function output2($type, $msg) {
+        if (!isset(self::$cache[$type])) {
+            self::$cache[$type] = array();
+        }
+        if (is_array($msg) || is_object($msg)) {
+            $msg = JsonUtil::encode($msg);
+        }
+        global $zoneid;
+        self::$cache[$type][] = "[" . self::dtCurrent() . "] $zoneid 区, " . $msg . "\r\n";
+    }
+
+    private static function flushFileCache() {
+        if (is_array(self::$cache)) {
+            foreach (self::$cache as $t => $varr) {
+                $fileName = self::GetDir($t) . date('Ymd') . ".log";            # 日志文件名(按天分割)
+                $fd = fopen($fileName, "a");
+                if (is_array($varr)) {
+                    foreach ($varr as $msg) {
+                        fputs($fd, $msg);
+                    }
+                }
+                fclose($fd);
+            }
+            self::$cache = array();
         }
     }
 
+// </editor-fold>
+//
+// 避免异常导致缓存丢失, 付费模块的日志直接写入文件
+// <editor-fold defaultstate="collapsed" desc=" 付费相关日志, 无缓存 ">
+
     /**
-     * 输出日志 到gift.log
+     * 输出日志 到pay.log
      * @param mixed $msg 参数是字符串则直接输出,否则调用json_encode
-     * @deprecated since version 0.1
      */
-    public static function giftlog($msg) {
-        $fileName = self::GetDir() . "gift.log";
-        self::Log2File($fileName, $msg);
+    public static function pay($msg) {
+        $str = self::makeLogMsg($msg);                                          # 统一日志格式字符串
+        self::Paylog2Mysql($str);
+//        if (GAME_ONLINE) {
+//            self::Paylog2Mysql($str);
+//        } else {
+//            $fileName = self::GetDir() . "pay" . date('Ym') . ".log";
+//            self::Log2File($fileName, $str);
+//        }
     }
 
     /**
@@ -248,107 +311,33 @@ class CLog {
      * @param string $msg
      */
     private static function Log2File($fileName, $msg) {
-
         $fd = fopen($fileName, "a");
-        if ($fd === FALSE) {                                         # 打开文件失败
+        if ($fd === FALSE) {                                                    # 打开文件失败
             throw new \Exception('open file failed! ' . $fileName);
         }
-        // todo: 文件写入也是有机会出错的, 此处出错应予监控,
-        // 并抛出异常到nginx/phpfpm层,记录日志.
-        //                                -wg 2017年8月5日 09:10:16
-        $str = self::makeLogMsg($msg);
-        fputs($fd, $str . PHP_EOL);
-        fclose($fd);                                                 # 关闭文件
-    }
-
-    /**
-     * 生成日志,格式: [x区][时间][文件][tag]: msg
-     * @global \loyalsoft\type $zoneid
-     * @param type $msg
-     * @param type $tag
-     * @return string
-     */
-    private static function makeLogMsg($msg, $tag = null) {
-        global $zoneid;
-        $array = debug_backtrace();
-        while (isset($array[0]) && isset($array[0]['file']) && $array[0]['file'] == __FILE__) {
-            array_shift($array);
-        }
-        $row = $array[0];
-        $row = $array[0];
-        $server_addr = isset($_SERVER['SERVER_ADDR']) ? $_SERVER['SERVER_ADDR'] : "-";
-        $client_addr = isset($_SERVER['REMOTE_ADDR']) ? $_SERVER['REMOTE_ADDR'] : "-";
-        return "[" . $server_addr . "][$zoneid 区][" . date('Y-m-d H:i:s') #              # 主机地址、分区、时间
-                . "][" . $client_addr . "][" #                                            # 客户端地址
-                . (isset($row['file']) ? CommUtil::str2UTF8(basename($row['file'])) : '-') # 所在文件名
-                . ":" . (isset($row['line']) ? $row['line'] : "???")#                     # 所在行   
-                . "]" . (isset($tag) ? "[$tag]" : "") . "=> " . var_export($msg, true)#   # 标签、内容
-                . PHP_EOL;
-//                . "req: " . JsonUtil::encode($req);
+        fputs($fd, $msg . PHP_EOL);
+        fclose($fd);                                                            # 关闭文件
     }
 
     /**
      * 将pay日志写入mysql
      * @param type $msg
      */
-    public static function Paylog2Mysql($msg) {
-        $str = self::makeLogMsg($msg);                                          # 统一日志格式字符串       
+    private static function Paylog2Mysql($msg) {
         $t = "tab_paylog_" . date('Ym');
-        $str = daoInst()->quote($str);                                          # 字符串引号处理
-        $sql = "create table if not exists $t like tpl_paylog_tab_ym;";
-        daoInst()->exec($sql);
-        $sql = " insert into $t (msg) values (" . $str . ");";
+        $sql = "create table if not exists $t like tpl_paylog_tab_ym;"          # 组装SQL
+                . " insert into $t (msg) values ("
+                . daoInst()->quote($msg) . ");";                                # 消息体
         $n = daoInst()->exec($sql);
         if ($n < 0) {
             self::err("写入数据库失败." . $sql);
         }
     }
 
-// </editor-fold>
-//
-// <editor-fold defaultstate="collapsed" desc=" 待实现">
-//    /**
-//     *  将redis中昨天的日志数据输出到磁盘存储介质比如MySQL中.
-//     *  配合crontable 定时将redis中的日志转存到成本较低的MySQL中方便查阅记录.
-//     *  而在MySQL中的数据则进行定期备份,比如一个月之后将上个月的数据转储为sql文件,然后从数据库中清除.
-//     */
-//    public static function dump() {
-//        throw new \Exception('uncompleted');
-//        $redis = gMem();
-//        $tsday = TimeUtil::dtYesterday();  // 20160702
-//        $db = CPayInit();
-//        $sk = "game-run-log-" . $tsday;
-//        set_time_limit(0);  // 这里要取消超时限制
-//        self::_insert2mysql($redis, $db, $sk . "-info");
-//        self::_insert2mysql($redis, $db, $sk . "-log");
-//        self::_insert2mysql($redis, $db, $sk . "-err");
-//        $db->close();
-//    }
-//    /**
-//     * 插入记录
-//     * @param CRedisUtil $redis
-//     * @param CDBUtil $db
-//     * @param string $key
-//     */
-//    private static function _insert2mysql($redis, $db, $key) {
-//        $len = 1000; # 一个批次插入1000条记录能达到相对较优的效率了. (100M内网/1000M本机测试,单条记录长度约为200个字节)
-//        $arr = $redis->lrange($key, 0, $len - 1);
-//        while (count($arr) > 0) {
-//            $values = array();
-//            $sql = 'insert into log201607 (type,ts,tag,msg) values ';
-//            foreach ($arr as $s) {
-//                $values[] = "(" . enum_LogLevel::Err . ", $s)";
-//            }
-//            $sql .= implode(',', $values);
-//            $db->query($sql);
-//            $redis->ltrim($key, $len, -1);
-//            $arr = $redis->lrange($key, 0, $len - 1);
-//        }
-//    }
 // </editor-fold>
 //
 }
 
-if (!SDK_GAME_ONLINE) {                                                         # 除了现网
+if (!GAME_ONLINE) {                                                             # 除了现网
     CLog::SetLogLevel(enum_LogLevel::All);                                      # 开启所有级别的日志输出
 }