Python使用redis的消息队列

Redis 服务

　　一、安装

　　yum install redis

　　二、 python安装支持模块

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

　　三、 和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。

　　一、链接池创建，利用链接池链接

　　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'

　　二、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进元素的同向处理(知足队列的特性先到先出)。

　　一、从左端插入元素

　　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插入到最左边。

　　二、从右边插入元素

　　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']

　　三、从左边取出元素怎么取呢?

　　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']

　　四、从右侧呢?

　　固然就是rc.rpop()了

　　python对于redis的基础使用和Redis做为队列的简单使用就介绍这些，

　　python的工程里边如何更好封装redis库的链接和方法，

　　及python不少的知识内容，你们能够关注我，我将提供更多的内容!