tcp通信程序发送图片_三十七、深入Python中的网络通信

「&＃64;Author&＃xff1a;Runsen」

计算机与网络设备两情侣要谈恋爱&＃xff0c;相互通信&＃xff0c;那么双方就必须有规则。基于相同的方法&＃xff0c;不同的硬件、操作系统之间的通信&＃xff0c;都需要一种规则。而我们就把这种规则称为协议(protocol)。

TCP/IP 是互联网相关各类协议族的总称。TCP/IP是指TCP和IP这两种协议。TCP/IP是在IP协议的通信过程中&＃xff0c;使用到的协议族的统称。

TCP/IP协议族按层次分别为 应用层&＃xff0c;传输层&＃xff0c;网络层&＃xff0c;数据链路层&＃xff0c;物理层。可以按照不同的模型分4层或者是7层。

将TCP/IP分为5层&＃xff0c;越靠下越接近硬件。

应用层&＃xff1a;应用程序收到传输层的数据后&＃xff0c;接下来就是要进行解读&＃xff0c;解读必须要先规定好格式&＃xff0c;而应用层就是规定应用程序的数据格式&＃xff0c;主要协议有HTTP等。

传输层&＃xff1a;该层为两台主机上的应用程序提供端到端的通信&＃xff0c;传输层有两个传输协议为TCP(传输控制协议)和UDP(用户数据报协议)&＃xff0c;TCP是一个可靠的面向连接的协议&＃xff0c;UDP是不可靠或者说无连接的协议。

网络层&＃xff1a;决定如何将数据从发送方到接收方&＃xff0c;是建立主机到主机的通信。

数据链路层&＃xff1a;控制网络层与物理层之间的通信&＃xff0c;主要功能是保证物理线路上进行可靠的数据传递。

物理层&＃xff1a;该层负责物理传输&＃xff0c;与链路有关&＃xff0c;也与传输的介质有关。

客户端和服务器具体的

图片出自《图解HTTP》书籍

TCP三次握手&＃xff0c;四次挥手&＃xff0c;Runsen也不会怎么说&＃xff0c;就把网上最通俗的图放在下面 了&＃xff0c;还是别看我很牛逼&＃xff0c;牛逼的是做图的大佬。

三次握手

四次挥手

图片出自公众号(程序员小小溪)&＃xff0c;更多的名词和概念查找参考公众号程序员小小溪的文章~^[1]

网络编程有一个重要的概念 socket(套接字)&＃xff0c;应用程序可以通过它发送或接收数据&＃xff0c;套接字允许应用程序将 I/O 插入到网络中&＃xff0c;并与网络中的其他应用程序进行通信。

我是来偷窥Python中的网络通信Socket&＃xff0c;不小心偷窥到了一个非常不错的Socket好图

将上面的图片整理步骤

1.建立连接&＃xff1a;

• 服务器&＃xff1a;socket--->address--->bind--->listen--->accept

• 客户端&＃xff1a;socket--->connect

2.通信&＃xff1a;收一发&＃xff1a;recv(1024)

3.关闭连接&＃xff1a;close()

实现简单的通讯程序

服务端&＃xff0c;server.py

#导入socket模块
import socket
#创建套接字 或使用server &＃61; socket.socket()
server &＃61; socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#定义绑定的ip和端口&＃xff0c;用元组定义
ip_port &＃61; (&＃39;127.0.0.1&＃39;, 8888)
#绑定监听:bind(address),在AF_INET下,以元组(ip,port)的形式表示地址
server.bind(ip_port)
#设置最大连接数&＃xff0c;默认为1
server.listen(5)
#不断接受连接&＃xff1a;one by one
while True:
    print("等待数据连接中……")
    #接受客服端数据请求
    conn, address &＃61; server.accept()
    &＃39;&＃39;&＃39;
    向客服端返回信息
    (注意&＃xff1a;python3.x以上&＃xff0c;网络数据的发送接收都是byte类型&＃xff0c;
    发送接收String类型数据时需要对数据进行编码(发送&＃xff1a;messages.enconde()&＃xff1b;接收后转为String类型:messages.deconde())&＃xff0c;pyhon2.x则直接发送数据无须编码)
    &＃39;&＃39;&＃39;
    messages &＃61; "连接成功&＃xff01;"
    conn.send(messages.encode())
    #计数信息条数
    count &＃61; 0
    #一个连接中&＃xff0c;不断的接受客户端发来的数据
    while True:
        data &＃61; conn.recv(1024)
        #打印客户端发来的数据信息
        print(data.decode())
        #判断是否退出当前连接,等在下一个连接
        if data &＃61;&＃61; b&＃39;exit&＃39;:
          break
        #处理客户端数据(如&＃xff1a;响应请求等)
        count &＃61; count &＃43; 1
        string &＃61; "第" &＃43; str(count) &＃43; "条信息&＃xff1a;" &＃43; data.decode()
        conn.send(string.encode())
        #主动关闭连接
    conn.close()


客户端&＃xff0c;client.py

import socket

#创建套接字
client &＃61; socket.socket()
#访问的服务器的ip和端口&＃xff0c;用元组定义
ip_port &＃61; ("127.0.0.1", 8888)
#连接服务器主机
client.connect(ip_port)
#同一链接中&＃xff0c;不断向服务器发生数据或请求
while True:
    #接收服务器发送或响应的数据
    data &＃61; client.recv(1024)
    #打印接收的数据&＃xff1b;python3.x以上数据要编码(发送&＃xff1a;data.enconde()&＃xff1b;接收后转为String类型:data.deconde())
    print(data.decode())
    messages &＃61; input("请输入发生或请求的数据(exit退出)&＃xff1a;")
    client.send(messages.encode())
    if messages &＃61;&＃61; &＃39;exit&＃39;:
        break
    &＃39;&＃39;&＃39;
    #接收服务器发送或响应的数据
    data &＃61; client.recv(1024)
    #打印接收的数据&＃xff1b;python3.x以上数据要编码&＃xff0c;发送enconde()&＃xff1b;接收deconde()
    print(data.decode())
    &＃39;&＃39;&＃39;
#关闭连接
client.close()


具体效果如下图所示。

多线程通信

TCP服务器与多个TCP客户端同时进行连续通信&＃xff0c;只需要通过threading创建多线程任务handle_client就可以了。

import socket
import threading
import random


def handle_client():
    # 接受客户端请求链接
    client, address &＃61; server.accept()
    print("[*] Accept connection from: %s:%d" % (address[0], address[1]))
    messages &＃61; "Hello World!"
    client.send(messages.encode())
    # 连续与当前连接的客户端通信
    while True:
        # 接受客户端数据
        request &＃61; (client.recv(1024)).decode()
        # 判断是否结束通信
        if request &＃61;&＃61; &＃39;exit&＃39;:
            break
        print("[*] Received from %s:%d : %s" % (address[0], address[1], request))
        # 发送响应信息给客户端
        client.send((str(random.randint(1, 1000)) &＃43; "&＃xff1a;" &＃43; "ACK!").encode())
    # 关闭当前连接
    client.close()


if __name__ &＃61;&＃61; "__main__":
    # 创建套接字
    server &＃61; socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 定义绑定ip和端口
    ip &＃61; &＃39;127.0.0.1&＃39;
    port &＃61; 8888
    # 绑定监听
    server.bind((ip, port))
    # 设置最大连接数&＃xff0c;默认为1
    server.listen(5)
    print("[*] Listening on %s:%d" % (ip, port))
    # 循环开启线程&＃xff0c;接受多个客户端的链接通信
    while True:
        # 创建一个线程
        client_handler &＃61; threading.Thread(target&＃61;handle_client)
        # 开启线程
        client_handler.start()



python3.x以上&＃xff0c;网络数据messages的发送接收都是byte类型&＃xff0c;若要发送接收String类型数据时需要通过messages.enconde()对数据进行编码&＃xff0c;接收后通过messages.deconde()转为String类型。pyhon2.x则直接发送数据无须编码。

❝

本文已收录 GitHub&＃xff0c;传送门~^[2] &＃xff0c;里面更有大厂面试完整考点&＃xff0c;欢迎 Star。

❞

Reference

参考公众号程序员小小溪的文章: https://mp.weixin.qq.com/s/KK1dnNoHrbjMyuhQptaBAQ

传送门~: https://github.com/MaoliRUNsen/runsenlearnpy100

更多的文章

点击下面小程序

- END -