应用中学习python多线程和socket编程
def run(self): global query_lock,query_list,server_list,server_pos,server_max while True: if query_lock.acquire(): try: query = query_list.pop(0) #轮询服务器 ip,port = server_list[server_pos] server_pos = server_pos + 1 if server_pos == server_max: server_pos = 0 except IndexError: query_lock.release() break; query_lock.release() sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM) sock.connect((ip,port)) sock.send(query) res = sock.recv(1024) sock.close() print res.replace('\n','')
?
服务器端server.py：
path_dir = sys.path[0]sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)sock.bind((socket.gethostbyname(socket.gethostname()),9710))sock.listen(10)while True: connection,address = sock.accept() try: connection.settimeout(60) line = connection.recv(1024) arrs = line.split() if len(arrs) == 2: table = arrs[0] url = arrs[1] cmd = "sh " + path_dir + "/seek_hst.sh " + table + " " + url sub_p = subprocess.Popen(cmd,shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT); result = ""; buff = ""; while True: buff = sub_p.stdout.readline(); result += buff; if buff == '': break; result = result.replace('\n',''); connection.send(result); else: connection.send('please go out!') except socket.timeout: print 'time out' connection.close()?
这是目前的简略版,写起来后各种不同的想法涌现出来,目前想到可以改进的地方：
1. client端连接服务器及端口的配置动态化
2. 可控的超时控制,进一步设计在socket连接上构建自己的协议包内容
3. 服务器端的多线程处理,select及epoll方式的异步IO
?