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

8
# 【1】.买手机
9
# socket.SOCK_STREAM ：流式协议 ----> TCP协议 ----> 所有数据是一个整体
10
# socket.SOCK_DGRAM : 报协议  ----> 每一次数据都是单独一部分
11
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
12

13
# 【2】.绑定手机卡 ---> 192.168.1.50(本机IP地址)
14
# 0.0.0.0(任意IP地址) ---> 关联公网IP才会起作用  ----> 服务器用
15
# 127.0.0.1(本机固定IP地址) ---> 只有本机才能访问这个地址（测试用）
16
# 端口号：0-65535, 1024以前的都被系统保留使用
17
# phone.bind(('ip', port))
18
phone.bind(('127.0.0.1', 8080))
19

20
# 【3】.开机 -- 监听状态
21
# 5 ：指的是半连接池的大小
22
phone.listen(5)
23
print(f'服务器启动,开始监听ip:>>>{"127.0.0.1"},port:>>>{8080}')
24
# （1）服务器启动,开始监听ip:>>>127.0.0.1,port:>>>8080
25

26
# 【4】.等待电话链接请求:拿到电话链接 conn
27
# 返回的是双向通路 --- 操作系统维持链接
28
# conn ： 双向通路的链接
29
# client_addr ： 客户端的iP和端口
30
conn, client_addr = phone.accept()
31
print('这是服务端的conn:>>>', conn)
32
# （3）这是服务端的conn:>>> <socket.socket fd=352, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 8080), raddr=('127.0.0.1', 5249)>
33
print('这是服务端的client_addr:>>>', client_addr)
34
# （4）这是服务端的client_addr:>>> ('127.0.0.1', 5249)
35

36
# 【5】.接收消息
37
# 1024 ：最大接受的数据量为1024 bytes类型，收到的是bytes类型
38
data = conn.recv(1024)
39
# 对接受的二进制数据进行解码
40
print('从客户端接受的数据:>>>>', data.decode('utf-8'))
41
# （5）从客户端接受的数据:>>>> is running for 发送信息
42
# 发消息 返回消息状态等信息
43
conn.send(data.upper())
44

45
# 【6】.关闭连接(必选的回收资源操作) conn
46
# 完成后断开连接
47
conn.close()
48

49
# 【7】.关机(可选操作)
50
phone.close()

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

8
# 【1】.买手机
9
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
10

11
# 【2】.拨通服务端电话
12
# connect(('服务端ip', 服务端端口))
13
phone.connect(('127.0.0.1', 8080))
14
# （2）
15
# 【3】.通信
16
# send(二进制数据类型)
17
phone.send('is running for 发送信息'.encode('utf8'))
18

19
# 接受服务端返回的数据
20
data = phone.recv(1024)
21
# 打印返回的消息 解码
22
print(data.decode('utf8'))
23
# （6）IS RUNNING FOR 发送信息
24

25
# 【4】.关闭连接(必选的回收资源操作)
26
phone.close()

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

8
# 【1】.买手机
9
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
10

11
# 【2】.拨通服务端电话
12
# connect(('服务端ip', 服务端端口))
13
phone.connect(('127.0.0.1', 8080))
14
# （2）
15

16
while True:
17

18
    # 【3】.通信
19
    # send(二进制数据类型)
20
    msg = input('请输入需要发送的消息:>>>>').strip()
21

22
    phone.send(f'{msg}'.encode('utf8'))
23

24
    if len(msg) == 0: continue
25
    # 加入结束条件强制结束通信
26
    if msg == 'q':
27
        break
28

29
    # 接受服务端返回的数据
30
    data = phone.recv(1024)
31
    # 打印返回的消息 解码
32
    print(data.decode('utf8'))
33
    # （6）IS RUNNING FOR 发送信息
34

35
# 【4】.关闭连接(必选的回收资源操作)
36
phone.close()

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

8
# 【1】.买手机
9
# socket.SOCK_STREAM ：流式协议 ----> TCP协议 ----> 所有数据是一个整体
10
# socket.SOCK_DGRAM : 报协议  ----> 每一次数据都是单独一部分
11
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
12

13
# 【2】.绑定手机卡 ---> 192.168.1.50(本机IP地址)
14
# 0.0.0.0(任意IP地址) ---> 关联公网IP才会起作用  ----> 服务器用
15
# 127.0.0.1(本机固定IP地址) ---> 只有本机才能访问这个地址（测试用）
16
# 端口号：0-65535, 1024以前的都被系统保留使用
17
# phone.bind(('ip', port))
18
phone.bind(('127.0.0.1', 8080))
19

20
# 【3】.开机 -- 监听状态
21
# 5 ：指的是半连接池的大小
22
phone.listen(5)
23
print(f'服务器启动,开始监听ip:>>>{"127.0.0.1"},port:>>>{8080}')
24
# （1）服务器启动,开始监听ip:>>>127.0.0.1,port:>>>8080
25

26
# 【4】.等待电话链接请求:拿到电话链接 conn
27
# 返回的是双向通路 --- 操作系统维持链接
28
# conn ： 双向通路的链接
29
# client_addr ： 客户端的iP和端口
30
conn, client_addr = phone.accept()
31
print('这是服务端的conn:>>>', conn)
32
# （3）这是服务端的conn:>>> <socket.socket fd=352, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 8080), raddr=('127.0.0.1', 5249)>
33
print('这是服务端的client_addr:>>>', client_addr)
34
# （4）这是服务端的client_addr:>>> ('127.0.0.1', 5249)
35

36
while True:
37
    # 【5】.接收消息
38
    # 1024 ：最大接受的数据量为1024 bytes类型，收到的是bytes类型
39
    try:
40
        data = conn.recv(1024)
41

42
        if len(data) == 0:
43
            # 在 unix 系统里，一旦data收到的内容为空
44
            # 就意味着一种异常行为：客户端非法断开了链接
45
            break
46

47
        if data.decode('utf-8') == 'q':
48
            break
49

50
        # 对接受的二进制数据进行解码
51
        print('从客户端接受的数据:>>>>', data.decode('utf-8'))
52
        # （5）从客户端接受的数据:>>>> is running for 发送信息
53
        # 发消息 返回消息状态等信息
54
        conn.send(data.upper())
55
    except Exception as e:
56
        break
57

58
# 【6】.关闭连接(必选的回收资源操作) conn
59
# 完成后断开连接
60
conn.close()
61

62
# 【7】.关机(可选操作)
63
phone.close()

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

8
# 【1】.买手机
9
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
10

11
# 【2】.拨通服务端电话
12
# connect(('服务端ip', 服务端端口))
13
phone.connect(('127.0.0.1', 8080))
14
# （2）
15

16
while True:
17

18
    # 【3】.通信
19
    # send(二进制数据类型)
20
    msg = input('请输入需要发送的消息:>>>>').strip()
21

22
    phone.send(f'{msg}'.encode('utf8'))
23

24
    if len(msg) == 0: continue
25
    # 加入结束条件强制结束通信
26
    if msg == 'q':
27
        break
28

29
    # 接受服务端返回的数据
30
    data = phone.recv(1024)
31
    # 打印返回的消息 解码
32
    print(data.decode('utf8'))
33
    # （6）IS RUNNING FOR 发送信息
34

35
# 【4】.关闭连接(必选的回收资源操作)
36
phone.close()

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

8
# 【1】.买手机
9
# socket.SOCK_STREAM ：流式协议 ----> TCP协议 ----> 所有数据是一个整体
10
# socket.SOCK_DGRAM : 报协议  ----> 每一次数据都是单独一部分
11
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
12

13
# 【2】.绑定手机卡 ---> 192.168.1.50(本机IP地址)
14
# 0.0.0.0(任意IP地址) ---> 关联公网IP才会起作用  ----> 服务器用
15
# 127.0.0.1(本机固定IP地址) ---> 只有本机才能访问这个地址（测试用）
16
# 端口号：0-65535, 1024以前的都被系统保留使用
17
# phone.bind(('ip', port))
18
phone.bind(('127.0.0.1', 8080))
19

20
# 【3】.开机 -- 监听状态
21
# 5 ：指的是半连接池的大小
22
phone.listen(5)
23
print(f'服务器启动,开始监听ip:>>>{"127.0.0.1"},port:>>>{8080}')
24
# （1）服务器启动,开始监听ip:>>>127.0.0.1,port:>>>8080
25

26
# 【4】.等待电话链接请求:拿到电话链接 conn
27
#  ---- 加上链接循环 ----> 循环建链接
28
while True:
29
    # 返回的是双向通路 --- 操作系统维持链接
30
    # conn ： 双向通路的链接
31
    # client_addr ： 客户端的iP和端口
32
    conn, client_addr = phone.accept()
33
    # （3）这是服务端的conn:>>> <socket.socket fd=352, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 8080), raddr=('127.0.0.1', 5249)>
34
    print('这是服务端的client_addr:>>>', client_addr)
35
    # （4）这是服务端的client_addr:>>> ('127.0.0.1', 5249)
36

37
    while True:
38
        # 【5】.接收消息
39
        # 1024 ：最大接受的数据量为1024 bytes类型，收到的是bytes类型
40
        try:
41
            data = conn.recv(1024)
42

43
            if len(data) == 0:
44
                # 在 unix 系统里，一旦data收到的内容为空
45
                # 就意味着一种异常行为：客户端非法断开了链接
46
                break
47

48
            if data.decode('utf-8') == 'q':
49
                break
50

51
            # 对接受的二进制数据进行解码
52
            print('从客户端接受的数据:>>>>', data.decode('utf-8'))
53
            # （5）从客户端接受的数据:>>>> is running for 发送信息
54
            # 发消息 返回消息状态等信息
55
            conn.send(data.upper())
56
        except Exception as e:
57
            break
58

59
    # 【6】.关闭连接(必选的回收资源操作) conn
60
    # 完成后断开连接
61
    conn.close()
62

63
# 【7】.关机(可选操作)
64
phone.close()