接上一篇，這么干純粹是為了好玩呵扛。
上一篇的博客中的例子只能處理一個(gè)Server對(duì)一個(gè)Client的情況渺蒿，今天修改了一版，可以支持一個(gè)Server對(duì)多個(gè)Client值纱。實(shí)現(xiàn)方式就是Server每派發(fā)一個(gè)動(dòng)作就扔到一個(gè)線程里去鳞贷，Client也類(lèi)似每收到一個(gè)數(shù)據(jù)，就起一個(gè)線程去做自己的邏輯虐唠。這樣看起來(lái)就有點(diǎn)像socket變成了搀愧。
import redis
import time
import json
import threading
host = 'localhost'
port = 6322
queue = 'myqueue'
class Server(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
def run(self):
pool = redis.BlockingConnectionPool(host=host, port=port, db='0')
conn = redis.Redis(connection_pool=pool)
idx = 0
while True:
idx = idx + 1
key = str(idx)
data = "request_" + key
threading.Thread(target=ServerHandler(conn, key, data).handle).start()
time.sleep(1)
class ServerHandler(object):
def __init__(self, conn, key, data):
self.conn = conn
self.key = key
self.data = data
def handle(self):
request = {'id': self.key, 'data': self.data}
print 'Server: Send request: %s' % request
self.conn.lpush(queue, json.dumps(request))
response = self.conn.brpop(self.key, 2)
if response:
print 'Server: Receive response: %s' % response[1]
else:
print "Server: Timeout!!!"
class Client(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
def run(self):
pool = redis.BlockingConnectionPool(host=host, port=port, db='0')
conn = redis.Redis(connection_pool=pool)
while True:
msg = conn.brpop(queue)[1]
threading.Thread(target=ClientHandler(conn, msg).handle).start()
class ClientHandler(object):
def __init__(self, conn, msg):
self.conn = conn
self.msg = msg
def handle(self):
print 'Client: Receive request: %s' % self.msg
time.sleep(0.1)
d = json.loads(self.msg)
key = d.get('id')
d['data'] = "response_" + key
print 'Client: Send response: %s' % d
self.conn.lpush(key, json.dumps(d))
self.conn.expire(key, 5)
server = Server()
server.start()
client = Client()
client.start()
