本文实例讲述了python实现的服务器。分享给大家供大家参考，具体如下：
python - 单进程服务器
|
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
|
#coding=utf-8from socket import *#创建套接字sersocket = socket(af_inet, sock_stream)#重复使用绑定信息sersocket.setsockopt(sol_socket, so_reuseaddr, 1)localaddr = ('', 7788)#绑定端口ipsersocket.bind(localaddr)#监听sersocket.listen(5)while true: print('－－－主进程，等待新客户端的到来－－－') newsocket,destaddr = sersocket.accept() print('－－－主进程，接下来负责数据处理[%s]－－－'%str(destaddr)) try: while true: recvdata = newsocket.recv(1024) if len(recvdata)>0: print('recv[%s]:%s'%(str(destaddr),recvdata)) else: print('[%s]客户端已经关闭') break finally: newsocket.close()sersocket.close() |
总结
同一时刻只能为一个客户进行服务，不能同时为多个客户服务。
当服务器为一个客户端服务时，另外的客户端发起了connect，只要服务器listen的队列有空闲的位置，就会为这个新客户端进行连接，并且客户端可以发送数据，但当服务器为这个新客户端服务时，可能一次性把所有数据接收完毕当recv接收数据时，返回值为空，即没有返回数据，那么意味着客户端已经调用了close关闭了；因此服务器通过判断recv接收数据是否为空 来判断客户端是否已经下线。
python - 多进程服务器
|
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
39
40
41
|
#coding=utf-8from socket import *from multiprocessing import *from time import sleep#处理客户端的请求并为其服务def dealwithclient(newsocket,destaddr): try: while true: recvdata = newsocket.recv(1024) if len(recvdata) > 0: print('recv[%s]:%s' % (str(destaddr), recvdata)) else: print('[%s]客户端已经关闭') break finally: newsocket.close()def main(): #创建套接字 sersocket = socket(af_inet, sock_stream) #重复使用绑定信息 sersocket.setsockopt(sol_socket, so_reuseaddr, 1) localaddr = ('', 7788) #绑定端口ip sersocket.bind(localaddr) #监听 sersocket.listen(5) try: while true: print('－－－主进程，等待新客户端的到来－－－') newsocket,destaddr = sersocket.accept() print('－－－主进程，接下来负责数据处理[%s]－－－'%str(destaddr)) client = process(target=dealwithclient, args=(newsocket, destaddr)) client.start() # 因为已经向子进程中copy了一份（引用），并且父进程中这个套接字也没有用处了 # 所以关闭 newsocket.close() finally: # 当为所有的客户端服务完之后再进行关闭，表示不再接收新的客户端的链接 sersocket.close()if __name__ == '__main__': main() |
总结
通过为每个客户端创建一个进程的方式，能够同时为多个客户端进行服
务当客户端不是特别多的时候，这种方式还行，如果有成百上千个，就不
可取了，因为每次创建进程的过程需要消耗较多的资源。
python - 多线程服务器
|
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
|
#coding=utf-8from socket import *from threading import threadfrom time import sleep# 处理客户端的请求并执行事情def dealwithclient(newsocket,destaddr): while true: recvdata = newsocket.recv(1024) if len(recvdata)>0: print('recv[%s]:%s'%(str(destaddr), recvdata)) else: print('[%s]客户端已经关闭'%str(destaddr)) break newsocket.close()def main(): sersocket = socket(af_inet, sock_stream) sersocket.setsockopt(sol_socket, so_reuseaddr , 1) localaddr = ('', 7788) sersocket.bind(localaddr) sersocket.listen(5) try: while true: print('-----主进程，，等待新客户端的到来------') newsocket,destaddr = sersocket.accept() print('-----主进程，，接下来创建一个新的进程负责数据处理[%s]----'%str(destaddr)) client = thread(target=dealwithclient, args=(newsocket,destaddr)) client.start() #因为线程中共享这个套接字，如果关闭了会导致这个套接字不可用， #但是此时在线程中这个套接字可能还在收数据，因此不能关闭 #newsocket.close() finally: # 当为所有的客户端服务完之后再进行关闭，表示不再接收新的客户端的链接 sersocket.close()if __name__ == '__main__': main() |
单进程服务器-非堵塞模式
服务器：
|
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
39
40
41
42
43
44
|
#coding=utf-8from socket import *import time# 用来存储所有的新链接的socketg_socketlist = []def main(): sersocket = socket(af_inet, sock_stream) sersocket.setsockopt(sol_socket, so_reuseaddr , 1) localaddr = ('', 7788) sersocket.bind(localaddr) #可以适当修改listen中的值来看看不同的现象 sersocket.listen(1000) #将套接字设置为?堵塞 #设置为?堵塞后，如果accept时，恰巧没有客户端connect，那么accept会 #产生一个异常，所以需要try来进行处理 sersocket.setblocking(false) while true: #?来测试 #time.sleep(0.5) try: newclientinfo = sersocket.accept() except exception as result: pass else: print("一个新的客户端到来:%s"%str(newclientinfo)) newclientinfo[0].setblocking(false) g_socketlist.append(newclientinfo) # 用来存储需要删除的客户端信息 needdelclientinfolist = [] for clientsocket,clientaddr in g_socketlist: try: recvdata = clientsocket.recv(1024) if len(recvdata)>0: print('recv[%s]:%s'%(str(clientaddr), recvdata)) else: print('[%s]客户端已经关闭'%str(clientaddr)) clientsocket.close() g_needdelclientinfolist.append((clientsocket,clientaddr)) except exception as result: pass for needdelclientinfo in needdelclientinfolist: g_socketlist.remove(needdelclientinfo)if __name__ == '__main__': main() |
客户端：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
#coding=utf-8from socket import *import randomimport timeserverip = input("请输入服务器的ip:")connnum = input("请输入要链接服务器的次数(例如1000):")g_socketlist = []for i in range(int(connnum)): s = socket(af_inet, sock_stream) s.connect((serverip, 7788)) g_socketlist.append(s) print(i)while true: for s in g_socketlist: s.send(str(random.randint(0,100))) # 用来测试 #time.sleep(1) |
希望本文所述对大家python程序设计有所帮助。
原文链接：https://blog.csdn.net/xuezhangjun0121/article/details/77639544
