基于socketserver实现并发#

多进程实现并发

【一】TCP协议实现并发#

【1】客户端

1
# -*-coding: Utf-8 -*-
2
# @File : 客户端 .py
3
# author: Chimengmeng
4
# blog_url : https://www.cnblogs.com/dream-ze/
5
# Time：2023/6/23
6
from socket import *
7

8
client = socket(AF_INET, SOCK_STREAM)
9
client.connect(('127.0.0.1', 8080))
10

11
while True:
12
    msg_client = input('请输入指令:>>>>>').strip()
13

14
    if len(msg_client) == 0:
15
        continue
16

17
    client.send(msg_client.encode('utf8'))
18

19
    msg_from_server = client.recv(1024)
20
    print(msg_from_server.decode('utf8'))

【2】服务端

1
# -*-coding: Utf-8 -*-
2
# @File : 服务端 .py
3
# author: Chimengmeng
4
# blog_url : https://www.cnblogs.com/dream-ze/
5
# Time：2023/6/23
6

7
import socketserver
8

9

10
class MyRequestHandler(socketserver.BaseRequestHandler):
11
    def handle(self):
12
        # print(self.request) ---->  # 如果是 TCP 协议, self.request ----> conn
13
        # print(self.client_address) ---->  # 如果是 TCP 协议, self.client_address ----> ip + port
14
        print(self.request)
15
        print(self.client_address)
16

17
        # （2）任务二：拿到链接对象，与其进行通信循环 =====> handle方法
18
        while True:
19
            try:
20
                # 接收来自客户端的信息指令
21
                msg_from_client = self.request.recv(1024)
22

23
                if len(msg_from_client) == 0:
24
                    continue
25

26
                # 反馈信息给客户端
27
                msg_to_client = msg_from_client.upper()
28
                self.request.send(msg_to_client)
29

30
            except Exception as e:
31
                print(e)
32
                break
33

34
        self.request.close()
35

36

37
# （1）任务一：循环的从半连接池中取出链接请求与其建立双向链接，拿到链接对象
38

39
# 实例化链接对象
40
server = socketserver.ThreadingTCPServer(('127.0.0.1', 8088), MyRequestHandler)
41
# 创建链接循环 ---- 一直提供服务（死循环过程）
42
server.serve_forever()
43
'''
44
等同于以下操作
45

46
while True:
47
    conn,client_address = server.accept()
48
    # 启动一个线程(conn,client_address)
49
'''

【二】UDP协议实现并发#

【1】服务端#

1
# -*-coding: Utf-8 -*-
2
# @File : 服务端 .py
3
# author: Chimengmeng
4
# blog_url : https://www.cnblogs.com/dream-ze/
5
# Time：2023/6/23
6
import socketserver
7

8

9
class MyRequestHandler(socketserver.BaseRequestHandler):
10
    def handle(self):
11
        '''
12
        # print(self.request)
13
        # (b'hellow', <socket.socket fd=420, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>)
14
        '''
15
        # 接收到的第一个数据是传入进来的信息
16
        msg_from_client = self.request[0]
17
        # 接收到的第二个数据是传入进来的链接对象
18
        server = self.request[1]
19

20
        client_address = self.client_address
21
        # ('127.0.0.1', 64418)
22

23
        # 回传数据
24
        msg_to_client = msg_from_client.upper()
25
        server.sendto(msg_to_client, client_address)
26

27

28
IP = '127.0.0.1'
29
PORT = 8080
30
server = socketserver.ThreadingUDPServer((IP, PORT), MyRequestHandler)
31
server.serve_forever()
32

33
'''
34
相当于
35
# 只负责循环的接收对象
36
while True:
37
    msg_from_client, client_address = server.recvfrom(1024)
38

39
    # 启动一个线程去处理后续的操作
40
    msg_to_client = msg_from_client.upper()
41
    server.sendto(msg_to_client, client_address)
42
'''
43

44
server.close()

【2】客户端#

1
# -*-coding: Utf-8 -*-
2
# @File : 客户端 .py
3
# author: Chimengmeng
4
# blog_url : https://www.cnblogs.com/dream-ze/
5
# Time：2023/6/23
6

7
from socket import *
8

9
client = socket(AF_INET, SOCK_DGRAM)
10

11
while True:
12
    msg_to_server = input('请输入信息:>>>>>').strip()
13

14
    msg_to_server = msg_to_server.encode('utf-8')
15
    IP = '127.0.0.1'
16
    PORT = 8080
17
    client.sendto(msg_to_server, (IP, PORT))
18

19
    msg_from_server = client.recvfrom(1024)
20

21
    print(msg_from_server)
22

23
client.close()

音乐

音乐

基于socketserver实现并发#

【一】TCP协议实现并发#

【二】UDP协议实现并发#

【1】服务端#

【2】客户端#

支持与分享

音乐

基于 SocketServer 实现并发

基于socketserver实现并发#

【一】TCP协议实现并发#

【二】UDP协议实现并发#

【1】服务端#

【2】客户端#

支持与分享