应用中学习python多线程和socket编程

蒦嗳伱

　　执行力才是最重要的。
　　python书籍也看了几个有好几个礼拜了,但是一直没上手应用,始终想着学的太浅,理解的透彻点再开始用,一直拖了好久。但是最近的一个项目某个查询模板,由于涉及到单机网络的原因,我就想到了开始写一段python处理程序,这样可以利用socket连接多多台服务器并发进行查询,而服务器端监听请求处理查询即可。在写的过程中，遇到各种问题,再去查询,边写边学,效率高多了,执行下去才是最重要的,先直接上干货
　　客户端client.py：

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