一、socket服务器

socket又叫套接字，实现网络通信的两端就是套接字。分为服务器对应的套接字和客户端对应的套接字。

python通过提供socket标准库来支持socket编程。

socket编程就是用程序实现服务器和客户端。

1.创建服务器对应的套接字对象

socket(family, type)
family:设置ip类型 AF_INET(ipv4) -> 默认值 AF_INET6(ipv6)
type:设置传输类型 SOCK_STREAM(TCP可靠传输) --> 默认值 SOCK_DGRAM(UDP不可靠传输)

server = socket.socket() # 创建一个基于ipv4的可靠传输的服务器套接字

---

2.绑定IP和端口

bind((ip, 端口))
ip:服务器的地址
端口：不同的端口用来区分电脑上不同的服务。取值范围是0_{65535，注意0}1024属于著名端口(用来绑定特殊服务端口，不要随便使用)

注意：同一时间同一个端口只能绑定一个服务。

server.bind(('10.7.156.121', 8080))

---

3.监听请求

listen(个数) --> 需要通过数字设置服务器一次可以处理最大的请求个数
server.listen(500)

4.让服务器一直处于启动状态

while True:

服务器需要做的操作

5.接收客户端的请求

accept()，程序会停下来，直到有客户端在请求这个服务器的时候才会往下执行。返回会话和客户端的地址。

conversation, addr = server.accept()

---

6.服务器给客户端发送数据

send(Data) --> 发送数据
data：需要发送的数据，要求是二进制数据(Bytes)

a.str 转 bytes：
bytes(字符串, encoding='utf-8')
字符串.encode(编码方式)

conversation.send(content)

---

7.接收客户端发送的消息

recv(字节数) --> 接收从客户端发送的数据，参数是用来设置一次能接收的最大字节数。返回值是接收到的数据(二进制)

bytes 转 str:
str(二进制，encoding='utf-8')
二进制.decode（编码方式）

注意：recv方法也会阻塞线程，程序运行到这儿会停下等，等到对方发送消息为止。

代码

import socket

server = socket.socket()  # 创建一个基于ipv4的可靠传输的服务器套接字

server.bind(('10.7.156.121', 8080))

server.listen(500)
print('开始监听')

while True:
    # 5.接收客户端的请求

    conversation, addr = server.accept()
    print(addr)

    # 6.服务器给客户端发送数据

message = '你好吗？'
# message_data = message.encode(encoding='utf-8')
message_data = bytes(message, encoding='utf-8')
conversation.send(message_data)

    # with open('./files/luffy.png', 'br')as f:
        # content = f.read()
        # conversation.send(content)
        # 关闭连接
        # conversation.close()

    # 7.接收客户端发送的消息
  
    print('准备接收消息')
    data = conversation.recv(1024)
    re_message = str(data, encoding='utf-8')
    # re_message = data.decode(encoding='utf-8')
    print(re_message)

测试结果

1.PNG

---

二、socket客户端

1.创建客户端套接字对象

client = socket.socket()

---

2.链接服务器

connect(地址)

client.connect(('10.7.156.121', 8080))

---

3.给服务器发送消息

client.send(message.encode('utf-8'))

---

4.接收服务器返回的数据

re_data = client.recv(1024)

---

代码

import socket

# 1.创建客户端套接字对象
client = socket.socket()

# 2.链接服务器
"""
connect(地址)
"""
client.connect(('10.7.156.121', 8080))

while True:
    # 3.给服务器发送消息
    message = input('客户端：')
    client.send(message.encode('utf-8'))
    if message == '拜拜':
        break

    # 4.接收服务器返回的数据
    re_data = client.recv(1024)
    print('服务器：', re_data.decode('utf-8'))
    if re_data.decode('utf-8') == '拜拜':
        break

测试结果

2.PNG

---

三、socket服务器升级

代码

import socket

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

# 2.绑定地址
server.bind(('10.7.156.121', 8081))

# 3.监听
server.listen(512)

# 让服务器一直处于运行状态
while True:
    # 4.接收请求
    conversation, addr = server.accept()

    # 保持通话
    while True:
        # 接收消息
        message_re = conversation.recv(1024).decode('utf-8')
        print('客户端(%s)：%s' %(addr[0][-2:], message_re))
        if message_re == '拜拜':
            break

        # 发送消息
        message = input('服务器：')
        conversation.send(message.encode('utf-8'))
        if message == '拜拜':
            break

测试结果

3.PNG

---

四、接收图片客户端

代码

import socket

client = socket.socket()

client.connect(('10.7.156.97', 8082))

message_re = client.recv(1024)
data = bytes()  # 创建一个空的二进制数据
while message_re:
    print('接收到数据')
    data += message_re  # 将每次获取到的数据叠加
    message_re = client.recv(1024)

with open('./new.jpg','bw')as f:
    f.write(data)

print('接收完成')

测试结果

4.PNG
4.2.PNG

---

五、request请求

python没有一个标准库来支持网络请求，但是目前有一个第三方库，支持http请求。

requests.get(url, params) --> 返回服务器的响应
url -> 请求地址
params -> 客户端给服务器发送的数据(字典) {参数名:值}

1.获取响应头

esponse.headers

---

2.拿二进制形式的响应体

response.content

---

3.拿字符串形式的响应体

response.text

---

4.拿json格式对应的python数据

response.json()

代码

import requests

# https://www.apiopen.top/satinApi?type=1&page=1
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
response = requests.get(url)
# 1.获取响应头
print(response.headers)

# 2.拿二进制形式的响应体
data_bytes = response.content
print(type(data_bytes), data_bytes)

# 3.拿字符串形式的响应体
data_text = response.text
print(type(data_text), data_text)

# 4.拿json格式对应的python数据
data_json = response.json()
print(type(data_json), data_json)

response = requests.get('http://wimg.spriteapp.cn/profile/large/2018/02/24/5a90448611639_mini.jpg')
content = response.content
with open('./aa.jpg', 'wb')as f:
    f.write(content)

测试结果

1.PNG

---

六、作业

写一个客户端和服务器的套接字：
客户端连接服务器后展示界面：

===========================

1. 需要图片
2. 需要文字
3. 通知结束
   ==========================
   请选择：

如果客户端选1，服务器给客户端发送一张图片，客户端保存图片到本地
如果客户端选2, 服务器输入一段文字发送给客户端， 客户端将文字保存在一个message.txt文件中
如果客户端选3，通知服务器关闭连接，并且客户端结束

代码

#服务器端代码
import socket

server = socket.socket()

server.bind(('10.7.156.121', 8080))

server.listen(500)

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

    while True:
        message = '\n===========================\n1. 需要图片\n2. 需要文字\n3. 通知结束\n==========================\n 请选择：'
        message_bytes = message.encode('utf-8')
        conversation.send(message_bytes)

        value_bytes = conversation.recv(1024)
        value = value_bytes.decode('utf-8')

        if value == '1':
            with open('./new.jpg', 'rb')as f:
                image = f.read()
                conversation.send(image)
                conversation.close()
                print('图片发送成功！')
                break
        elif value =='2':
            input_message = input('请输入一段文字：')
            input_message_bytes = input_message.encode('utf-8')
            conversation.send(input_message_bytes)
            print('文字发送成功！')
        elif value == '3':
            conversation.close()
            break


#客户端代码
import socket

client = socket.socket()

client.connect(('10.7.156.121', 8080))

while True:
        message_bytes = client.recv(1024)
        message = message_bytes.decode('utf-8')
        print(message)

        value = input()
        if value == '1':
            data = bytes()
            value_bytes = value.encode('utf-8')
            client.send(value_bytes)
            image = client.recv(1024)
            while image:
                data += image
                image = client.recv(1024)
            with open('./files/tupian.jpg', 'wb')as f:
                f.write(data)
                client.close()
                print('图片保存成功！')
                client = socket.socket()
                client.connect(('10.7.156.121', 8080))
        elif value == '2':
            value_bytes = value.encode('utf-8')
            client.send(value_bytes)
            message_bytes = client.recv(1024)
            message = message_bytes.decode('utf-8')
            with open('./files/message.txt', 'w', encoding='utf-8')as f:
                f.write(message)
                print('文字保存成功！')
        elif value == '3':
            value_bytes = value.encode('utf-8')
            client.send(value_bytes)
            break

测试结果

1.PNG

---

请求接口：https://www.apiopen.top/satinApi?type=1&page=1 获取网络数据。
将内容中所有的name和text对应的值取出，并且保存到一个json文件中，保存的格式：

[{“name”:”张三”, “text”:”哈哈，让我们一起自由的飞翔”}, {“name”:”喒你家玻璃”, “text”:”截图暂停，截到的将会是对你爱情的预言三词！”}]

代码

import requests

import json
url = 'https://www.apiopen.top/satinApi?type=1&page=1'

response = requests.get(url)

contents = response.json()

list1 = []
for dict1 in contents['data']:
    dictionary = {}
    dictionary['name'] = dict1['name']
    dictionary['text'] = dict1['text']
    list1.append(dictionary)
list1 = str(list1)

with open('./files/data.json', 'w', encoding='utf-8')as f:
    json.dump(list1, f)

with open('./files/data.json', 'r', encoding='utf-8')as f:
    print(json.load(f))

测试结果

2.PNG

---