Python实现的服务器示例小结【单进程、多进程、多线程、非阻塞式】
本文实例讲述了Python实现的服务器。分享给大家供大家参考，具体如下：
python-单进程服务器
#coding=utf-8
fromsocketimport*
#创建套接字
serSocket=socket(AF_INET,SOCK_STREAM)
#重复使用绑定信息
serSocket.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
localAddr=('',7788)
#绑定端口ip
serSocket.bind(localAddr)
#监听
serSocket.listen(5)
whileTrue:
print('－－－主进程，等待新客户端的到来－－－')
newSocket,destAddr=serSocket.accept()
print('－－－主进程，接下来负责数据处理[%s]－－－'%str(destAddr))
try:
whileTrue:
recvData=newSocket.recv(1024)
iflen(recvData)>0:
print('recv[%s]:%s'%(str(destAddr),recvData))
else:
print('[%s]客户端已经关闭')
break
finally:
newSocket.close()
serSocket.close()
总结
同一时刻只能为一个客户进行服务，不能同时为多个客户服务。
当服务器为一个客户端服务时，另外的客户端发起了connect，只要服务器listen的队列有空闲的位置，就会为这个新客户端进行连接，并且客户端可以发送数据，但当服务器为这个新客户端服务时，可能一次性把所有数据接收完毕当recv接收数据时，返回值为空，即没有返回数据，那么意味着客户端已经调用了close关闭了；因此服务器通过判断recv接收数据是否为空来判断客户端是否已经下线。
python-多进程服务器
#coding=utf-8
fromsocketimport*
frommultiprocessingimport*
fromtimeimportsleep
#处理客户端的请求并为其服务
defdealWithClient(newSocket,destAddr):
try:
whileTrue:
recvData=newSocket.recv(1024)
iflen(recvData)>0:
print('recv[%s]:%s'%(str(destAddr),recvData))
else:
print('[%s]客户端已经关闭')
break
finally:
newSocket.close()
defmain():
#创建套接字
serSocket=socket(AF_INET,SOCK_STREAM)
#重复使用绑定信息
serSocket.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
localAddr=('',7788)
#绑定端口ip
serSocket.bind(localAddr)
#监听
serSocket.listen(5)
try:
whileTrue:
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-多线程服务器
#coding=utf-8
fromsocketimport*
fromthreadingimportThread
fromtimeimportsleep
#处理客户端的请求并执行事情
defdealWithClient(newSocket,destAddr):
whileTrue:
recvData=newSocket.recv(1024)
iflen(recvData)>0:
print('recv[%s]:%s'%(str(destAddr),recvData))
else:
print('[%s]客户端已经关闭'%str(destAddr))
break
newSocket.close()
defmain():
serSocket=socket(AF_INET,SOCK_STREAM)
serSocket.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
localAddr=('',7788)
serSocket.bind(localAddr)
serSocket.listen(5)
try:
whileTrue:
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()
单进程服务器-非堵塞模式
服务器：
#coding=utf-8
fromsocketimport*
importtime
#用来存储所有的新链接的socket
g_socketList=[]
defmain():
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)
whileTrue:
#?来测试
#time.sleep(0.5)
try:
newClientInfo=serSocket.accept()
exceptExceptionasresult:
pass
else:
print("一个新的客户端到来:%s"%str(newClientInfo))
newClientInfo[0].setblocking(False)
g_socketList.append(newClientInfo)
#用来存储需要删除的客户端信息
needDelClientInfoList=[]
forclientSocket,clientAddring_socketList:
try:
recvData=clientSocket.recv(1024)
iflen(recvData)>0:
print('recv[%s]:%s'%(str(clientAddr),recvData))
else:
print('[%s]客户端已经关闭'%str(clientAddr))
clientSocket.close()
g_needDelClientInfoList.append((clientSocket,clientAddr))
exceptExceptionasresult:
pass
forneedDelClientInfoinneedDelClientInfoList:
g_socketList.remove(needDelClientInfo)
if__name__=='__main__':
main()
客户端：
#coding=utf-8
fromsocketimport*
importrandom
importtime
serverIp=input("请输入服务器的ip:")
connNum=input("请输入要链接服务器的次数(例如1000):")
g_socketList=[]
foriinrange(int(connNum)):
s=socket(AF_INET,SOCK_STREAM)
s.connect((serverIp,7788))
g_socketList.append(s)
print(i)
whileTrue:
forsing_socketList:
s.send(str(random.randint(0,100)))
#用来测试
#time.sleep(1)
更多关于Python相关内容可查看本站专题：《PythonSocket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。