应用中学习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 + 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
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
url = arrs
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
页:
[1]