且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

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

更新时间:2022-10-01 11:35:53

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

已经实现内容如下:

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



脚本如下

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
import SocketServer,sys
from threading import Thread
import socket
from hash_ring import HashRing
 
redis_servers = ['127.0.0.1:6480',
                 '127.0.0.1:6481',
                 '127.0.0.1:6482']
  
ring = HashRing(redis_servers)
 
class service(SocketServer.BaseRequestHandler):
    def handle(self):
        data = 'dummy'
        print "Client connected with "self.client_address
        while len(data):
            data = self.request.recv(1024)
        if data:
            key =(data.split("\n"))[4]
        server = ring.get_node(key)
        = socket.socket(socket.AF_INET,socket.SOCK_STREAM)      
        s.connect(((server.split(":"))[0],int((server.split(":"))[1])))
            s.sendall(data)
        r_data  = s.recv(1024)
        print server
            self.request.send(r_data)
 
        print "Client exited"
        self.request.close()
 
 
class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    pass
try:
    = ThreadedTCPServer(('',6379), service)
    t.serve_forever()
except KeyboardInterrupt:
    sys.exit(1)

本文转自   tianshuai369   51CTO博客,原文链接:http://blog.51cto.com/kkkkkk/1760030