【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端就需要支持多线程,即数据折并发。

相关文章
|
2月前
|
机器学习/深度学习 数据采集 TensorFlow
使用Python实现智能食品消费模式分析的深度学习模型
使用Python实现智能食品消费模式分析的深度学习模型
157 70
|
27天前
|
并行计算 安全 Java
Python GIL(全局解释器锁)机制对多线程性能影响的深度分析
在Python开发中,GIL(全局解释器锁)一直备受关注。本文基于CPython解释器,探讨GIL的技术本质及其对程序性能的影响。GIL确保同一时刻只有一个线程执行代码,以保护内存管理的安全性,但也限制了多线程并行计算的效率。文章分析了GIL的必要性、局限性,并介绍了多进程、异步编程等替代方案。尽管Python 3.13计划移除GIL,但该特性至少要到2028年才会默认禁用,因此理解GIL仍至关重要。
125 16
Python GIL(全局解释器锁)机制对多线程性能影响的深度分析
|
14天前
|
Python
python3多线程中使用线程睡眠
本文详细介绍了Python3多线程编程中使用线程睡眠的基本方法和应用场景。通过 `time.sleep()`函数,可以使线程暂停执行一段指定的时间,从而控制线程的执行节奏。通过实际示例演示了如何在多线程中使用线程睡眠来实现计数器和下载器功能。希望本文能帮助您更好地理解和应用Python多线程编程,提高程序的并发能力和执行效率。
41 20
|
2天前
|
SQL 数据建模 BI
【YashanDB 知识库】用 yasldr 配置 Bulkload 模式作单线程迁移 300G 的业务数据到分布式数据库,迁移任务频繁出错
问题描述 详细版本:YashanDB Server Enterprise Edition Release 23.2.4.100 x86_64 6db1237 影响范围: 离线数据迁移场景,影响业务数据入库。 外场将部分 NewCIS 的报表业务放到分布式数据库,验证 SQL 性能水平。 操作系统环境配置: 125G 内存 32C CPU 2T 的 HDD 磁盘 问题出现的步骤/操作: 1、部署崖山分布式数据库 1mm 1cn 3dn 单线启动 yasldr 数据迁移任务,设置 32 线程的 bulk load 模式 2、观察 yasldr.log 是否出现如下错
|
1天前
|
数据采集 Java 数据处理
Python实用技巧:轻松驾驭多线程与多进程,加速任务执行
在Python编程中,多线程和多进程是提升程序效率的关键工具。多线程适用于I/O密集型任务,如文件读写、网络请求;多进程则适合CPU密集型任务,如科学计算、图像处理。本文详细介绍这两种并发编程方式的基本用法及应用场景,并通过实例代码展示如何使用threading、multiprocessing模块及线程池、进程池来优化程序性能。结合实际案例,帮助读者掌握并发编程技巧,提高程序执行速度和资源利用率。
10 0
|
3月前
|
设计模式 开发者 Python
Python编程中的设计模式:工厂方法模式###
本文深入浅出地探讨了Python编程中的一种重要设计模式——工厂方法模式。通过具体案例和代码示例,我们将了解工厂方法模式的定义、应用场景、实现步骤以及其优势与潜在缺点。无论你是Python新手还是有经验的开发者,都能从本文中获得关于如何在实际项目中有效应用工厂方法模式的启发。 ###
|
2月前
|
机器学习/深度学习 数据采集 数据挖掘
使用Python实现智能食品消费模式预测的深度学习模型
使用Python实现智能食品消费模式预测的深度学习模型
92 2
|
3月前
|
数据采集 存储 数据处理
Python中的多线程编程及其在数据处理中的应用
本文深入探讨了Python中多线程编程的概念、原理和实现方法,并详细介绍了其在数据处理领域的应用。通过对比单线程与多线程的性能差异,展示了多线程编程在提升程序运行效率方面的显著优势。文章还提供了实际案例,帮助读者更好地理解和掌握多线程编程技术。
|
2月前
|
缓存 安全 Java
【JavaEE】——单例模式引起的多线程安全问题:“饿汉/懒汉”模式,及解决思路和方法(面试高频)
单例模式下,“饿汉模式”,“懒汉模式”,单例模式下引起的线程安全问题,解锁思路和解决方法
|
3月前
|
并行计算 数据处理 调度
Python中的并发编程:探索多线程与多进程的奥秘####
本文深入探讨了Python中并发编程的两种主要方式——多线程与多进程,通过对比分析它们的工作原理、适用场景及性能差异,揭示了在不同应用需求下如何合理选择并发模型。文章首先简述了并发编程的基本概念,随后详细阐述了Python中多线程与多进程的实现机制,包括GIL(全局解释器锁)对多线程的影响以及多进程的独立内存空间特性。最后,通过实例演示了如何在Python项目中有效利用多线程和多进程提升程序性能。 ####

热门文章

最新文章