手动编写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)
s = 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:
t = ThreadedTCPServer(('',6379), service)
t.serve_forever()
except KeyboardInterrupt:
sys.exit(1)
|
