统计客户端

applications/Statistics/Clients/StatisticClient.php

@@ -0,0 +1,77 @@
+<?php
+require_once WORKERMAN_ROOT_DIR . 'applications/Statistics/Lib/StatisticProtocol.php'; 
+/**
+ * 统计客户端
+ * @author workerman.net
+ */
+class StatisticClient
+{
+    /**
+     * [module=>[interface=>time_start, interface=>time_start ...], module=>[interface=>time_start ..], ... ]
+     * @var array
+     */
+    protected static $timeMap = array();
+    
+    /**
+     * 模块接口上报消耗时间记时
+     * @param string $module
+     * @param string $interface
+     * @return void
+     */
+    public static function tick($module = '', $interface = '')
+    {
+        return self::$timeMap[$module][$interface] = microtime(true);
+    }
+    
+    /**
+     * 上报统计数据
+     * @param string $module
+     * @param string $interface
+     * @param bool $success
+     * @param int $code
+     * @param string $msg
+     * @param string $report_address
+     * @return boolean
+     */
+    public static function report($module, $interface, $success, $code, $msg, $report_address = '')
+    {
+        $report_address = $report_address ? $report_address : 'udp://127.0.0.1:55656';
+        if(isset(self::$timeMap[$module][$interface]) && self::$timeMap[$module][$interface] > 0)
+        {
+            $time_start = self::$timeMap[$module][$interface];
+            self::$timeMap[$module][$interface] = 0;
+        }
+        else if(isset(self::$timeMap['']['']) && self::$timeMap[''][''] > 0)
+        {
+            $time_start = self::$timeMap[''][''];
+            self::$timeMap[''][''] = 0;
+        }
+        else
+        {
+            $time_start = microtime(true);
+        }
+         
+        $cost_time = microtime(true) - $time_start;
+        
+        $bin_data = StatisticProtocol::encode($module, $interface, $cost_time, $success, $code, $msg);
+        
+        return self::sendData($report_address, $bin_data);
+    }
+    
+    /**
+     * 发送数据给统计系统
+     * @param string $address
+     * @param string $buffer
+     * @return boolean
+     */
+    public static function sendData($address, $buffer)
+    {
+        $socket = stream_socket_client($address);
+        if(!$socket)
+        {
+            return false;
+        }
+        return stream_socket_sendto($socket, $buffer) == strlen($buffer);
+    }
+    
+}

applications/Statistics/Lib/StatisticProtocol.php

@@ -0,0 +1,106 @@
+<?php 
+/**
+ * 
+ * struct statisticPortocol
+ * {
+ *     unsigned char module_name_len;
+ *     unsigned char interface_name_len;
+ *     float cost_time;
+ *     unsigned char success;
+ *     int code;
+ *     unsigned short msg_len;
+ *     unsigned int time;
+ *     char[module_name_len] module_name;
+ *     char[interface_name_len] interface_name;
+ *     char[msg_len] msg;
+ * }
+ *  
+ * @author workerman.net
+ */
+class StatisticProtocol
+{
+    /**
+     * 包头长度
+     * @var integer
+     */
+    const PACKEGE_FIXED_LENGTH = 17;
+    
+    /**
+     * udp 包最大长度
+     * @var integer
+     */
+    const MAX_UDP_PACKGE_SIZE  = 65507;
+    
+    /**
+     * char类型能保存的最大数值
+     * @var integer
+     */
+    const MAX_CHAR_VALUE = 255;
+    
+    /**
+     *  usigned short 能保存的最大数值
+     * @var integer
+     */
+    const MAX_UNSIGNED_SHORT_VALUE = 65535;
+    
+    /**
+     * 编码
+     * @param string $module
+     * @param string $interface
+     * @param float $cost_time
+     * @param int $success
+     * @param int $code
+     * @param string $msg
+     * @return string
+     */
+    public static function encode($module, $interface , $cost_time, $success,  $code = 0,$msg = '')
+    {
+        // 防止模块名过长
+        if(strlen($module) > self::MAX_CHAR_VALUE)
+        {
+            $module = substr($module, 0, self::MAX_CHAR_VALUE);
+        }
+        
+        // 防止接口名过长
+        if(strlen($interface) > self::MAX_CHAR_VALUE)
+        {
+            $interface = substr($interface, 0, self::MAX_CHAR_VALUE);
+        }
+        
+        // 防止msg过长
+        $module_name_length = strlen($module);
+        $interface_name_length = strlen($interface);
+        $avalible_size = self::MAX_UDP_PACKGE_SIZE - self::PACKEGE_FIXED_LENGTH - $module_name_length - $interface_name_length;
+        if(strlen($msg) > $avalible_size)
+        {
+            $msg = substr($msg, 0, $avalible_size);
+        }
+        
+        // 打包
+        return pack('CCfCNnN', $module_name_length, $interface_name_length, $cost_time, $success ? 1 : 0, $code, strlen($msg), time()).$module.$interface.$msg;
+    }
+   
+    /**
+     * 解包
+     * @param string $bin_data
+     * @return array
+     */
+    public static function decode($bin_data)
+    {
+        // 解包
+        $data = unpack("Cmodule_name_len/Cinterface_name_len/fcost_time/Csuccess/Ncode/nmsg_len/Ntime", $data);
+        $module = substr($bin_data, self::PACKEGE_FIXED_LENGTH, $data['module_name_len']);
+        $interface = substr($bin_data, self::PACKEGE_FIXED_LENGTH + $data['module_name_len'], $data['interface_name_len']);
+        $msg = substr($bin_data, self::PACKEGE_FIXED_LENGTH + $data['module_name_len'] + $data['interface_name_len']);
+        return array(
+                'module'          => $module,
+                'interface'        => $interface,
+                'cost_time' => $data['cost_time'],
+                'success'           => $data['success'],
+                'time'                => $data['time'],
+                'code'               => $data['code'],
+                'msg'                => $msg, 
+                );
+    }
+    
+}

workers/StatisticWorker.php

@@ -1,5 +1,6 @@
 <?php 
 require_once WORKERMAN_ROOT_DIR . 'man/Core/SocketWorker.php';
+require_once WORKERMAN_ROOT_DIR . 'applications/Statistics/Lib/StatisticProtocol.php';
 /**
  * 
 * @author walkor <worker-man@qq.com>
@@ -263,111 +264,3 @@ class StatisticWorker extends Man\Core\SocketWorker
         }
     }
 } 
-
-
-
-/**
- * 
- * struct statisticPortocol
- * {
- *     unsigned char module_name_len;
- *     unsigned char interface_name_len;
- *     float cost_time;
- *     unsigned char success;
- *     int code;
- *     unsigned short msg_len;
- *     unsigned int time;
- *     char[module_name_len] module_name;
- *     char[interface_name_len] interface_name;
- *     char[msg_len] msg;
- * }
- *  
- * @author valkor
- */
-class StatisticProtocol
-{
-    /**
-     * 包头长度
-     * @var integer
-     */
-    const PACKEGE_FIXED_LENGTH = 17;
-    
-    /**
-     * udp 包最大长度
-     * @var integer
-     */
-    const MAX_UDP_PACKGE_SIZE  = 65507;
-    
-    /**
-     * char类型能保存的最大数值
-     * @var integer
-     */
-    const MAX_CHAR_VALUE = 255;
-    
-    /**
-     *  usigned short 能保存的最大数值
-     * @var integer
-     */
-    const MAX_UNSIGNED_SHORT_VALUE = 65535;
-    
-    /**
-     * 编码
-     * @param string $module
-     * @param string $interface
-     * @param float $cost_time
-     * @param int $success
-     * @param int $code
-     * @param string $msg
-     * @return string
-     */
-    public static function encode($module, $interface , $cost_time, $success,  $code = 0,$msg = '')
-    {
-        // 防止模块名过长
-        if(strlen($module) > self::MAX_CHAR_VALUE)
-        {
-            $module = substr($module, 0, self::MAX_CHAR_VALUE);
-        }
-        
-        // 防止接口名过长
-        if(strlen($interface) > self::MAX_CHAR_VALUE)
-        {
-            $interface = substr($interface, 0, self::MAX_CHAR_VALUE);
-        }
-        
-        // 防止msg过长
-        $module_name_length = strlen($module);
-        $interface_name_length = strlen($interface);
-        $avalible_size = self::MAX_UDP_PACKGE_SIZE - self::PACKEGE_FIXED_LENGTH - $module_name_length - $interface_name_length;
-        if(strlen($msg) > $avalible_size)
-        {
-            $msg = substr($msg, 0, $avalible_size);
-        }
-        
-        // 打包
-        return pack('CCfCNnN', $module_name_length, $interface_name_length, $cost_time, $success ? 1 : 0, $code, strlen($msg), time()).$module.$interface.$msg;
-    }
-   
-    /**
-     * 解包
-     * @param string $bin_data
-     * @return array
-     */
-    public static function decode($bin_data)
-    {
-        // 解包
-        $data = unpack("Cmodule_name_len/Cinterface_name_len/fcost_time/Csuccess/Ncode/nmsg_len/Ntime", $data);
-        $module = substr($bin_data, self::PACKEGE_FIXED_LENGTH, $data['module_name_len']);
-        $interface = substr($bin_data, self::PACKEGE_FIXED_LENGTH + $data['module_name_len'], $data['interface_name_len']);
-        $msg = substr($bin_data, self::PACKEGE_FIXED_LENGTH + $data['module_name_len'] + $data['interface_name_len']);
-        return array(
-                'module'          => $module,
-                'interface'        => $interface,
-                'cost_time' => $data['cost_time'],
-                'success'           => $data['success'],
-                'time'                => $data['time'],
-                'code'               => $data['code'],
-                'msg'                => $msg, 
-                );
-    }
-    
-}