python操作redis

在使用django的websocket的時(shí)候，發(fā)現(xiàn)web請求和其他當(dāng)前的django進(jìn)程的內(nèi)存是不共享的，猜測django的機(jī)制可能是每來一個(gè)web請求，就開啟一個(gè)進(jìn)程去與web進(jìn)行交互，一次來達(dá)到利用cpu多核的目的。但是這樣一來，內(nèi)存共享的問題就變成了焦點(diǎn)。這周試了一下redis，果然很好用。

redis是一個(gè)key-value存儲系統(tǒng)。和Memcached類似，它支持存儲的value類型相對更多，包括string（字符串）、list（鏈表）、set（集合）、zset（sorted set --有序集合）和hash（哈希類型）。這些數(shù)據(jù)類型都支持push/pop、add/remove及取交集并集和差集及更豐富的操作，而且這些操作都是原子性的。在此基礎(chǔ)上，redis支持各種不同方式的排序。與memcached一樣，為了保證效率，數(shù)據(jù)都是緩存在內(nèi)存中。區(qū)別的是redis會周期性的把更新的數(shù)據(jù)寫入磁盤或者把修改操作寫入追加的記錄文件，并且在此基礎(chǔ)上實(shí)現(xiàn)了master-slave（主從）同步。

上面的話好像很專業(yè)的樣子，這里我們簡單的理解為，其實(shí)redis就是一個(gè)消息中間件，可以作為多個(gè)進(jìn)程的消息中轉(zhuǎn)站，是比之前我們用的manage模塊更方便自由的共享內(nèi)存。

redis的安裝和啟動自己到網(wǎng)上去找，由于操作系統(tǒng)等環(huán)境差異，這里不多贅述。我們要使用python操作redis，還需要一個(gè)redis模塊?？梢灾苯邮褂?a href="http://ttokpm.com/tags/pi/" target="_blank">pip安裝。

假設(shè)我們已經(jīng)啟動了redis，也安裝好了相關(guān)的python模塊，redis的啟動默認(rèn)端口是6379，現(xiàn)在就來看看redis應(yīng)該如何使用。

1.基本操作

之前我們已經(jīng)知道，redis是以key-value的形式存儲的，所以我們在操作的時(shí)候。首先我們將redis所在主機(jī)的ip和發(fā)布端口作為參數(shù)實(shí)例化了一個(gè)對象r，然后執(zhí)行set（‘name’，‘Eva_J’），這樣我們就在內(nèi)存中存儲了一個(gè)key為name，值為‘Eva_J’的項(xiàng)。我們可以理解為{‘name’：‘Eva_J’}，當(dāng)我們要讀取的之后，只需要get（‘name’），就會得到‘Eva_J’的值。

2.連接池

redis-py使用connection pool來管理對一個(gè)redis server的所有連接，避免每次建立、釋放連接的開銷。默認(rèn)，每個(gè)Redis實(shí)例都會維護(hù)一個(gè)自己的連接池?？梢灾苯咏⒁粋€(gè)連接池，然后作為參數(shù)Redis，這樣就可以實(shí)現(xiàn)多個(gè)Redis實(shí)例共享一個(gè)連接池。

3、管道

redis-py默認(rèn)在執(zhí)行每次請求都會創(chuàng)建（連接池申請連接）和斷開（歸還連接池）一次連接操作，如果想要在一次請求中指定多個(gè)命令，則可以使用pipline實(shí)現(xiàn)一次請求指定多個(gè)命令，并且默認(rèn)情況下一次pipline 是原子性操作。

4、發(fā)布訂閱

發(fā)布者：服務(wù)器

訂閱者：Dashboad和數(shù)據(jù)處理

Demo如下：

定義一個(gè)redishelper類，建立與redis連接，定義頻道為fm92.4，定義發(fā)布public及訂閱subscribe方法。

訂閱者：導(dǎo)入剛剛我們寫好的類，實(shí)例化對象，調(diào)用訂閱方法，就可以使用while True接收信息了。

發(fā)布者：導(dǎo)入剛剛我們寫好的類，實(shí)例化對象，調(diào)用發(fā)布方法，下例發(fā)布了一條消息‘hello’