phpredis实现简单的消息队列详解编程语言

<?php 
 
require_once __DIR__ . '/phprediscaozuo.php'; 
 
$redis = /RedisClient::getInstance(); 
 
$ss = $redis->subscribe(array('xiaoxiduilie'), 'callback'); 
 
function callback($instance, $channelName, $message) 
{ 
    $info     = unserialize($message); 
    $url      = $info['url']; 
  if (is_numeric(strpos(__FILE__, 'phpStudy'))) { 
        $yuming  = 'bendilink'; 
    } else { 
        $yuming  = 'fuwuqilink'; 
    }     
    $url=$yuming.$url; 
    $postdata = $info['postdata']; 
 
    echo $channelName, "==>", $message, PHP_EOL; 
    $info = httprepair($url, $postdata, 'post'); 
 
    file_put_contents(__DIR__ . '/xiaoxiduilie.log', date("Y-m-d H:i:s") . " " . var_export($info, true) . PHP_EOL, FILE_APPEND | LOCK_EX); 
} 
 
/** 
 * 发送HTTP请求方法，目前只支持CURL发送请求 
 * @param  string $url    请求URL 
 * @param  array  $data   POST的数据，GET请求时该参数无效 
 * @param  string $method 请求方法GET/POST 
 * @return array          响应数据 
 */ 
function httprepair($url, $data = '', $method = 'GET') 
{ 
    $opts = array( 
        CURLOPT_TIMEOUT        => 1000, 
        CURLOPT_RETURNTRANSFER => 1, 
        CURLOPT_SSL_VERIFYPEER => false, 
        CURLOPT_SSL_VERIFYHOST => false, 
    ); 
 
    /* 根据请求类型设置特定参数 */ 
    $opts[CURLOPT_URL] = $url; 
 
    if (strtoupper($method) == 'POST') { 
        $opts[CURLOPT_POST]       = 1; 
        $opts[CURLOPT_POSTFIELDS] = $data; 
 
        if (is_string($data)) { 
            //发送JSON数据 
            $opts[CURLOPT_HTTPHEADER] = array( 
                'Content-Type: application/json; charset=utf-8', 
                'Content-Length: ' . strlen($data), 
            ); 
        } 
    } 
 
    /* 初始化并执行curl请求 */ 
    $ch = curl_init(); 
    curl_setopt_array($ch, $opts); 
    $data  = curl_exec($ch); 
    $error = curl_error($ch); 
    curl_close($ch); 
 
    //发生错误，抛出异常 
    if ($error) { 
        file_put_contents(__DIR__ . '/error.log', date("Y-m-d H:i:s") . " " . var_export('<<<<< ' . json_encode($error), 'ERROR', true) . PHP_EOL, FILE_APPEND | LOCK_EX); 
    } 
 
    return $data; 
}