Python에서 Redis 메시지 큐를 작동하는 방법

redis는 Key-Value 데이터베이스입니다. Value는 문자열(string), 목록(list), 집합(set), zset(ordered set), 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에 대해 이야기해야 합니다. 이 데이터 유형은 Python에서는 목록이고 Redis에서는 정렬된 대기열(또는 데이터 연결 목록)입니다.

유형 다이어그램은 다음과 같습니다.

이 구조를 보면 누구나 명확하게 이해할 수 있습니다. 목록의 데이터 인터페이스 모드를 사용하여 왼쪽과 오른쪽 끝에서 목록의 요소를 동일한 방향으로 처리하도록 설계할 수 있습니다. (큐의 특성을 먼저 충족하여 선착순으로 나옵니다).

rreee

위 내용은 Python에서 Redis 메시지 큐를 작동하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!