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

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

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

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

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

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端:

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端运行服务端程序

[email protected]:/mnt/hgfs/Python/day5$ python server4.py 
===>光标在此处处于等待状态

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

[email protected]:/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端中观察现象

[email protected]:/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端再连接进来,会有下面的情况:

[email protected]:/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端:

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端:与前面例子的代码一样

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端运行服务端程序

[email protected]:/mnt/hgfs/Python/day5$ python server4.py 
===>光标在此处处于等待状态

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

[email protected]:/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端中观察现象

[email protected]:/mnt/hgfs/Python/day5$ python server4.py 
Connected by (‘192.168.1.13‘, 52647)
Received Hello!
Received I‘m Client A.
===>光标在此处处于等待状态

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

[email protected]:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:I‘m Client B.
===>光标在此处处于等待状态

Server端的状态依然为:

[email protected]:/mnt/hgfs/Python/day5$ python server4.py 
Connected by (‘192.168.1.13‘, 52647)
Received Hello!
Received I‘m Client A.
===>光标在此处处于等待状态

这时试图把Client A端断开:

[email protected]:/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端的情况:

[email protected]:/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端的情况:

[email protected]:/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端就需要支持多线程,即数据折并发。

时间: 2024-10-10 05:01:20

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

python学习记录第五篇--遍历目录

#coding=utf-8'''@author: 简单遍历目录删除文件的小程序'''import os#查找文件操作def findFile(path): fileList=[] for rootPath,subRoot,fileName in os.walk(path): for sub in fileName: if os.path.isfile(os.path.join(rootPath,sub)): k=os.path.splitext(sub)[1].lower() if k in (

第五篇:python基础之字符编码

1. 计算机基础知识(三幅图) 2. 文本编辑器存取文件的原理(nodepad++,pycharm,word) 打开编辑器就打开了启动了一个进程,是在内存中的,所以在编辑器编写的内容也都是存放与内存中的,断电后数据丢失 因而需要保存到硬盘上,点击保存按钮,就从内存中把数据刷到了硬盘上. 在这一点上,我们编写一个py文件(没有执行),跟编写其他文件没有任何区别,都只是在编写一堆字符而已.  3. python解释器执行py文件的原理 ,例如python test.py 1.第一阶段,python解

Python网络编程之高级篇二

在上一篇中,我们深入探讨了TCP/IP协议的11种状态,理解这些状态对我们编写服务器的时候有很大的帮助,但一般写服务器都是使用C/Java语言,因为这些语言对高并发的支持特别好.我们写的这些简单的服务器主要是为了深入学习TCP/IP协议.IO操作以及Python中协程的原理.在上一篇中也提到非阻塞这个概念,在这一篇中,我们继续深入探讨IO模型,因为理解IO操作对我们深入学习异步编程有很大帮助.所以在这一节中我们主要是从Linux内核态和用户态的层面来考虑IO操作时会发生什么样的事情,Linux内

Python零基础学习系列之二--Python介绍及环境搭建

1-1.Python简介: Python是一种解释型.面向对象.动态数据类型的高级程序设计语言.Python由Guido van Rossum于1989年底发明,第一个公开发行版发行于1991年.像Perl语言一样, Python 源代码同样遵循 GPL(GNU General Public License)协议. Python(英国发音:/?pa?θ?n/ 美国发音:/?pa?θɑ?n/), 是一种面向对象的解释型计算机程序设计语言,由荷兰人Guido van Rossum于1989年发明,第

Python之路,第一篇:Python入门与基础

第一篇:Python入门与基础 1,什么是python? Python 是一个高层次的结合了解释性.编译性.互动性和面向对象的脚本语言. 2,python的特征: (1)易于学习,易于利用: (2)开发效率高,内建众多数据类型,强大的标准库支持: (3)高级语言: (4)可移植性,基于开放源代码特性 (5)可扩展性,如果你需要一段运行很快的关键代码,或者是想要编写一些不愿开放的算法,你可以使用C或C++完成那部分程序,然后从你的Python程序中调用. (6)可嵌入,你可以将Python嵌入到C

Python成长之路 第一篇 《Python基础》

1.python文件命名 - 后缀名可以是任意的,但为规范便于识别,后缀名应为 .py 2.两种执行方式    python解释器   py文件路径     python   进入解释器: 实时输入并获取到执行结果 3.解释器路径 在Linux系统中应添加  #!/user/bin/env python    , windows系统中可不添加 4.编码 # -*- coding:utf8 -*-  (在python3中可不加,python只要出现中文头部必须加) ascill  只能编译英文 u

【Python之旅】第二篇(五):基于列表、字典和元组的员工信息处理接口

1.基本需求 编写一个查询员工信息表的程序,实现如下功能: (1)让用户输入不小于3个字符查询员工信息 (2)通过员工号或员工个人信息可以精确或模糊查询到员工信息 (3)输出员工信息 2.实现代码与注释 首先提供员工信息的txt文件: [email protected]:/mnt/hgfs/Python/day3$ more student_info.txt  stu1101 mingjia.xu [email protected] 263 SystemAdmin 18810404260 stu

第五篇:python基础_5

本篇内容 协程函数 递归 二分法 import语句 from...import语句 模块搜索路径 包的导入 软件开发规范 logging模块的使用 一. 协程函数 1.定义 协程函数就是使用了yield表达式形式的生成器. #!/usr/binl/env python #encoding: utf-8 #author: YangLei def eater(name): print("%s eat food" %name) while True: food = yield g = eat

Python 学习日记第五篇 -- collections系列

一.计数器(counter) 计数器(counter)以字典的形式返回序列中各个字符出现的次数,值为key,次数为value #!/usr/bin/env python #-*- coding:utf-8 -*- #导入collections模块 import collections counter_test = collections.Counter("asfafjhadgkhjkgfjhgfjhaghdg") print(counter_test) #返回值 C:\Python27