PHP實現redis訂閱和發布（用於異步任務處理）

訂閱頻道並獲取信息：

<?php
ini_set('default_socket_timeout', -1);
header("Content-type: text/html; charset=utf-8");
$redis = new Redis();
$redis->connect('127.0.0.1',6379);

$redis->subscribe(array('test'), 'callback');

// 回調函數,這里寫處理邏輯
function callback($instance, $channelName, $message) {
echo $channelName, "==>", $message,PHP_EOL;

}

 

推送信息：

<?php

$redis = new Redis();

$redis->connect('127.0.0.1',6379);

$res = $redis->publish('test','hello,我是隔壁小王');