day18-套接字

一.套接字server

import socket

# 1.什么是socket编程
"""
socket又叫套接字, 指的是实现通信的两个端；这个两个端又分为服务器套接字和客户端套接字
"""
# 2.服务器套接字
"""
python中提供了一个socket模块来支持socket编程
"""
# 1) 创建套接字对象
"""
socket(family=AF_INET, type=SOCK_STREAM)

family - 设置ip类型; AF_INET - ipv4, AF_INET6 - ipv6
type - 设置数据的传输方式; SOCK_STREAM - TCP, SOCK_DGRAM - UDP
"""
server = socket.socket()


# 2) 绑定ip和端口
"""
bind((ip地址, 端口号))

ip地址 - 字符串; 服务器程序运行在哪台计算机上,ip地址就写哪台计算机的ip
端口号 - 整型；范围是0~65535，其中0~1024是著名端口，有自己特殊的意义一般不随便用。
"""
server.bind(('10.7.181.109', 8882))

# 3) 等待连接并且设置同一时间能够接收的请求数量
server.listen(512)


# 4) 让服务器保持一致运行的状态
while True:
    print('开始监听')
    # 5) 接收请求(接电话)
    # 注意: 当程序执行到accept()的时候，会停下来直到有客户端给当前服务器发送请求为止
    connect, address = server.accept()
    print('接收到请求')
    print(connect, address)

    # 保持通话
    while True:
        # 6) 接收客户端发送的数据
        """
        recv(数据大小)  -  接收数据并且设置一次性能够接收最大数据
        
        补充: 二进制转字符串
        二进制对象.decode(encoding='utf-8')
        str(二进制对象, encoding='utf-8')
        """
        recv_data = connect.recv(1024)
        # print('接收:', recv_data.decode(encoding='utf-8'))
        print('接收:', str(recv_data, encoding='utf-8'))

        # 7) 给客户端发送数据(说话别人听)
        """
        send(数据)   -  发送数据，数据的类型必须是bytes
        """
        # 发送一个网页数据
        # with open('test.html', encoding='utf-8') as f:
        #     #     html = f.read()
        #     # message = 'HTTP/1.1 200 OK\r\n\r\n'+html
        #     # connect.send(message.encode())

        send_message = input('服务器:')
        connect.send(send_message.encode())

    # 8) 关闭连接
    connect.close()

二.套接字client

import socket
# 1.创建套接字对象
client = socket.socket()
# 2.发送请求
"""
connect((ip地址, 端口号))
"""
client.connect(('10.7.181.109', 8882))

while True:

    # 3.发送消息
    send_message = input('客户端:')
    client.send(send_message.encode())

    # 4.接收消息
    re_data = client.recv(1024)
    print(re_data.decode(encoding='utf-8'))

client.close()

三.图片server

server = socket()
server.bind(('10.7.181.109', 12346))
server.listen(512)

# 让程序一直运行
while True:
    print('开始监听....')
    connect, address = server.accept()
    print(address)

    # 发送图片
    with open('files/luffy.jpg', 'rb') as f:
        connect.send(f.read())

    connect.close()

四.图片client

from socket import *

client = socket()
client.connect(('10.7.181.109', 12347))

# 图片输入较大数据，在TCP传输协议中会分段发送
while True:
    re_data = client.recv(1024)
    with open('files/new.jpg', 'ab') as f:
        f.write(re_data)

    if(len(re_data) < 1024):
        break