最全總結(jié) | 聊聊 Python 數(shù)據(jù)處理全家桶（Memcached篇）

第一時(shí)間關(guān)注 Python 技術(shù)干貨！

1. 前言

本篇文章繼續(xù)繼續(xù)另外一種比較常用的數(shù)據(jù)存儲(chǔ)方式：Memcached

Memcached：一款高性能分布式內(nèi)存對(duì)象緩存系統(tǒng)，通過(guò)?內(nèi)存緩存，以減少數(shù)據(jù)庫(kù)的讀取，從而分擔(dān)數(shù)據(jù)庫(kù)的壓力，進(jìn)而提高網(wǎng)站的加載速度

Memcached，實(shí)際上是一套簡(jiǎn)潔的鍵值對(duì)存儲(chǔ)系統(tǒng)，可以存儲(chǔ)各種類(lèi)型的數(shù)據(jù)，包含：字符串、對(duì)象、圖像、文件、視頻等

由于 Memcached 的數(shù)據(jù)存儲(chǔ)在內(nèi)存中，因此重啟服務(wù)或系統(tǒng)之后，數(shù)據(jù)會(huì)全部丟失；另外，當(dāng) Memcached 使用容量達(dá)到指定值時(shí)，會(huì)基于?LRU 算法，自動(dòng)刪除掉不使用的緩存

Memcached 協(xié)議簡(jiǎn)潔而強(qiáng)大，開(kāi)發(fā)方便快捷，兼容大部分的開(kāi)發(fā)語(yǔ)言；本篇文章就聊聊 Python 操作?Memcached 正確的姿勢(shì)

2. 準(zhǔn)備

我們以在云服務(wù)器 Centos 7.8?安裝 Memcached-Server 為例

首先，在云服務(wù)器上安裝 Memcached

#?使用yum安裝memcached
yum?install?memcached

通過(guò)?whereis?命令，查詢出 Memcached 安裝的目錄

#?使用whereis命令查詢memcached安裝目錄
#?/usr/bin/memcached
[root@VM-16-11-centos?~]#?whereis?memcached
memcached:?/usr/bin/memcached?/usr/share/man/man1/memcached.1.gz

然后，通過(guò)命令行及參數(shù)啟動(dòng)?Memcached 服務(wù)

#?運(yùn)行memcached服務(wù)
#?-p：端口號(hào)
#?-m：分類(lèi)的內(nèi)存
#?-d：守護(hù)進(jìn)程，后臺(tái)運(yùn)行
#?-u：運(yùn)行memcached的用戶
#?-l：設(shè)置哪些ip可以連接到服務(wù)，0.0.0.0：容許外網(wǎng)ip訪問(wèn)
/usr/bin/memcached?-p?11211?-m?64m?-d?-u?root?-l?0.0.0.0

常見(jiàn)的啟動(dòng)參數(shù)包含：

• -d：通過(guò)守護(hù)進(jìn)程，在后臺(tái)運(yùn)行

• -m：分配的最大內(nèi)存，默認(rèn)大小為 64 M

• -u：運(yùn)行 Memcached 的用戶

• -l：設(shè)置可以訪問(wèn) Memecache 服務(wù)的 ip 地址，默認(rèn)只能通過(guò)本機(jī)訪問(wèn)；如果想外網(wǎng)進(jìn)行訪問(wèn)，需要設(shè)置為：0.0.0.0

• -p：設(shè)置 Memcached 監(jiān)聽(tīng)的端口號(hào)，默認(rèn)為 111211

• -c：最大運(yùn)行的并發(fā)連接數(shù)，默認(rèn)為 1024

接著，開(kāi)啟防火墻端口

需要注意的是，如果是云服務(wù)器，需要在安全組中開(kāi)放相應(yīng)端口號(hào)

#?開(kāi)啟端口號(hào)
firewall-cmd?--add-port=11211/tcp?--permanent

#?重啟立即生效
firewall-cmd?--reload

完成以上操作，我們有兩種方式操作數(shù)據(jù)

分別是：

1、通過(guò)?telnet?連接 Memecached 服務(wù)，使用命令行去操作

#?連接
telnet?IP地址?11211

2、通過(guò)編程語(yǔ)言，包含：Python、Java、Php，去操作 Memcached 數(shù)據(jù)

以 Python 為例，需要安裝?python-memcached?依賴(lài)

#?安裝依賴(lài)
pip3?install?python-memcached

def?__init__(self):
????#?連接memcached服務(wù)，可以包含多個(gè)服務(wù)ip
????self.mc?=?memcache.Client(['ip:11211'],?debug=True)

def?__add(self):
????"""
????添加記錄
????:return:
????"""
????#?添加一條數(shù)據(jù)，如果已經(jīng)存在，會(huì)添加失敗，并提出異常
????# time：保存時(shí)間，超時(shí)會(huì)被清除，單位為秒，默認(rèn)是保存永久
????#?注意：如果添加的key已經(jīng)存在，會(huì)警告：MemCached: while expecting 'STORED', got unexpected response 'NOT_STORED'
????self.mc.add("name",?"xag",?time=60?*?5)
????self.mc.add("age",?23)

def?__query_one(self,?key):
????"""
????查詢單條記錄
????:return:
????"""
????result?=?self.mc.get(key)
????print('單條記錄查詢,key:',?key,?",value:",?result)

def?__query_many(self,?keys):
????"""
????查詢多條記錄
????:param?keys:?鍵值列表
????:return:
????"""
????values?=?self.mc.get_multi(keys)

????#?dict，鍵值對(duì)
????print(type(values))
????print('多條記錄查詢:',?values)

def?__update_default(self):
????"""
????更新數(shù)據(jù)，包含：replace、set、set_multi
????:return:
????"""
????#?1、使用replace更新一條記錄
????#?self.mc.replace("name","xag1")
????#?self.__query_one("name")

????#?2、使用set更新記錄，如果key不存在，則添加一條記錄
????#?set?=?replace?+?add
????#?self.mc.set("name",?"xag2")
????#?self.__query_one("name")

????#?3、使用set_multi更新多條記錄，如果其中有不存在的key，則新建一個(gè)鍵值對(duì)
????self.mc.set_multi({"name":?"xag3",?"age":?28})
????self.__query_many(["name",?"age"])

def?__update_append(self):
????"""
????追加更新，包含：append、prepend
????:return:
????"""

????#?1、append
????#?value尾部追加內(nèi)容
????self.mc.append("name","我是新增的內(nèi)容")
????self.__query_one("name")

????#?2、prepend
????#?頭部新增內(nèi)容
????self.mc.prepend("name","頭部新增的內(nèi)容")
????self.__query_one("name")

def?__delete(self):
????"""
????刪除數(shù)據(jù)，包含：delete、delete_multi
????:return:delete_multi
????"""
????#?1、delete
????#?刪除單條鍵值對(duì)
????#?self.mc.delete("age")
????#?self.__query_one("age")

????#?2、delete_multi
????#?刪除多條記錄
????keys?=?["name","age"]
????self.mc.delete_multi(keys)
????self.__query_many(keys)

4.最后