python中怎麼操作redis訊息佇列

redis 是一個Key-Value 資料庫，Value 支援string(字串)，list(列表)，set(集合)，zset(有序集合)，hash(哈希類型)等類型。

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 的互動。

  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訊息佇列的詳細內容。更多資訊請關注PHP中文網其他相關文章！