php sdk更新

Aliyun/Log/Logger.php

@@ -39,9 +39,23 @@ public function log($logLevel, $logMessage, $topic){
             $response = $this->client->putLogs($request);
             print($response ->getRequestId());
         } catch (Aliyun_Log_Exception $ex) {
-            logVarDump($ex);
+            var_dump($ex);
         } catch (Exception $ex) {
-            logVarDump($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);
         }
     }
 

Aliyun/Log/Models/LogBatch.php

@@ -0,0 +1,87 @@
+<?php
+/**
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved
+ */
+
+class Aliyun_Log_Models_LogBatch{
+
+    private $logItems = [];
+
+    private $arraySize;
+
+    private $logger;
+
+    private $sem_id;
+
+    private $shm_id;
+
+    public function __construct($maxLogSize, Aliyun_Log_Logger $logger, $sem_id = null, $shm_id = null)
+    {
+        $this->arraySize = $maxLogSize;
+        if(!is_integer($maxLogSize)){
+            $this->arraySize = 5;
+        }
+        $this->logger = $logger;
+        if($sem_id == null || $shm_id == null){
+            $MEMSIZE    =   10240;
+            $SEMKEY     =   22;
+            $SHMKEY     =   33;
+
+            $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){
+        $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->logger->logBatch($logItems, 'MainFlow');
+                $logItems = [];
+            }
+
+            shm_remove_var($this->shm_id, 1);
+            shm_put_var($this->shm_id, 1, $logItems);
+            $this->logItems = $logItems;
+        }
+    }
+
+    public function shareSem($shm_id){
+
+        if(shm_has_var($shm_id, 1)){
+            $tmp = shm_get_var($shm_id, 1);
+            shm_put_var($shm_id, 1, "*,".$tmp);
+        }else{
+            shm_put_var($shm_id, 1, "Variable 1");
+        }
+
+        $result = shm_get_var($shm_id, 1);
+        echo $result."<br>";
+    }
+
+    function __destruct() {
+        if(sizeof($this->logItems) > 0){
+            $this->logger->logBatch($this->logItems, 'MainFlow');
+        }
+
+        sem_remove($this->sem_id);
+        shm_remove ($this->shm_id);
+    }
+}

Aliyun/Log/Models/Response/ListShardsResponse.php

@@ -26,7 +26,6 @@ class Aliyun_Log_Models_ListShardsResponse extends Aliyun_Log_Models_Response {
     public function __construct($resp, $header) {
         parent::__construct ( $header );
         foreach($resp as $key=>$value){
-            var_dump($value);
             $this->shardIds[] = $value['shardID'];
             $this->shards[] = new Aliyun_Log_Models_Shard($value['shardID'],$value["status"],$value["inclusiveBeginKey"],$value["exclusiveEndKey"],$value["createTime"]);
         }

sample/demo.php

@@ -70,8 +70,8 @@ function getLogs(Aliyun_Log_Client $client, $project, $logstore) {
 }
 
 $endpoint = 'http://cn-shanghai-corp.sls.aliyuncs.com';
-$accessKeyId = 'LTAIUbY1Pk7Ryf1P';
-$accessKey = '0oXZLJrFoRnlzVpDpopNVstd87bUWn';
+$accessKeyId = '';
+$accessKey = '';
 $project = 'ali-sls-sdk-test';
 $logstore = 'sls-test';
 $token = "";
@@ -81,6 +81,12 @@ function getLogs(Aliyun_Log_Client $client, $project, $logstore) {
 
 $logger = new Aliyun_Log_Logger($client, $project, $logstore);
 
-$logger->log('test', 'something wrong with the inner info', 'MainFlow');
+//$logger->log('test', 'something wrong with the inner info', 'MainFlow');
+$batchLogger = new Aliyun_Log_Models_LogBatch(25, $logger);
+
+for($i = 1; $i <= 133; $i++){
+    $batchLogger->log('something wrong with the inner info '.$i,'info');
+}
+
+getLogs($client,$project,$logstore);
 
-getLogs($client,$project,$logstore);

sample/sample.php

@@ -195,10 +195,10 @@ function logVarDump($expression){
  * http://help.aliyun-inc.com/internaldoc/detail/29074.html?spm=0.0.0.0.tqUNn5
  */
 $endpoint = 'http://cn-shanghai-corp.sls.aliyuncs.com';
-$accessKeyId = 'LTAIUbY1Pk7Ryf1P';
-$accessKey = '0oXZLJrFoRnlzVpDpopNVstd87bUWn';
-$project = 'ali-sls-sdk-test';
-$logstore = 'sls-test';
+$accessKeyId = '';
+$accessKey = '';
+$project = '';
+$logstore = '';
 $token = "";
 
 $client = new Aliyun_Log_Client($endpoint, $accessKeyId, $accessKey,$token);