python 消息队列 get是从队首还是队尾取东西_从零开始Python对redis作为消息队列的使用...

一、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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/455358.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

‘’和“”

单引号引的数据是char类型的 双引号引的数据是String类型的 单引号只能引一个字符 而双引号可以引0个及以上 字符(Character)是指人类语言的最小的表义符号,字符是指计算机中使用的字母、数字和符号,包括1、2、3、A、B、C、#、&am…

Spring整合Quartz定时任务 在集群、分布式系统中的应用(Mysql数据库环境)

转载:http://www.cnblogs.com/jiafuwei/p/6145280.html 单个Quartz实例能给予你很好的Job调度能力,但它不能满足典型的企业需求,如可伸缩性、高可靠性满足。假如你需要故障转移的能力并能运行日益增多的 Job,Quartz集群势必成为你…

JDBC笔记02-数据库连接池 Spring JDBC

今日内容 数据库连接池Spring JDBC : JDBC Template 数据库连接池 概念: 其实就是一个容器(集合),存放数据库连接的容器 当系统初始化好后,容器被创建,容器中会申请一些连接对象,当用户来访问数据库时,从容器中获取连接对象,用户访问完之后,会将连接对象归还给容器 好处:…

20温控f1什么意思_欧姆龙温控器是什么 欧姆龙温控器介绍【图文】

欧姆龙温控器,乍一眼看上去真的很难理解这到底是一个什么产品,或者是一个有什么用处的温控器,对于这个比较浅显的问题,不知道大家会有什么样地感受,是不是正在一头雾水的等着我进行解答呢?经过我比较浅显的分析&#…

bootstrap 解决弹出窗口(modal) 常见问题

无法使用键盘esc关闭窗口方法: 首先在modal容器的div中增加属性tabindex"-1",其次设置键盘ESC属性keyboard为true; 方法1:使用js打开窗口时 $(“#modal”).modal({keyboard:true}) 方法2:使用H5属性在modal窗…

zabbix3.2学习笔记(二):服务端安装

2019独角兽企业重金招聘Python工程师标准>>> 一般小公司大多将zabbix web端和zabbix server部署在同一台主机上,其实二者是可以分开的,web GUI配置连接到对应的数据库就行,让zabbix server和MySQL数据库在同一台主机上便于数据快速…

H.264解码器中CAVLC码表查找算法的分析与优化

0 引言 近年来,随着信息技术飞速发展和互联网的日益普及,尤其是以视频为信息主要来源的多媒体领域越来越受到人们的关注。H.264是ITU-T的视频编码专家组(VCEG)和ISO/IEC的活动图像编码专家组(MPEG)的联合视频组(Joint Video Te…

python求加速度_如何利用Python 为自然语言处理加速度

自去年发布 Python 的指代消解包(coreference resolution package)之后,很多用户开始用它来构建许多应用程序,而这些应用与我们最初的对话应用完全不同。利用 spaCy 和一点点 Cython 给 NLP 加速。自去年发布 Python 的指代消解包(coreference resolutio…

druid.properties文件的配置

# druid.properties文件的配置 driverClassNamecom.mysql.jdbc.Driver urljdbc:mysql://127.0.0.1:3306/plan usernameroot password # 初始化连接数量 initialSize5 # 最大连接数 maxActive10 # 最大超时时间 maxWait3000

jquery+easyui开发、培训文档

目 录 1.... Accordion(可折叠标签)....................................................................................... 2 1.1 实例.............................................................................................…

HAProxy用法详解 全网最详细中文文档

一、HAProxy简介(1)HAProxy 是一款提供高可用性、负载均衡以及基于TCP(第四层)和HTTP(第七层)应用的代理软件,支持虚拟主机,它是免费、快速并且可靠的一种解决方案。 HAProxy特别适用…

mp4文件格式系列

mp4文件格式系列1 - 综述Overview and Introduction Core Concepts MP4文件格式中,所有的内容存在一个称为movie的容器中。一个movie可以由多个tracks组成。每个track就是一个随时间变化的媒体序列,例如,视频帧序列。track里的每个时间单…

JDBC笔记-李伟杰版

JDBC 03 2019/8/1 9:51:41 笔记网站 全球加速: http://zaixianke.com 北京节点: http://itdage.cnJDBC 事务 *** 在dos命令行操作oracle时 , 执行DML , 需要结束事务 (commit提交 或 rollback回退) 在JDBC中, 事务是自动提交的, 每执行一条DML语句, 事务就自动提交一次…

局域网网络风暴检测工具_【思唯网络学院】从原理到配置,最全的VLAN说明就在这了!...

有关VLAN的技术标准IEEE 802.1Q早在1999年6月份就由IEEE委员正式颁布实施了,而且最早的VLNA技术早在1996年Cisco(思科)公司就提出了。随着几年来的发展,VLAN技术得到广泛的支持,在大大小小的企业网络中广泛应用,成为当前最为热门的…

SQL server 基本语句

--查询数据库是否存在 if exists ( select * from sysdatabases where [name]TestDB) print Yes, the DB exists else print No, need a new one? --新建一个数据库 create database TestDB on ( name TestData, filename G:\DBS\KeyTest.mdf, size 3, filegrowth 2 ) log…

pythonselenium模拟登陆爬取信息_python3 使用selenium模拟登陆天眼查抓取数据

由于之前用Scrapy 抓了一些公司的名称,但是没有准确的联系方式,所以就自己就学习了一下使用selenium自动化工具,速度比较慢,网上也有很多这方面的代码,但是大部分的网页解析部分都出错了,可能是这种网站定时…

mp4格式

下面的软件下载地址:http://download.csdn.net/source/2607382 ftyp: 这是一个筐,可以装mdat等其他Box。 例:00 00 00 14 66 74 79 70 69 73 6F 6D 00 00 02 00 6D 70 34 31 语义为:ftyp: Major brand: isom Minor version: 5…

PyQt5案例汇总(简洁版)

01菜单栏 import sys from PyQt5.QtWidgets import QMainWindow, QAction, qApp, QApplication from PyQt5.QtGui import QIconclass Example(QMainWindow):def __init__(self):super().__init__()self.initUI()def initUI(self):exitAct QAction(QIcon(exit.png), &Exit,…

个人关于浮动的理解

浮动带来的影响: ①. 能够让浮动之后的元素布局产生混乱 (元素浮动后脱离了标准文档流,它的布局也就不再遵循标准文档流的规则,多个浮动元素在一起的时候就会随着窗口的变化而变化,也就失去了稳定的布局) ②…

接口测试 rest-assured 使用指南

转载:https://testerhome.com/topics/7060 原文:https://github.com/rest-assured/rest-assured/wiki/Usage本文github地址:https://github.com/RookieTester/rest-assured-doc 注意,如果您正在使用1.9.0或者更早的版本请参考旧文…