【Python之旅】第五篇（三）：Pyt

发布时间：2019-09-13 09:25:31编辑：auto阅读（1878）

    前面的几个例子都是单线程的，下面再来说说多线程的。





1.多线程模块

    主要是socketserver模块，如下图示：






2.多线程原理

    如下图示说明：







3.SockteServer例子说明

服务器端：







客户端：






4.演示

    还是以前面例子，对代码进行修改，作如下的演示。


Server端：

import SocketServer            #导入SocketServer，多线程并发由此类实现

class MySockServer(SocketServer.BaseRequestHandler):    #定义一个类

	def handle(self):      #handle(self)方法是必须要定义的，可以看上面的说明
		print 'Got a new connection from', self.client_address
		while True:
			data = self.request.recv(1024)    #需要通过self的方法调用数据接收函数
			if not data:break
			print 'recv:', data

			self.request.send(data.upper())   #需要通过self的方法调用数据接收函数

if __name__ == '__main__':    #并非一定要用这样的方式，只是建议这样使用
	HOST = ''             #定义侦听本地地址口（多个IP地址情况下），这里表示侦听所有
	PORT = 50007          #Server端开放的服务端口
	s = SocketServer.ThreadingTCPServer((HOST, PORT), MySockServer)
                              #调用SocketServer模块的多线程并发函数
	s.serve_forever()     #持续接受客户端的连接

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

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

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

xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:Hello!    ===>User输入数据
Received 'HELLO!'     ===>Server端返回的数据
msg to send:I'm Client A.
Received "I'M CLIENT A."
msg to send:          ===>继续等待User输入数据

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

xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python Thread_socket_server4.py 
Got a new connection from ('192.168.1.13', 52650)
recv: Hello!        
recv: I'm Client A.    ===>接收到Client A端发送的数据
===>光标在此处处于等待状态

步骤4：Client B端运行客户端程序

xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python client4.py 
msg to send:I'm Client B.    ===>User输入数据
Received "I'M CLIENT B."     ===>Server端返回的数据
msg to send:                 ===>继续等待User输入数据

步骤5：在Server端中观察现象

xpleaf@xpleaf-machine:/mnt/hgfs/Python/day5$ python Thread_socket_server4.py 
Got a new connection from ('192.168.1.13', 52650)
recv: Hello!
recv: I'm Client A.
Got a new connection from ('192.168.1.13', 52651)
recv: I'm Client B.    ===>接收到Client A端发送的数据
===>光标在此处处于等待状态

    通过上面的演示，使用SocketServer便可以实现Python Socket的多线程并发。

关键字：