奥飞火千万电 发表于 2018-11-5 11:00:15

【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]
查看完整版本: 【php-redis】pub/sub 公开和订阅