脚本之家，脚本语言编程技术及教程分享平台！
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Python - Python实现的服务器示例小结【单进程、多进程、多线程、非阻塞式】

Python实现的服务器示例小结【单进程、多进程、多线程、非阻塞式】

2021-06-28 00:44xuezhangjun Python

这篇文章主要介绍了Python实现的服务器,结合实例形式分析了Python实现单进程、多进程、多线程、非阻塞式服务器的相关操作技巧,需要的朋友可以参考下

本文实例讲述了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-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 - 多进程服务器

?
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-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 - 多线程服务器

?
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-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()

单进程服务器-非堵塞模式

服务器：

?
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-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)
  #将套接字设置为?堵塞
  #设置为?堵塞后，如果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-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程序设计有所帮助。

原文链接：https://blog.csdn.net/xuezhangjun0121/article/details/77639544

  • Python
  • 服务器

    • 延伸 · 阅读

    精彩推荐
    最近更新
    编辑推荐
    阅读排行
    热门标签
    2048 　 6006 　 contextlib 　 SLOTS 　 MELIAE 　 FEEDPARSER 　 暂存 　 持久性管理 　 pickle模块 　 THREADING 　 reduce 　 nignx 　 装饰器 　 函数式编程 　 兔子毒药 　 监控文件 　 流量监控 　 Web框架 　 办公工具 　 PIL库 　 高斯模糊 　 wxPython 　 import 　 自定义模块 　 Python开发 　 元类 　 metaclass 　 魔术方法 　 DNSPod 　 动态解析域名 　
    © 2019-2023 脚本之家 | 服务器之家(www.zzvips.com)旗下站点 版权所有关于我们联系我们版权申明网站地图