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);
    }
}
?>