Python操作Redis、Memcache、RabbitMQ、SQLAlchemy

class ConnectionPool(object): 
    ...........
  def __init__(self, connection_class=Connection, max_connections=None,
         **connection_kwargs):  #类初始化时调用构造函数
    max_connections = max_connections or 2 ** 31
    if not isinstance(max_connections, (int, long)) or max_connections < 0: #判断输入的max_connections是否合法
      raise ValueError(‘"max_connections" must be a positive integer‘)
    self.connection_class = connection_class #设置对应的参数
    self.connection_kwargs = connection_kwargs
    self.max_connections = max_connections
    self.reset() #初始化ConnectionPool 时的reset操作
  def reset(self):
    self.pid = os.getpid()
    self._created_connections = 0 #已经创建的连接的计数器
    self._available_connections = []  #声明一个空的数组，用来存放可用的连接
    self._in_use_connections = set() #声明一个空的集合，用来存放已经在用的连接
    self._check_lock = threading.Lock()
.......
  def get_connection(self, command_name, *keys, **options): #在连接池中获取连接的方法
    "Get a connection from the pool"
    self._checkpid()
    try:
      connection = self._available_connections.pop() #获取并删除代表连接的元素，在第一次获取connectiong时，因为_available_connections是一个空的数组，
      会直接调用make_connection方法
    except IndexError:
      connection = self.make_connection()
    self._in_use_connections.add(connection)  #向代表正在使用的连接的集合中添加元素
    return connection  
  def make_connection(self): #在_available_connections数组为空时获取连接调用的方法
    "Create a new connection"
    if self._created_connections >= self.max_connections:  #判断创建的连接是否已经达到最大限制，max_connections可以通过参数初始化
      raise ConnectionError("Too many connections")
    self._created_connections += 1  #把代表已经创建的连接的数值+1
    return self.connection_class(**self.connection_kwargs)   #返回有效的连接，默认为Connection(**self.connection_kwargs)
  def release(self, connection): #释放连接，链接并没有断开，只是存在链接池中
    "Releases the connection back to the pool"
    self._checkpid()
    if connection.pid != self.pid:
      return
    self._in_use_connections.remove(connection)  #从集合中删除元素
    self._available_connections.append(connection) #并添加到_available_connections 的数组中
  def disconnect(self): #断开所有连接池中的链接
    "Disconnects all connections in the pool"
    all_conns = chain(self._available_connections,
             self._in_use_connections)
    for connection in all_conns:
      connection.disconnect()

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import redis
class RedisHelper:
 def __init__(self):
        self.__conn = redis.Redis(host=‘127.0.0.1‘)  #连接redis服务器
        self.chan_sub = ‘fm104.5‘        #订阅频道
        self.chan_pub = ‘fm104.5‘        #发布频道
 def public(self, msg):                  #定义发布函数，msg为发布消息
        self.__conn.publish(self.chan_pub, msg)
        return True
 def subscribe(self):
        pub = self.__conn.pubsub()        #定义接收函数，接收消息
        pub.subscribe(self.chan_sub)
        pub.parse_response()               #等待消息
        return pub