【Python之旅】第五篇(二):Python Socket单线程+阻塞模式

简介:

 前面第五篇(一)中的一个Socket例子其实就是单线程的,即Server端一次只能接受来自一个Client端的连接,为了更好的说明socket单线程和阻塞模式,下面对前面的例子做修改。


1.单线程+阻塞+交互式

    前面的例子是单线程阻塞和非交互式的,现在改写为交互式的,即不会执行一次就结束,希望达到的效果是,发送的数据由User输入,然后Server端进行接收。

Server端:与上个例子一样,并没有什么变化

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
import  socket                #导入socket类
  
HOST = ''                      #定义侦听本地地址口(多个IP地址情况下),这里表示侦听所有,也可以写成 0.0 . 0.0
PORT =  50007                  #Server端开放的服务端口
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)    #选择Socket类型和Socket数据包类型
s.bind((HOST, PORT))         #绑定IP地址和端口
s.listen( 1 )                  #定义侦听数开始侦听(实际上并没有效果)
conn, addr = s.accept()      #定义实例,accept()函数的返回值可以看上面的socket函数说明
  
print  'Connected by' , addr
while  1 :
     data = conn.recv( 1024 )    #接受套接字的数据
     if  not data: break          #如果没有数据接收,则断开连接
     print  'revc:' ,data        #发送接收到的数据
     conn.sendall(data)        #发送接收到的数据
conn.close()                      #关闭套接字

Client端:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
import  socket
 
HOST =  '192.168.1.13'
PORT =  50007
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
 
while  True:
     user_input = raw_input( 'msg to send:' ).strip()    #由User输入要发送的数据
     s.sendall(user_input)
     data = s.recv( 1024 )
     print  'Received' , repr(data)
 
s.close()

演示:

步骤1:Server端运行服务端程序

1
2
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python server4.py 
===>光标在此处处于等待状态

步骤2:Client A端运行客户端程序

1
2
3
4
5
6
7
8
9
10
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:The first msg.    ===>User输入数据
Received  'The first msg.'      ===>Server端返回的数据
msg to send:The second msg.
Received  'The second msg.'
msg to send:The third msg.
Received  'The third msg.'
msg to send:I'm A.
Received  "I'm A."
msg to send:                  ===>继续等待User输入数据

步骤3:在Server端中观察现象

1
2
3
4
5
6
7
8
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5/[ 2 ]sec_4_ver2(单线程,交互式,阻塞模
一般演示)$ python server4.py 
Connected by ( '192.168.1.13' 52645 )
revc: The first msg.    ===>接收到用户发送的数据
revc: The second msg.
revc: The third msg.
revc: I'm A.
===>光标在此处处于等待状态

如果此时有另一个Client B端再连接进来,会有下面的情况:

1
2
3
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:I'm B
===>光标在此处处于等待状态

    这时如果在Client A端断开连接,则服务端也会关闭套接字,Client B端发送的数据仍然无法被Server端接收。

    此时服务端即出现阻塞情况,因为服务端还和Client A处于连接状态,无法接收Client B发送的数据,这也说明了此时的Server端是单线程的。


2.单线程+阻塞+交互式的进阶演示

    把上面的例子中的代码再做进一步的修改,以使得阻塞模式的现象更加明显。

Server端:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import  socket
 
HOST = ''
PORT =  50007
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen( 1 )
 
while  1 :
     conn, addr = s.accept()        #在循环中接受Client端连接的请求
     print  'Connected by' , addr
     while  True:                    #再做一个内部的循环
         data = conn.recv( 1024 )
         print  'Received' ,data
         if  not data: break
         conn.sendall(data)
conn.close()

Client端:与前面例子的代码一样

1
2
3
4
5
6
7
8
9
10
11
12
13
14
import  socket
 
HOST =  '192.168.1.13'
PORT =  50007
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
 
while  True:
     user_input = raw_input( 'msg to send:' ).strip()
     s.sendall(user_input)
     data = s.recv( 1024 )
     print  'Received' , repr(data)
 
s.close()

演示:

步骤1:Server端运行服务端程序

1
2
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python server4.py 
===>光标在此处处于等待状态

步骤2:Client A端运行客户端程序

1
2
3
4
5
6
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:Hello!
Received  'Hello!'
msg to send:I'm Client A.
Received  "I'm Client A."
msg to send:        ===>继续等待User输入数据

步骤3:在Server端中观察现象

1
2
3
4
5
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python server4.py 
Connected by ( '192.168.1.13' 52647 )
Received Hello!
Received I'm Client A.
===>光标在此处处于等待状态

如果此时有另一个Client B端再连接进来,会有下面的情况:

1
2
3
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:I'm Client B.
===>光标在此处处于等待状态

Server端的状态依然为:

1
2
3
4
5
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python server4.py 
Connected by ( '192.168.1.13' 52647 )
Received Hello!
Received I'm Client A.
===>光标在此处处于等待状态

这时试图把Client A端断开:

1
2
3
4
5
6
7
8
9
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:Hello!
Received  'Hello!'
msg to send:I'm Client A.
Received  "I'm Client A."
msg to send:^CTraceback (most recent call last):
   File  "client4.py" , line  10 in  <module>
     user_input = raw_input( 'msg to send:' ).strip()
KeyboardInterrupt

再看看Server端的情况:

1
2
3
4
5
6
7
8
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python server4.py 
Connected by ( '192.168.1.13' 52647 )
Received Hello!
Received I'm Client A.
Received 
Connected by ( '192.168.1.13' 52648 )
Received I'm Client B.    ===>成功接收到来自Client B端发送的数据
===>光标在此处处于等待状态

再看看Client B端的情况:

1
2
3
4
xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:I'm Client B.
Received  "I'm Client B."
msg to send:    ===>光标在此处处于等待状态

    以上的现象,再根据Server端的程序代码,就可以非常好理解单线程模式和阻塞的细节情况了,在这里是这样的:Server端接受Client A端的连接后,即把接受连接的线程释放,但此时仍然占用接收和发送数据的线程,所以Client B端虽然可以连接上Server端,但数据是无法成功被Server端接收的;当Client A端断开与Server端的连接后,Server端的接收和发送数据的线程立即被释放,之后就可以正常接收来自Client B端发送的数据了。

    


    单线程,即数据的串行发送,会导致阻塞,上面的两个例子就非常好地演示了这个阻塞的过程,如果要解决这个问题,当然在Server端就需要支持多线程,即数据折并发。

相关文章
|
3月前
|
负载均衡 算法 安全
基于Reactor模式的高性能网络库之线程池组件设计篇
EventLoopThreadPool 是 Reactor 模式中实现“一个主线程 + 多个工作线程”的关键组件,用于高效管理多个 EventLoop 并在多核 CPU 上分担高并发 I/O 压力。通过封装 Thread 类和 EventLoopThread,实现线程创建、管理和事件循环的调度,形成线程池结构。每个 EventLoopThread 管理一个子线程与对应的 EventLoop(subloop),主线程(base loop)通过负载均衡算法将任务派发至各 subloop,从而提升系统性能与并发处理能力。
172 3
|
3月前
|
数据采集 存储 JSON
Python爬取知乎评论:多线程与异步爬虫的性能优化
Python爬取知乎评论:多线程与异步爬虫的性能优化
|
3月前
|
人工智能 安全 调度
Python并发编程之线程同步详解
并发编程在Python中至关重要,线程同步确保多线程程序正确运行。本文详解线程同步机制,包括互斥锁、信号量、事件、条件变量和队列,探讨全局解释器锁(GIL)的影响及解决线程同步问题的最佳实践,如避免全局变量、使用线程安全数据结构、精细化锁的使用等。通过示例代码帮助开发者理解并提升多线程程序的性能与可靠性。
128 0
|
1月前
|
开发者 Python
Python中的match-case语句:更优雅的模式匹配
Python中的match-case语句:更优雅的模式匹配
|
6月前
|
数据采集 监控 数据安全/隐私保护
Python正则表达式:用"模式密码"解锁复杂字符串
正则表达式是处理字符串的强大工具,本文以Python的`re`模块为核心,详细解析其原理与应用。从基础语法如字符类、量词到进阶技巧如贪婪匹配与预定义字符集,结合日志分析、数据清洗及网络爬虫等实战场景,展示正则表达式的强大功能。同时探讨性能优化策略(如预编译)和常见错误解决方案,帮助开发者高效掌握这一“瑞士军刀”。最后提醒,合理使用正则表达式,避免过度复杂化,追求简洁优雅的代码风格。
162 0
|
3月前
|
数据采集 监控 调度
干货分享“用 多线程 爬取数据”:单线程 + 协程的效率反超 3 倍,这才是 Python 异步的正确打开方式
在 Python 爬虫中,多线程因 GIL 和切换开销效率低下,而协程通过用户态调度实现高并发,大幅提升爬取效率。本文详解协程原理、实战对比多线程性能,并提供最佳实践,助你掌握异步爬虫核心技术。
|
4月前
|
JSON 算法 Java
打造终端里的下载利器:Python实现可恢复式多线程下载器
在数字时代,大文件下载已成为日常需求。本文教你用Python打造专业级下载器,支持断点续传、多线程加速、速度限制等功能,显著提升终端下载体验。内容涵盖智能续传、多线程分块下载、限速控制及Rich库构建现代终端界面,助你从零构建高效下载工具。
274 1
|
3月前
|
数据采集 存储 Java
多线程Python爬虫:加速大规模学术文献采集
多线程Python爬虫:加速大规模学术文献采集
|
4月前
|
数据采集 网络协议 前端开发
Python多线程爬虫模板:从原理到实战的完整指南
多线程爬虫通过并发请求大幅提升数据采集效率,适用于大规模网页抓取。本文详解其原理与实现,涵盖任务队列、线程池、会话保持、异常处理、反爬对抗等核心技术,并提供可扩展的Python模板代码,助力高效稳定的数据采集实践。
208 0

推荐镜像

更多