phpredis列表

『壹』 php怎麼將數據導入redis

對於大訪問量的站點使用默認的Session 並不合適，我們可以將其存入資料庫、或者使用Redis KEY-VALUE數據存儲方案
首先新建一個session表
CREATE TABLE `sessions` (
`sid` char(40) NOT NULL,
`updatetime` int(20) NOT NULL,
`data` varchar(200) NOT NULL,
UNIQUE KEY `sid` (`sid`) USING HASH
) ENGINE=MEMORY DEFAULT CHARSET=utf8;
Mysql 的memory引擎採用內存表，所有數據存儲在內存，操作速度快
復制代碼
<?php
//引入資料庫文件
include "db.php";
class MySessionHandler implements SessionHandlerInterface
{
private $savePath;
private $sessData;
public $expiretime; //設置過期時間
public $db; //資料庫
public function __construct($hanlder =''){
$this->db = Database::getInstance();
//獲取資料庫實力
///var_mp($this->db);
}
public function open($savePath, $sessionName)
{
return true;
}
public function close()
{
return true;
}
public function read($id)
{
$sql ="select * from sessions where sid ='$id'";
$result = $this->db->execute($sql);
if(!empty($result)){
return $this->sessData = $result;
}
}
//函數的參數 $id -> 當前會話ID
//數據DATA -> 序列化之後的字元串
public function write($id, $data)
{
// echo $id;
// echo $data;
$now = time();
$newExp = $now+$this->expiretime; //總時間=當前時間 + 期限時間
$sql = "select * from sessions where sid ='$id'";
$result = $this->db->getOne($sql);
//var_mp($result);
if($data==''||isset($data)){
$data = $this->sessData;
}
if($result){
//如果存在則更新
$sql ="update sessions set updatetime = '$newExp',data ='$data' where sid = '$id'";
//echo $sql;
$update_data =$this->db->execute($sql);
if($update_data){
return true;
}
}else{
//不存在則生成生成
$sql = "insert into sessions(sid,updatetime,data) values('$id','$now','$data')";
$insert_data = $this->db->execute($sql);
if($insert_data){
return true;
}
}
return false;
}
public function destroy($id)
{ //銷毀
$sql = "delete from sessions where sid="."$id";
$destory = $this->db->execute($sql);
if($destory){
return true;
}else{
return false;
}
}
public function gc($sessMaxLifeTime)
{
$t = time();
$sql ="delete from sessions where $t - 'updatetime'>${sessMaxLifeTime}";
$data = $this->db->execute($this->tosql);
if($data){
return true;
}else{
return false;
}
return true;
}
}
復制代碼
實例化
此處 PHP 手冊可以有兩種方法
1，實現了SessionHandlerInterface借口的對象,自PHP5.4可以使用
2 ，直接使用 session_set_save_handler
復制代碼
//判斷PHP版本
if(version_compare(PHP_VERSION,5.4)==1){
session_set_save_handler($handler, true);
session_start();
}else{
ini_set('session.use_trans_sid',0);
ini_set('session.use_cookies',1);
ini_set('session.cookie_path','/');
ini_set('session.save_handler','user');
session_mole_name('user');
session_set_save_handler(array($session,"open"),array($session,"close"),array($session,"read"),array($session,"write"),array($session,"destory"),array($session,"gc"));
session_start();
}
$_SESSION['QQ']="QQ";
echo $_SESSION['QQ'];
復制代碼
資料庫代碼 db.php
復制代碼
<?php
class Database{
static $instance;
static $db;
static function getInstance(){
if(self::$instance){
return self::$instance;
}else{
return new Database();
}
}
public function __construct(){
self::$db = new PDO('mysql:host=localhost;dbname=session', 'root','');
}
public function getOne($sql){
$rs =self::$db->query($sql);
@$rs->setFetchMode(PDO::FETCH_ASSOC);//返回關聯數組
$result = $rs -> fetch();
return $result;
}
public function execute($sql){
$rs = self::$db->exec($sql);
return $rs;
}
}
//$data = Database::getInstance();
//var_mp($data);
復制代碼
使用REDIS 存儲SESSION
復制代碼
<?php
class SessionManager{
private $redis;
private $sessionSavePath;
private $sessionName;
private $sessionExpireTime = 30;
public function __construct(){
$this->redis = new Redis();
$this->redis->connect('127.0.0.1',6379); //連接redis
$retval = session_set_save_handler(
array($this,"open"),
array($this,"close"),
array($this,"read"),
array($this,"write"),
array($this,"destory"),
array($this,"gc")
);
session_start();
}
public function open($path,$name){
return true;
}
public function close(){
return true;
}
public function read($id){
$value = $this->redis->get($id);
if($value){
return $value;
}else{
return "";
}
}
public function write($id,$data){
if($this->redis->set($id,$data)){
$this->redis->expire($id,$this->sessionExpireTime);
//設置過期時間
return true;
}
return false;
}
public function destory($id){
if($this->redis->delete($id)){
return true;
}
return false;
}
public function gc($maxlifetime){
return true;
}
//析構函數
public function __destruct(){
session_write_close();
}
}
$re = new SessionManager();
$_SESSION['name'] = "qq";
echo $_SESSION['name'];

『貳』 php使用redis的有序集合zset實現延遲隊列

延遲隊列就是個帶延遲功能的消息隊列，相對於普通隊列，它可以在指定時間消費掉消息。

我們通過redis的有序集合zset來實現簡單的延遲隊列，將消息數據序列化，作為zset的value，把消息處理時間作為score，每次通過zRangeByScore獲取一條消息進行處理。

然後，我們寫一個php腳本，用來處理隊列中的任務。

『叄』 為什麼php調用redis 返回+ok

Redis::__construct構造函數
$redis = new Redis();
connect, open 鏈接redis服務
參數
host: string，服務地址
port: int,埠號
timeout: float,鏈接時長 (可選, 默認為 0 ，不限鏈接時間)
注: 在redis.conf中也有時間，默認為300
pconnect, popen 不會主動關閉的鏈接
參考上面
setOption 設置redis模式
getOption 查看redis設置的模式
ping 查看連接狀態
KEY相關操作
DEL
移除給定的一個或多個key。
如果key不存在，則忽略該命令。
時間復雜度：
O(N)，N為要移除的key的數量。
移除單個字元串類型的key，時間復雜度為O(1)。
移除單個列表、集合、有序集合或哈希表類型的key，時間復雜度為O(M)，M為以上數據結構內的元素數量。
返回值：
被移除key的數量。這樣呢我自己學習在後盾人看見的，老師講的很詳細，希望對你有用😊(ง •̀_•́)ง努力

『肆』 【Redis】基礎數據結構-ziplist壓縮列表

壓縮列表是列表和哈希表的底層實現之一：

Redis壓縮列表是由連續的內存塊組成的列表，主要包含以下內容：

列表在初始化的時候會計算需要分配的內存空間大小，然後進行內存分配，之後將內存空間的最後一個位元組標記為列表結尾，內存空間的大小計算方式如下：

所以在創建之後，內存布局如下，此時壓縮列表中還沒有節點：

之後如果如果需要添加節點，會進行移動，為新節點的插入騰出空間，所以還是斗彎余佔用的連續的空間：

壓縮列表的節點可以存儲字元串或者整數類型的值，為了節省內存，它採用了變長的編碼方式，壓縮列表的節點的結構定義如下：

prevrawlen ：存儲前一個節點的長度（佔用的位元組數），這樣如果從後向前遍歷，只需要當前節點的起始地址減去長度的偏移量prevrawlen就可以定位到上一個節點的位置，prevrawlen的長度可以是1位元組或者5位元組：

encoding ：記錄了節點的數據類型和內容的長度，因為壓縮列表可以存儲字元串或者整型，所以有以下兩種情況：

存儲內容為整數時，encoding佔用1個位元組，最高位是11開頭，後六位代表整數值的長度，其中當編碼為1111xxxx時情況比較特殊，

後四位的值在0001和1101之間， 此時直接代表數據的內容，是0到12之間的一個數字 ，並不是數據長度，因為它代表了數據內容，所以也不需要額外的空間存儲數據內容。

zipStoreEntryEncoding

因為壓縮列表中每個節點記錄了前一個節點的長度：

假設有一種情況，一個壓縮列表中，存儲了多個長度是253位元組的節點，因為節點的長度都在254位元組以內，所以每個節點的prevrawlen只需要1個位元組去存儲長度的值：

此時在列表的頭部需要新增加一個節點，並且節點的長度大於254，這個時候原先的頭結點entry1 prevrawlen使用1位元組已經不能滿足當前的情況了，必須要使用5位元組存儲，因此entry1的prevrawlen變成了5位元組，entry1的長度也會跟著增加4個位元組，已經超過了254位元組，因為大於254就需要使用5個位元組存儲，所以entry2的prevrawlen也鬧李需要改變為5位元組，後面的以此類推，引發了連鎖更新，這種情況稱之為連鎖更新：

總結空滾

（1）Redis壓縮列表使用了一塊連續的內存，來節約內存空間。

（2）壓縮列表的節點可以存儲字元串或者整數類型的值，它採用了變長的編碼方式，根據數據類型的不同以及數據長度的不同，選擇不同的編碼方式，每種編碼佔用的位元組大小不同，以此來節約內存。

（3）壓縮列表的每個節點中存儲了前一個節點的位元組長度，如果知道某個節點的地址，可以使用地址減去位元組長度定位到上一個節點，不過新增節點的時候，由於前一個節點的長度大於254使用5個位元組，小於254使用1個位元組存儲，在一些極端的情況下由於長度的變化會引起連鎖更新。

參考

黃健宏《Redis設計與實現》

極客時間 - Redis源碼剖析與實戰(蔣德鈞)

【張鐵蕾】Redis內部數據結構詳解(4)——ziplist

【_HelloBug】Redis-壓縮表-__ziplistInsert詳解

圖解Redis之數據結構篇——壓縮列表

Redis版本：redis-6.2.5

『伍』 php 分頁查詢怎麼redis緩存

對於有分頁條件的緩存，我們也可以按照不同的分頁條件來緩存多個key，比如分頁查詢產品列表,page=1&limit=10和page=1&limit=5這兩次請求可以這樣緩存查詢結果

proctList:page:1:limit:10

proctList:page:1:limit:5
這個是一種常見方案，但是存在著一些問題：

緩存的value存在冗餘，proctList:page:1:limit:10緩存的內容其實是包括了proctList:page:1:limit:5中的內容（緩存兩個key的時候，數據未發生變化的情況下）

僅僅是改變了查詢條件的分頁條件，就會導致緩存未命中，降低了緩存的命中率

為了保證數據一致性，需要清理緩存的時候，很難處理，redis的keys命令對性能影響很大，會導致redis很大的延遲，生產環境一般來說禁止該命令。自己手動拼緩存key，你可能根本不知道拼到哪一個page為止。

放棄數據一致性，通過設置失效時間來自動失效，可能會出現查詢第一頁命中了緩存，查詢第二頁的時候未命中緩存，但此時數據已經發生了改變，導致第二頁查詢返回的和第一頁相同的結果。
以上，在分頁條件下這樣使用常規方案總感覺有諸多困擾，諸多麻煩，那是不是就應該放棄使用緩存？
基於SortedSet的分頁查詢緩存方案
首先想到的解決方法是使用@see ListOperations<K, V>不再根據分頁條件使用多個key，而是使用一個key，也不分頁將全部的數據緩存到redis中，然後按照分頁條件使用range(key,start,limit)獲取分頁的結果，這個會導致一個問題，當緩存失效時，並發的寫緩存會導致出現重復數據
所以想到通過使用set來處理並發時的重復數據，@see ZSetOperations<K, V>
代碼邏輯如下：

range(key,start,limit)按照分頁條件獲取緩存，命中則直接返回

緩存未命中，查詢（沒有分頁條件）資料庫或是調用（沒有分頁）底層介面

add(key,valueScoreMap<value,score>)寫入緩存，expire設置緩存時間

當需要清理緩存時，直接刪除key，如果是因為數據新增和刪除，可以add(key,value,score)或remove(key,value)

redis中會按照score分值升序排列map中的數據，一般的，score分值是sql語句的order by filedA的filedA的值，這樣能保證數據一致性
但是這種方式也存在一定問題：

這個key緩存的value確實是熱數據，但可能只有少數數據被頻繁使用其餘的可能根本就未被使用，比如數據有100頁，實際可能只會用到前10頁，這也會導致緩存空間的浪費，如果使用了redis虛擬內存，也會有一定影響

sql查詢由原來的分頁查詢變成了不分頁查詢，緩存失效後，系統的處理能力較之前會有下降，尤其是對於大表.

『陸』 PHP刪除Redis所有數據

1、創建userinfo_update.php，用於查詢用戶信息，先顯示信息，在修改：先通過GET獲取用戶編號查詢用戶信息：$sql = "select * from user_info where user_id='".$_GET['userId']."'"; $result = mysql_query($sql,$con);if($row = mysql_fetch_array($result)){}。

『柒』 redis隊列什麼意思

Redis隊列功能介紹

List

常用命令：

Blpop刪除，並獲得該列表中的第一元素，或阻塞，直到有一個可用

Brpop刪除，並獲得該列表中的最後一個元素，或阻塞，直到有一個可用

Brpoplpush

Lindex獲取一個元素，通過其索引列表

Linsert在列表中的另一個元素之前或之後插入一個元素

Llen獲得隊列(List)的長度

Lpop從隊列的左邊出隊一個元素

Lpush從隊列的左邊入隊一個或多個元素

Lpushx當隊列存在時，從隊到左邊入隊一個元素

Lrange從列表中獲取指定返回的元素

Lrem從列表中刪除元素

Lset設置隊列裡面一個元素的值

Ltrim修剪到指定范圍內的清單

Rpop從隊列的右邊出隊一個元素

Rpoplpush刪除列表中的最後一個元素，將其追加到另一個列表

Rpush從隊列的右邊入隊一個元素

Rpushx從隊列的右邊入隊一個元素，僅隊列存在時有效

Redis支持php、python、c等介面

應用場景：

Redislist的應用場景非常多，也是Redis最重要的數據結構之一，比如twitter的關注列表，粉絲列表等都可以用Redis的list結構來實現。

Lists就是鏈表，相信略有數據結構知識的人都應該能理解其結構。使用Lists結構，我們可以輕松地實現最新消息排行等功能。

Lists的另一個應用就是消息隊列，

可以利用Lists的PUSH操作，將任務存在Lists中，然後工作線程再用POP操作將任務取出進行執行。Redis還提供了操作Lists中某一段的api，你可以直接查詢，刪除Lists中某一段的元素。

如果需要還可以用redis的Sorted-Sets數據結構來做優先隊列.可以給每條消息加上一個唯一的序號。這里就不詳細介紹了。

實現方式：

Redislist的實現為一個雙向鏈表，即可以支持反向查找和遍歷，更方便操作，不過帶來了部分額外的內存開銷，Redis內部的很多實現，包括發送緩沖隊列等也都是用的這個數據結構。

示意圖:

1)入隊