1.socket编程

socket又叫套接字，就是进行数据通信两端。分为服务端套接字和客户端套接字。

python对socket编程的支持：socket库
1.服务端

import socket
def creat_server():
    '''
    服务器
    :return:
    '''
    #1.创建套接字对象
    server = socket.socket()
    '''
    family=AF_INET, type=SOCK_STREAM
    family:IP协议类型--------AF_INET：IPV4  ---------AF_INET6:IPV6
    type：传输协议类型。 -------SOCK_STREAM：TCP  -----SOCK_DGRAM：UDP
   
    '''
    #2.绑定IP地址和端口
    #bind((IP地址,端口))
    #端口:不同的端口号标记不同的服务(在同一个设备) 0 ~ 65535 （0 ~ 1024是著名端口）
    server.bind(('10.7.153.152',8080))

    #3.监听(监听客户端的请求)
    #listen(backlog)：最大连接数
    server.listen(5)

    #4.让服务器处于运行状态。
    while True:
        #5.连接客户端(建立连接),返回连接对象和客户地址
        #这句代码会阻塞线程，直到有客户端来请求当前服务器为止
        connect,addr = server.accept()
        print(connect,addr)

        #6.服务器给客户端发送消息
        '''
        send(data,flags)
        data:类型是bytes(python3,python2中可以是字符串)
        
        字符串(str)转二进制(bytes):
        1.字符串.encode(编码方式)----->默认utf-8
        2.bytest(字符串,编码方式)
        '''
        connect.send()

        #7.接受从客户端传来的消息
        '''
        recv(bufsize)
        bufsize:每次能够接受的最大的字节数
        返回值:接受到的数据(bytes)
         recv也会阻塞线程
        
        二进制转字符串
        1.二进制.decode()
        2.str(二进制,编码方式)
        '''
        recv_data = connect.recv(1024)
        print(recv_data.decode())

        #8.断开连接
        connect.close()

creat_server()

2.客户端

import socket
def create_client():
    #1.创建套接字对象
    client = socket.socket()

    #2.连接服务器
    '''
    connect(服务器地址)
    '''
    client.connect(('10.7.153.152',8080))

    #3.接收服务器发送的消息
    recv_data = client.recv(1024)
    print(recv_data.decode())

    #4.给服务器发送消息
    client.send('哈哈哈'.encode())

    #5.断开连接
    client.close()

create_client()

3.Http请求

 # 1.准备url
    url = 'https://www.apiopen.top/satinApi?type=1&page=1'

    # 2.发送请求(GET请求)
    """
    get(url,参数对应的字典)
    post(url,参数对应的字典)
    返回值是服务器返回的响应
    """
    response = requests.get(url)
    # requests.get('https://www.apiopen.top/satinApi',{'type':1, 'page':1})
    print(response)

    # 3.通过响应获取服务器返回的数据
    # a.获取字符串类型的数据
    print(response.text)

    # b.获取json格式的数据
    print(response.json())
    print(response.json()['msg'])

    # c.获取二进制格式的数据
    print(response.content)

    # 4.获取响应头(了解)
    print(response.headers)

作业

1. 客户端和服务器聊天，可以一直聊天，直到一方发送’拜拜’。然后就可以和下一个人一直聊

1.server
import socket

def test_server():

    server  = socket.socket()
    server.bind(('10.7.153.152',6789))
    server.listen(10)

    while True:
        connect,addr = server.accept()
        while True:
            data = connect.recv(1024)

            if data.decode() == '拜拜':
                print('该客户端断开，重新开始监听')
                break
            else:
                print(data.decode())

            message = input('服务器:')
            connect.send(message.encode('utf-8'))


if __name__ == '__main__':
    test_server()
'''
你好
服务器:你也好
11
服务器:22
33
服务器:44
该客户端断开，重新开始监听
'''

2.client
import socket
def client():
    try:
        client = socket.socket()
        client.connect(('10.7.153.152',6789))

        while True:
            message = input("客户端:")
            client.send(message.encode('utf-8'))
            if message == '拜拜':
                print('通话结束')
                return 0

            data = client.recv(1024)
            if data.decode() == '拜拜':
                print('服务器断开,通讯结束')
                return 0
            else:
                print(data.decode())
    except ConnectionResetError:
        print('服务端已异常，通话结束')



if __name__ == '__main__':
    client()
'''
客户端:你好
你也好
客户端:11
22
客户端:33
44
客户端:拜拜
通话结束

'''

2. 下载网络图片
   https://ss1.bdstatic.com/70cFuXSh_Q1YnxGkpoWK1HF6hhy/it/u=2808438283,4249462766&fm=26&gp=0.jpg）到本地

def get_one_picture(url):
    response = requests.get(url)
    if response.status_code == 200:
        with open('./image/123.png','wb') as f:
            f.write(response.content)
    else:
        print('连接超时')


url = r'https://ss1.bdstatic.com/70cFuXSh_Q1YnxGkpoWK1HF6hhy/it/u=2808438283,4249462766&fm=26&gp=0.jpg'
get_one_picture(url)