PHP 收發消息__HTTP 接入(簡單)_消息隊列 MQ-阿裏雲

通過 HTTP 協議接收消息，請參考以下示例代碼。

<?php
include ("Util.php");
/*
 * 消息訂閱者
 */
class HttpConsumer
{
    //簽名
    private static $signature = "Signature";
    //Consumer ID
    private static $consumerid = "ConsumerID";
    //訪問碼
    private static $ak = "AccessKey";
    //配置信息
    private static $config = null;
    //構造函數
    function __construct()
    {
        //讀取配置信息
        $this::$config = parse_ini_file("config.ini");
    }
    //訂閱流程
    public function process()
    {
    //打印配置信息
    var_dump($this::$config);
    //獲取Topic
    $topic = $this::$config["Topic"];
    //獲取Topic的URL路徑
    $url = $this::$config["URL"];
    //阿裏雲身份驗證碼
    $ak = $this::$config["Ak"];
    //阿裏雲身份驗證密鑰
    $sk = $this::$config["Sk"];
    //Consumer ID
    $cid = $this::$config["ConsumerID"];
    $newline = "n";
    //構造工具對象
    $util = new Util();
    while (true)
    {
        try
        {
            //構造時間戳
            $date = time()*1000;
            //簽名字符串
            $signString = $topic.$newline.$cid.$newline.$date;
            //計算簽名
            $sign = $util->calSignatue($signString,$sk);
            //構造簽名標記
            $signFlag = $this::$signature.":".$sign;
            //構造密鑰標記
            $akFlag = $this::$ak.":".$ak;
            //標記
            $consumerFlag = $this::$consumerid.":".$cid;
            //構造HTTP請求發送內容類型標記
            $contentFlag = "Content-Type:text/html;charset=UTF-8";
            //構造HTTP頭部信息
            $headers = array(
                $signFlag,
                $akFlag,
                $consumerFlag,
                $contentFlag,
            );
            //構造HTTP請求URL
            $getUrl = $url."/message/?topic=".$topic."&time=".$date."&num=32";
            //初始化網絡通信模塊
            $ch = curl_init();
            //填充HTTP頭部信息
            curl_setopt($ch,CURLOPT_HTTPHEADER,$headers);
            //設置HTTP請求類型,此處為GET
            curl_setopt($ch,CURLOPT_CUSTOMREQUEST,"GET");
            //設置HTTP請求URL
            curl_setopt($ch,CURLOPT_URL,$getUrl);
            //構造執行環境
            ob_start();
            //開始發送HTTP請求
            curl_exec($ch);
            //獲取請求應答消息
            $result = ob_get_contents();
            //清理執行環境
            ob_end_clean();
            //打印請求應答信息
            var_dump($result);
            //關閉HTTP網絡連接
            curl_close($ch);
            //解析HTTP應答信息
            $messages = json_decode($result,true);
            //如果應答信息中的沒有包含任何的Topic信息,則直接跳過
            if (count($messages) ==0)
            {
                continue;
            }
            //依次遍曆每個Topic消息
            foreach ((array)$messages as $message)
            {
                var_dump($message);
                //獲取時間戳
                $date = (int)($util->microtime_float()*1000);
                //構造刪除Topic消息URL
                $delUrl = $url."/message/?msgHandle=".$message['msgHandle']."&topic=".$topic."&time=".$date;
                //簽名字符串
                $signString = $topic.$newline.$cid.$newline.$message['msgHandle'].$newline.$date;
                //計算簽名
                $sign = $util->calSignatue($signString,$sk);
                //構造簽名標記
                $signFlag = $this::$signature.":".$sign;
                //構造密鑰標記
                $akFlag = $this::$ak.":".$ak;
                //構造消費者組標記
                $consumerFlag = $this::$consumerid.":".$cid;
                //構造HTTP請求頭部信息
                $delheaders = array(
                    $signFlag,
                    $akFlag,
                    $consumerFlag,
                    $contentFlag,
                );
                //初始化網絡通信模塊
                $ch = curl_init();
                //填充HTTP請求頭部信息
                curl_setopt($ch,CURLOPT_HTTPHEADER,$delheaders);
                //設置HTTP請求URL信息
                curl_setopt($ch,CURLOPT_URL,$delUrl);
                //設置HTTP請求類型,此處為DELETE
                curl_setopt($ch,CURLOPT_CUSTOMREQUEST,'DELETE');
                //構造執行環境
                ob_start();
                //開始發送HTTP請求
                curl_exec($ch);
                //獲取請求應答消息
                $result = ob_get_contents();
                //清理執行環境
                ob_end_clean();
                //打印應答消息
                var_dump($result);
                //關閉連接
                curl_close($ch);
            }
        }
        catch (Exception $e)
        {
            //打印異常信息
            echo $e->getMessage();
        }
    }
    }
}
//構造消息訂閱者
$consumer = new HttpConsumer();
//啟動消息訂閱者
$consumer->process();        
?>

4. 工具方法(Util.php)示例程序

<?php
/*
 * 工具類
 */
class Util
{
    //計算簽名
    public static function calSignatue($str,$key)
    {
        $sign = "";
        if(function_exists("hash_hmac"))
        {
            $sign = base64_encode(hash_hmac("sha1",$str,$key,true));
        }
        else
        {
            $blockSize = 64;
            $hashfunc = "sha1";
            if(strlen($key) > $blockSize)
            {
                $key = pack('H*',$hashfunc($key));
            }
            $key = str_pad($key,$blockSize,chr(0x00));
            $ipad = str_repeat(chr(0x36),$blockSize);
            $opad = str_repeat(chr(0x5c),$blockSize);
            $hmac = pack(
                'H*',$hashfunc(
                    ($key^$opad).pack(
                        'H*',$hashfunc($key^$ipad).$str
                    )
                )
            );
            $sign = base64_encode($hmac);
        }
        return $sign;
    }
    //計算時間戳
    public static function microtime_float()
    {
        list($usec,$sec) = explode(" ",microtime());
        return ((float)$usec+(float)$sec);
    }
}
?>