【php-redis】pub/sub 公开和订阅
ini_set('default_socket_timeout', -1);$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->auth('lizongying');
$channel = 'msg';
$redis->subscribe(array($channel), 'callback');
function callback($redis, $channel, $message)
{
if (ob_get_level() == 0) {
ob_start();
}
echo str_pad(' ', 1024 * 8);
echo date('Y-m-d H:i:s');
var_dump($message);
flush();
ob_flush();
ob_end_flush();
}
页:
[1]