#!/usr/bin/python # coding=utf-8 __author__ = ‘shuangjiang‘ import redis import sys default_encoding = ‘utf-8‘ if sys.getdefaultencoding() != default_encoding: reload(sys) sys.setdefaultencoding(default_encoding) class myRedis: def __init__(self,host,port,db_index): self._redis_host=host self._redis_port=port self._redis_db=db_index def getRedis(self): _redis = redis.Redis(host=self._redis_host, port=self._redis_port, db=self._redis_db) return _redis def getRecRedis(): host = ‘127.0.0.1‘ port = 6379 db_index = 0 return myRedis(host,port,db_index).getRedis() def getQueueRedis(): host = ‘172.0.0.1‘ port = 6379 db_index = 0 return myRedis(host,port,db_index).getRedis()
在调用处直接导入:
from common.myRedis import *
使用:
获取redis对象:_redis = getQueueRedis()
使用: value = _redis.rpop(‘hello‘)
时间: 2024-11-02 17:45:54