套接字

socket编程：指的就是通过代码来创建实现通信的两个端(服务器和客户端)

socket一般可以基于TCP和UDP实现客户端和服务器之间的可靠传输和不可靠传输

通过socket实现服务器端

1. 创建服务器套接字对象
   server = socket.socket()

family：确定服务类型
AF_INET --> ipv4
AF_INET6 --> ipv6

type：确定传输协议类型
SOCK_STREAM -> TCP协议
SOCK_DGRAM -> UDP协议

2.绑定ip地址
server.bind(('10.7.181.117', 8081))

地址格式:(ip地址字符串, 端口号)

端口号是用来区分一个计算机中不同的服务,范围是0-65535；
注意：1.其中0-1024是'著名端口'用来绑定一些特殊的服务的，一般不使用。
2.同一时间一个端口只能绑定一个服务

3.监听
server.listen(50)

参数：用来限制一次性能够接受的客服端请求数量

保证服务器处于一直启动的状态
while循环

4.接收客户端请求
client, addr = server.accept()

accept()会阻塞线程，当有有客户端给这个服务器发送请求，才会开始执行

5.给客户端发送消息
client.send(bytes('hello', encoding='utf-8'))
client.send('python'.encode())

send(数据)：数据必须是二进制数据(bytes)类型

字符串转二进制：
client.send(bytes('hello', encoding='utf-8'))
client.send('python'.encode())

bytes(字符串,encoding=编码方式)
字符串.encode(encoding=编码方式)

接收从客户端发来的消息

bufsize：设置缓存大小（单位是字节）
1024字节 -> 1k
1024k -> 1M
1024M -> 1G
1024G -> 1T
1024T - 1P

二进制(bytes)转换字符串：
data = client.recv(1024)
str1 = str(data, encoding='utf-8')
str2 = data.decode(encoding='utf-8

a. str(二进制数据, encoding='utf-8')
b. 二进制数据.decode(encoding='utf-8')

6.关闭连接
client.close()

客户端连接服务器
1.创建套接字对象

client = socket.socket()

2.连接服务器

client.connect(('10.7.181.117', 8081))

3.接收信息

data = client.recv(1024)
print('接收到服务器的数据:', data.decode(encoding='utf-8'))

4.发送信息

str1 = input('>>>')
client.send(str1.encode(encoding='utf-8'))
client.close()

两个服务器和客户端持续发送消息

server.py

import socket

if __name__ == '__main__':
    # 1.创建对象
    server = socket.socket()

    # 2.绑定地址
    server.bind(('10.7.181.117', 12345))

    # 3.监听
    server.listen(50)

    # 保持服务器不关闭
    while True:
        conversation, addr = server.accept()
        print(addr)

        # 让客户端和服务器一直处于连接的状态
        while True:
            # 发送消息
            message = input('>>>')
            conversation.send(message.encode())

            # 接收消息
            message_data = conversation.recv(1024)
            print(message_data.decode(encoding='utf-8'))

client.py

import socket
if __name__ == '__main__':
    # 1.创建套接字对象
    client = socket.socket()

    # 2.连接服务器
    client.connect(('10.7.181.117', 12345))

    while True:
        # 接收消息
        data = client.recv(1024)
        print(data.decode(encoding='utf-8'))

        # 发送消息
        message = input('>>>')
        client.send(message.encode())

imageSever.py

import socket

if __name__ == '__main__':
    server = socket.socket()
    server.bind(('10.7.181.84', 8081))
    server.listen(10)

    while True:
        conversation, addr = server.accept()
        print(addr)

        # 发送一张图片
        with open('./ddd.png', 'rb') as f:
            data = f.read()
        conversation.send(data)


        conversation.close()

imageClient.py

import socket

if __name__ == '__main__':
    client = socket.socket()
    client.connect(('10.7.181.84', 8081))

    # 接收数据，因为图片数据较大，可能会分多次发送
    image_data = bytes()  # 创建一个空的bytes用来保存整个图片数据
    data = client.recv(1024)
    while data:
        image_data += data
        data = client.recv(1024)

    # 保存图片到本地
    with open('./image.png', 'wb') as f:
        f.write(image_data)

    client.close()