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