美文网首页
day19-网络通信

day19-网络通信

作者: xdxh | 来源:发表于2018-10-24 21:34 被阅读0次

    一、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:服务器的地址
    端口：不同的端口用来区分电脑上不同的服务。取值范围是065535，注意01024属于著名端口(用来绑定特殊服务端口，不要随便使用)

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

    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

    相关文章

      网友评论

          本文标题：day19-网络通信

          本文链接：https://www.haomeiwen.com/subject/qbqxtqtx.html

          延伸阅读

          深度阅读

          • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

          栏目导航

          热点阅读

          关于我们|服务条款|联系我们|day19-网络通信|投稿指南|网站地图|RSS订阅|排版工具|手机版

          提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

          Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

          备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

          本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

          所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！