How does PHP use Redis? (Introduction to common usage scenarios)

青灯夜游
Release: 2023-04-09 10:24:01
forward
3065 people have browsed it

How does PHP use Redis? (Introduction to common usage scenarios)

7 common usage scenarios of PHP using Redis

Redis is an open source software written in ANSI C language, supports the network, and can be based on memory or memory. A durable log-type, Key-Value database, and provides APIs in multiple languages.

This article mainly introduces the main application scenarios of using Redis using PHP.

Simple string cache practice

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

$strCacheKey  = 'Test_bihu';

//SET 应用

$arrCacheData = [

    'name' => 'job',

    'sex'  => '男',

    'age'  => '30'

];

$redis->set($strCacheKey, json_encode($arrCacheData));

$redis->expire($strCacheKey, 30);  # 设置30秒后过期

$json_data = $redis->get($strCacheKey);

$data = json_decode($json_data);

print_r($data->age); //输出数据

//HSET 应用

$arrWebSite = [

    'google' => [

        'google.com',

        'google.com.hk'

    ],

];

$redis->hSet($strCacheKey, 'google', json_encode($arrWebSite['google']));

$json_data = $redis->hGet($strCacheKey, 'google');

$data = json_decode($json_data);

print_r($data); //输出数据
Copy after login

Simple queue practice

$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);
Copy after login

Simple publish and subscribe practice

//以下是 pub.php 文件的内容 cli下运行
ini_set(&#39;default_socket_timeout&#39;, -1);
$redis->connect(&#39;127.0.0.1&#39;, 6379);
$strChannel = &#39;Test_bihu_channel&#39;;
//发布
$redis->publish($strChannel, "来自{$strChannel}频道的推送");
echo "---- {$strChannel} ---- 频道消息推送成功~ <br/>";
$redis->close();
//以下是 sub.php 文件内容 cli下运行
ini_set(&#39;default_socket_timeout&#39;, -1);
$redis->connect(&#39;127.0.0.1&#39;, 6379);
$strChannel = &#39;Test_bihu_channel&#39;;
//订阅
echo "---- 订阅{$strChannel}这个频道,等待消息推送...----  <br/><br/>";
$redis->subscribe([$strChannel], &#39;callBackFun&#39;);
function callBackFun($redis, $channel, $msg)
{
 print_r([
 &#39;redis&#39; => $redis,
 &#39;channel&#39; => $channel,
 &#39;msg&#39; => $msg
 ]);
}
Copy after login

Simple counter practice

$redis->connect(&#39;127.0.0.1&#39;, 6379);
$strKey = &#39;Test_bihu_comments&#39;;
//设置初始值
$redis->set($strKey, 0);
$redis->INCR($strKey);  //+1
$redis->INCR($strKey);  //+1
$redis->INCR($strKey);  //+1
$strNowCount = $redis->get($strKey);
echo "---- 当前数量为{$strNowCount}。 ---- ";
Copy after login

Rankboard Practice

$redis->connect(&#39;127.0.0.1&#39;, 6379);
$strKey = &#39;Test_bihu_score&#39;;
//存储数据
$redis->zadd($strKey, &#39;50&#39;, json_encode([&#39;name&#39; => &#39;Tom&#39;]));
$redis->zadd($strKey, &#39;70&#39;, json_encode([&#39;name&#39; => &#39;John&#39;]));
$redis->zadd($strKey, &#39;90&#39;, json_encode([&#39;name&#39; => &#39;Jerry&#39;]));
$redis->zadd($strKey, &#39;30&#39;, json_encode([&#39;name&#39; => &#39;Job&#39;]));
$redis->zadd($strKey, &#39;100&#39;, json_encode([&#39;name&#39; => &#39;LiMing&#39;]));
$dataOne = $redis->ZREVRANGE($strKey, 0, -1, true);
echo "---- {$strKey}由大到小的排序 ---- <br /><br />";
print_r($dataOne);
$dataTwo = $redis->ZRANGE($strKey, 0, -1, true);
echo "<br /><br />---- {$strKey}由小到大的排序 ---- <br /><br />";
print_r($dataTwo);
Copy after login

Simple String Pessimistic Lock Practice

Explanation: Pessimistic Lock (Pessimistic Lock), as the name suggests, is very pessimistic.

Every time I go to get the data, I think others will modify it, so I lock it every time I get the data.

Scenario: If cache is used in the project and a timeout is set for the cache.

When the amount of concurrency is relatively large, if there is no lock mechanism, then the moment the cache expires,

A large number of concurrent requests will penetrate the cache and directly query the database, causing an avalanche effect.

/**
 * 获取锁
 * @param  String  $key    锁标识
 * @param  Int     $expire 锁过期时间
 * @return Boolean
 */
public function lock($key = &#39;&#39;, $expire = 5) {
 $is_lock = $this->_redis->setnx($key, time()+$expire);
 //不能获取锁
 if(!$is_lock){
 //判断锁是否过期
 $lock_time = $this->_redis->get($key);
 //锁已过期,删除锁,重新获取
 if (time() > $lock_time) {
 unlock($key);
 $is_lock = $this->_redis->setnx($key, time() + $expire);
 }
 }
 return $is_lock? true : false;
}
/**
 * 释放锁
 * @param  String  $key 锁标识
 * @return Boolean
 */
public function unlock($key = &#39;&#39;){
 return $this->_redis->del($key);
}
// 定义锁标识
$key = &#39;Test_bihu_lock&#39;;
// 获取锁
$is_lock = lock($key, 10);
if ($is_lock) {
 echo &#39;get lock success<br>&#39;;
 echo &#39;do sth..<br>&#39;;
 sleep(5);
 echo &#39;success<br>&#39;;
 unlock($key);
} else { //获取锁失败
 echo &#39;request too frequently<br>&#39;;
}
Copy after login

Optimistic locking practice for simple transactions

Explanation: Optimistic Lock (Optimistic Lock), as the name suggests, is very optimistic.

Every time I go to get the data, I think that others will not modify it, so it will not be locked.

The watch command will monitor the given key. If the monitored key has changed since calling watch during exec, the entire transaction will fail.

You can also call watch multiple times to monitor multiple keys. In this way, optimistic locking can be added to the specified key.

Note that the watch key is valid for the entire connection, and the same is true for transactions.

If the connection is disconnected, monitoring and transactions will be automatically cleared.

Of course, the exec, discard, and unwatch commands will clear all monitoring in the connection.

$strKey = &#39;Test_bihu_age&#39;;
$redis->set($strKey,10);
$age = $redis->get($strKey);
echo "---- Current Age:{$age} ---- <br/><br/>";
$redis->watch($strKey);
// 开启事务
$redis->multi();
//在这个时候新开了一个新会话执行
$redis->set($strKey,30);  //新会话
echo "---- Current Age:{$age} ---- <br/><br/>"; //30
$redis->set($strKey,20);
$redis->exec();
$age = $redis->get($strKey);
echo "---- Current Age:{$age} ---- <br/><br/>"; //30
//当exec时候如果监视的key从调用watch后发生过变化,则整个事务会失败
Copy after login

Related tutorial recommendations: "PHP Tutorial"

The above is the detailed content of How does PHP use Redis? (Introduction to common usage scenarios). For more information, please follow other related articles on the PHP Chinese website!

Related labels:
source:cnblogs.com
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template
About us Disclaimer Sitemap
php.cn:Public welfare online PHP training,Help PHP learners grow quickly!