python实现类似tweproxy和codes的功能的redis代理功能

手动编写redis代理软件脚本实现类似tweproxy 和codes的功能

已经实现内容如下&＃xff1a;

起1个代理ip和端口 redisl客户端连接代理然后脚本通过一致性hash分发key到后端的redis

脚本如下

 import SocketServer,sys
from threading import Thread
import socket
from hash_ring import HashRing
 
redis_servers &＃61; [&＃39;127.0.0.1:6480&＃39;,
                 &＃39;127.0.0.1:6481&＃39;,
                 &＃39;127.0.0.1:6482&＃39;]
  
ring &＃61; HashRing(redis_servers)
 
class service(SocketServer.BaseRequestHandler):
    def handle(self):
        data &＃61; &＃39;dummy&＃39;
        print "Client connected with ", self.client_address
        while len(data):
            data &＃61; self.request.recv(1024)
        if data:
            key &＃61;(data.split("\n"))[4]
        server &＃61; ring.get_node(key)
        s &＃61; socket.socket(socket.AF_INET,socket.SOCK_STREAM)      
        s.connect(((server.split(":"))[0],int((server.split(":"))[1])))
            s.sendall(data)
        r_data  &＃61; s.recv(1024)
        print server
            self.request.send(r_data)
 
        print "Client exited"
        self.request.close()
 
 
class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    pass
try:
    t &＃61; ThreadedTCPServer((&＃39;&＃39;,6379), service)
    t.serve_forever()
except KeyboardInterrupt:
    sys.exit(1)
 
本文转自   tianshuai369   51CTO博客&＃xff0c;原文链接:http://blog.51cto.com/kkkkkk/1760030