一、Redis 服務

1、安裝

yum install redis

2、 python安裝支持模塊

/opt/python2.7.13/bin/pip install redis

3、 和redis的簡單直接交互

In [1]: import redis

In [2]: rc = redis.Redis(host='192.168.8.237',port=6379,decode_responses=True)

In [5]: rc.set('imoocc','jeson')

Out[5]: True

In [7]: rc.get('imoocc')

Out[7]: u'jeson'

二、Redis簡單操作

對于和Redis的交互， Redis的類中提供了連接池的方式，我們可以通過連接池管理并操作Redis。

1、連接池建立，利用連接池連接

In [8]: connpool = redis.ConnectionPool(host='192.168.8.237',port=6379,decode_responses=True)

In [9]: rc = redis.Redis(connection_pool=connpool)

In [10]: rc.set('imooccp','1234566')

Out[10]: True

In [11]: rc.get('imooccp')

Out[11]: u'1234566'

2、redis中DB ，指定數據存取的DB

redis.conf中設置了db的數量，那么redis的數據庫名也為0 到15，如下：

databases 16

指定使用那個數據庫名，我們通過如下的方式，就可以了：

In [29]: connpool = redis.ConnectionPool(host='192.168.8.237',port=6379,decode_responses=True,db=3)

In [30]: rc.set('test2','lllll')

Out[30]: True

這樣就將數據庫寫入到db3了，如何驗證呢?我們從服務端來認證最直接，如下：

用redis-cli(redis自帶的工具)登錄服務端，查看寫入的key。

127.0.0.1:6379> SELECT 3

OK

127.0.0.1:6379[3]> KEYS * //查看db 3這個庫下所有的key

1) "imooccc"

那么 接下來介紹redis詳細項目使用的內容，大家不要覺得介紹的內容擴散太大。

最近在作一個任務系統，任務寫入是不定時的，我們需要用一個程序去定期消費這些任務，必須是有先后順序的，而且是

前一個任務確認執行完后，才會去執行下一個。

怎么辦呢?用隊列啊，對吧!用什么隊列，怎么用?

介紹下為什么要用redis來作消息處理：

簡單說，redis支持兩種消費模式，一種發布-訂閱模式，及一個消息會被多個消費者處理(簡單說類似是一個廣播消息，所有人都會接收)。很明顯我得系統中不需要這么用，系統里邊就需要隊列模式，及先到的任務優先處理。那么對隊列用什么類型得數據庫結構來作呢?

四、先得聊聊list

list 這個數據類型，在python里是一個列表，在redis里就是一個有序隊列(或者說數據鏈表)了。

類型圖示如下：

大家看了這個結構就可以清楚了，我們可以利用list的數據接口模式，設計從左端和右端都可以對list進元素的同向處理(滿足隊列的特性先到先出)。

1、從左端插入元素

In [10]: rc.lpush('tasklist',1,2,3)

Out[10]: 3L

打印輸出內容，如下：

In [17]: print(rc.lrange('tasklist',0,2))

[u'3', u'2', u'1']

類似的從左測插入的方法還有lpushx(name,value)，區別只有當name存在才將value插入到最左邊。

2、從右邊插入元素

In [21]: rc.rpush('tasklist','5')

Out[21]: 5L

In [22]: print(rc.lrange('tasklist',0,4))

[u'4', u'3', u'2', u'1', u'5']

3、從左邊取出元素怎么取呢?

In [23]: rc.lpop("tasklist")

Out[23]: u'4'

In [24]: rc.lpop("tasklist")

Out[24]: u'3'

In [25]: print(rc.lrange('tasklist',0,4))

[u'2', u'1', u'5']

我們會看到從左側已經取出了兩個元素了。剩下來[u'2', u'1', u'5']

4、從右側呢?

當然就是rc.rpop()了

python對于redis的基礎使用和Redis作為隊列的簡單使用就介紹這些，

python的工程里邊如何更好封裝redis庫的連接和方法，

及python很多的知識內容，大家可以關注我，我將提供更多的內容!

本文由 帝一博客 原創發布。用戶在本站發布的原創內容(包括但不僅限于回答、文章和評論)，著作權均歸用戶本人所有。獨家文章轉載，請聯系郵箱：17762131@qq.com。獲得授權后，須注明本文地址：

https://www.d1blog.com/pythonpachong/1121.html

總結

以上是生活随笔為你收集整理的python 消息队列 get是从队首还是队尾取东西_从零开始Python对redis作为消息队列的使用...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。