本文实例讲述了Python实现的服务器。分享给大家供大家参考,具体如下:
python - 单进程服务器
#coding=utf-8 from socket import * #创建套接字 serSocket = socket(AF_INET, SOCK_STREAM) #重复使用绑定信息 serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) localAddr = ('', 7788) #绑定端口ip serSocket.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 - 多进程服务器
#coding=utf-8 from 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 - 多线程服务器
#coding=utf-8 from socket import * from threading import Thread from 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()
单进程服务器-非堵塞模式
服务器:
#coding=utf-8 from socket import * import time # 用来存储所有的新链接的socket g_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) #将套接字设置为"一个新的客户端到来:%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()
客户端:
#coding=utf-8 from socket import * import random import time serverIp = 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相关内容可查看本站专题:《Python Socket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。