代码拉取完成,页面将自动刷新
#! /usr/bin/php
<?php
require_once './RedisInstance.class.php';
RedisInstance::getInstance()->setOption(\Redis::OPT_READ_TIMEOUT,-1);
RedisInstance::getInstance()->psubscribe(array('__keyevent@0__:expired'), 'psCallback');
RedisInstance::getInstance()->psubscribe(array('__keyevent@0__:expired'),function ($redis, $pattern, $chan, $msg){
// 回调函数,这里写处理逻辑
$messageId = explode(':',$msg);
switch($messageId[0]){
case '4001':
curlPost('http://127.0.0.1',array('id'=>$messageId[1]));
break;
case '4002':
curlPost('http://127.0.0.1',array('id'=>$messageId[1]));
break;
case '4003':
curlPost('http://127.0.0.1',array('id'=>$messageId[1]));
break;
default:
curlPost('http://127.0.0.1',array('id'=>$msg));
break;
}
});
function curlPost($url, $curlPost)
{
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_HEADER, false);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
curl_setopt($curl, CURLOPT_NOBODY, true);
curl_setopt($curl, CURLOPT_POST, true);
curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
$return_str = curl_exec($curl);
curl_close($curl);
return $return_str;
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。