//发布 $redis = new \Redis(); $redis->connect('127.0.0.1', 6379); $redis->publish('msg', '来自msg频道的推送'); echo "msg频道消息推送成功~ \n"; $redis->close();
// ini_set(‘default_socket_timeout’, -1); $redis = new \Redis(); $redis->pconnect('127.0.0.1', 6379); //订阅 echo "订阅msg这个频道,等待消息推送... \n"; $redis->subscribe(['msg'], 'callfun'); function callfun($redis, $channel, $msg) { print_r([ 'redis' => $redis, 'channel' => $channel, 'msg' => $msg ]); }