PHP使用Redis常见7种使用场景(2)

当前位置:

首页 > PHP >

PHP使用Redis常见7种使用场景(2)

简单队列实战

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

										$strQueueName = 'Test_bihu_queue';

										//进队列

										$redis->rpush($strQueueName, json_encode(['uid' => 1,'name' => 'Job']));

										$redis->rpush($strQueueName, json_encode(['uid' => 2,'name' => 'Tom']));

										$redis->rpush($strQueueName, json_encode(['uid' => 3,'name' => 'John']));

										echo "---- 进队列成功 ---- <br /><br />";

										//查看队列

										$strCount = $redis->lrange($strQueueName, 0, -1);

										echo "当前队列数据为： <br />";

										print_r($strCount);

										//出队列

										$redis->lpop($strQueueName);

										echo "<br /><br /> ---- 出队列成功 ---- <br /><br />";

										//查看队列

										$strCount = $redis->lrange($strQueueName, 0, -1);

										echo "当前队列数据为： <br />";

										print_r($strCount);

简单发布订阅实战

				
										//以下是 pub.php 文件的内容 cli下运行

										ini_set('default_socket_timeout', -1);

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

										$strChannel = 'Test_bihu_channel';

										//发布

										$redis->publish($strChannel, "来自{$strChannel}频道的推送");

										echo "---- {$strChannel} ---- 频道消息推送成功～ <br/>";

										$redis->close();

										//以下是 sub.php 文件内容 cli下运行

										ini_set('default_socket_timeout', -1);

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

										$strChannel = 'Test_bihu_channel';

										//订阅

										echo "---- 订阅{$strChannel}这个频道，等待消息推送...----  <br/><br/>";

										$redis->subscribe([$strChannel], 'callBackFun');

										function callBackFun($redis, $channel, $msg)

										{

										 print_r([

										 'redis' => $redis,

										 'channel' => $channel,

										 'msg' => $msg

										 ]);

										}

栏目列表