php sdk更新

Aliyun/Log/Logger.php

@@ -0,0 +1,69 @@
+<?php
+/**
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved
+ */
+
+class Aliyun_Log_Logger{
+
+    protected $client;
+
+    protected $project;
+
+    protected $logstore;
+
+    public function __construct($client, $project, $logstore)
+    {
+        $this ->client = $client;
+        $this->logstore=$logstore;
+        $this->project=$project;
+    }
+
+    public function log($logLevel, $logMessage, $topic){
+        if(!Aliyun_Log_Models_logLevel_LogLevel::isValidValue($logLevel)){
+            throw new Exception('logLevel value is invalid!');
+        }
+        $ip = $this->getLocalIp();
+        $contents = array( // key-value pair
+            'time'=>date('m/d/Y h:i:s a', time()),
+            'message'=> $logMessage,
+            'loglevel'=> $logLevel
+        );
+        try {
+            $logItem = new Aliyun_Log_Models_LogItem();
+            $logItem->setTime(time());
+            $logItem->setContents($contents);
+            $logitems = array($logItem);
+            $request = new Aliyun_Log_Models_PutLogsRequest($this->project, $this->logstore,
+                $topic, $ip, $logitems);
+            $response = $this->client->putLogs($request);
+            print($response ->getRequestId());
+        } catch (Aliyun_Log_Exception $ex) {
+            var_dump($ex);
+        } catch (Exception $ex) {
+            var_dump($ex);
+        }
+    }
+
+    public function logBatch($logItems, $topic){
+        $ip = $this->getLocalIp();
+        try{
+            $request = new Aliyun_Log_Models_PutLogsRequest($this->project, $this->logstore,
+                $topic, $ip, $logItems);
+            $response = $this->client->putLogs($request);
+            print($response ->getRequestId());
+        } catch (Aliyun_Log_Exception $ex) {
+            var_dump($ex);
+        } catch (Exception $ex) {
+            var_dump($ex);
+        }
+    }
+
+    private function getLocalIp(){
+        $local_ip = getHostByName(php_uname('n'));
+        if(strlen($local_ip) == 0){
+            $local_ip = getHostByName(getHostName());
+        }
+        return $local_ip;
+    }
+}

Aliyun/Log/Models/LogBatch.php

@@ -0,0 +1,111 @@
+<?php
+/**
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved
+ */
+
+/**
+ * Class Aliyun_Log_Models_LogBatch
+ * in some cases the http port is quite limited, so user could config a batch logger,
+ * which will cache some log and send to server in bulk
+ */
+class Aliyun_Log_Models_LogBatch{
+
+    private $logItems = [];
+
+    private $arraySize;
+
+    private $logger;
+
+    private $sem_id;
+
+    private $shm_id;
+
+    private $topic;
+
+    private $waitTime;
+
+    private $previousLogTime;
+
+    public function __construct(Aliyun_Log_Logger $logger, $topic, $cacheLogCount = null, $cacheLogWaitTime = null)
+    {
+        if(NULL === $cacheLogCount || !is_integer($cacheLogCount)){
+            $this->arraySize = 100;
+        }else{
+            $this->arraySize = $cacheLogCount;
+        }
+
+        if(NULL === $cacheLogWaitTime || !is_integer($cacheLogWaitTime)){
+            $this->waitTime = 5;
+        }else{
+            $this->waitTime = $cacheLogWaitTime;
+        }
+
+        $this->logger = $logger;
+        $this->topic = $topic;
+
+        $MEMSIZE    =   10240;
+        $SEMKEY     =   22 + time();
+        $SHMKEY     =   33 + time();
+
+        $this->sem_id = sem_get($SEMKEY, 1);
+        //sem_acquire($this->sem_id);
+        $this->shm_id =   shm_attach($SHMKEY, $MEMSIZE);
+        if(shm_has_var($this->shm_id, 1)){
+            shm_remove_var($this->shm_id, 1);
+        }
+        shm_put_var($this->shm_id, 1, $this->logItems);
+
+    }
+
+    public function log($logMessage, $logLevel){
+        $prevoidCallTime = $this->previousLogTime;
+        if(NULL ===  $prevoidCallTime){
+            $prevoidCallTime = 0;
+        }
+        $this->previousLogTime = time();
+        $contents = array( // key-value pair
+            'time'=>date('m/d/Y h:i:s a', time()),
+            'message'=> $logMessage,
+            'loglevel'=> $logLevel
+        );
+        $logItem = new Aliyun_Log_Models_LogItem();
+        $logItem->setTime(time());
+        $logItem->setContents($contents);
+        printf($logMessage.'<br>');
+        if(shm_has_var($this->shm_id, 1)){
+            $logItems = shm_get_var($this->shm_id, 1);
+            array_push($logItems, $logItem);
+
+            if((sizeof($logItems) == $this->arraySize) || ($this->previousLogTime - $prevoidCallTime > 5)){
+                $this->logger->logBatch($logItems, $this->topic);
+                $logItems = [];
+            }
+
+            shm_remove_var($this->shm_id, 1);
+            shm_put_var($this->shm_id, 1, $logItems);
+            $this->logItems = $logItems;
+        }
+    }
+
+    private function batchSentLog($logItems){
+
+    }
+
+    public function logFlush(){
+        if(sizeof($this->logItems) > 0){
+            $this->logger->logBatch($this->logItems, $this->topic);
+            $this->logItems = [];
+        }
+        shm_remove_var($this->shm_id, 1);
+    }
+
+    function __destruct() {
+        if(sizeof($this->logItems) > 0){
+            $this->logger->logBatch($this->logItems, $this->topic);
+        }
+
+        sem_remove($this->sem_id);
+        shm_remove ($this->shm_id);
+    }
+}

Aliyun/Log/Models/ApplyConfigToMachineGroupRequest.php → Aliyun/Log/Models/Request/ApplyConfigToMachineGroupRequest.php

@@ -1,39 +1,39 @@
-<?php
-/**
- * Copyright (C) Alibaba Cloud Computing
- * All rights reserved
- */
-
-require_once realpath(dirname(__FILE__) . '/Request.php');
-
-/**
- * 
- *
- * @author log service dev
- */
-class Aliyun_Log_Models_ApplyConfigToMachineGroupRequest extends Aliyun_Log_Models_Request {
-    private $groupName;
-    private $configName; 
-    /**
-     * Aliyun_Log_Models_ApplyConfigToMachineGroupRequest Constructor
-     *
-     */
-    public function __construct($groupName=null,$configName=null) {
-        $this->groupName = $groupName;
-        $this->configName = $configName;
-    }
-    public function getGroupName(){
-        return $this->groupName;
-    }
-    public function setGroupName($groupName){
-        $this->groupName = $groupName;
-    }
-
-    public function getConfigName(){
-        return $this->configName;
-    }
-    public function setConfigName($configName){
-        $this->configName = $configName;
-    }
-    
-}
+<?php
+/**
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved
+ */
+
+require_once realpath(dirname(__FILE__) . '/Request.php');
+
+/**
+ * 
+ *
+ * @author log service dev
+ */
+class Aliyun_Log_Models_ApplyConfigToMachineGroupRequest extends Aliyun_Log_Models_Request {
+    private $groupName;
+    private $configName; 
+    /**
+     * Aliyun_Log_Models_ApplyConfigToMachineGroupRequest Constructor
+     *
+     */
+    public function __construct($groupName=null,$configName=null) {
+        $this->groupName = $groupName;
+        $this->configName = $configName;
+    }
+    public function getGroupName(){
+        return $this->groupName;
+    }
+    public function setGroupName($groupName){
+        $this->groupName = $groupName;
+    }
+
+    public function getConfigName(){
+        return $this->configName;
+    }
+    public function setConfigName($configName){
+        $this->configName = $configName;
+    }
+
+}