Python 基础之网络 socket 使用 udp （SOCK_DGRAM）简单介绍、并实现简单的消息发送和接收

谁践踏了优雅 2022-10-28 15:28 636阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70][]

# Python 基础 之 网络 socket 使用 udp （SOCK\_DGRAM）实现简单的消息发送和接收 #

**目录**

Python 基础 之 网络 socket 使用 udp （SOCK\_DGRAM）实现简单的消息发送和接收

一、简单介绍

二、实现原理

三、注意事项

四、效果预览

五、实现步骤

socket udp 消息发送

socket udp 接收消息

六、关键代码

附录：NetAssist （网络调试助手）可以百度搜索下载即可

--------------------

## 一、简单介绍 ##

Python是一种跨平台的计算机程序设计语言。是一种面向对象的动态类型语言，最初被设计用于编写自动化脚本(shell)，随着版本的不断更新和语言新功能的添加，越多被用于独立的、大型项目的开发。Python是一种解释型脚本语言，可以应用于以下领域： Web 和 Internet开发、科学计算和统计、人工智能、教育、桌面界面开发、软件开发、后端开发、网络爬虫。

本节简单介绍，使用 python 进行网络通讯的的案例，socket udp 实现消息的发送和接收的简单使用。

UDP，用户数据报传输协议，它位于TCP/IP协议的传输层，是一种无连接的协议，它发送的报文不能确定是否完整地到达了另外一端。UDP广泛应用于需要相互传输数据的网络应用中，如QQ使用的就是UDP协议。在网络质量不好的情况下，使用UDP协议时丢包现象十分严重，但UDP占用资源少，处理速度快，UDP依然是传输数据时常用的协议。

> **udp 无链接**
> 
>  *  无链接，因而无需listen（backlog），更加没有什么连接池之说了
>  *  无链接，udp的sendinto不用管是否有一个正在运行的服务端，可以己端一个劲的发消息，只不过数据丢失
>  *  recvfrom收的数据小于sendinto发送的数据时，在mac和linux系统上数据直接丢失，在windows系统上发送的比接收的大直接报错
>  *  只有sendinto发送数据没有recvfrom收数据，数据丢失

**udp通信模型**

udp通信模型中，在通信开始之前，不需要建立相关的链接，只需要发送数据即可，类似于生活中，"写信""

[![ff70e4d6bed16eb6f0311ef89762e0a2.png][]][ff70e4d6bed16eb6f0311ef89762e0a2.png 1]

## 二、实现原理 ##

1、socket.socket(socket.AF\_INET, socket.SOCK\_DGRAM) 创建套接字

2、socket.sendto 和 socket.recvfrom 发送和接收消息

3、借助 NetAssist （网络调试助手）进行功能验证

## 三、注意事项 ##

1、如果 socket.bind 绑定ip和端口，会自动绑定本地ip和动态端口

2、注意发送带有中文等消息的时候，注意进行encode和decode

3、中文的注意区分 utf-8 还是 gbk （我这里使用的是 Windows 平台的 NetAssist ，使用gbk 编解码 ）

4、创建完 socket 最后记得关闭 socket.close

## 四、效果预览 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1][]

## 五、实现步骤 ##

###  socket udp 消息发送 ###

1、打开 pycharm 新建一个工程，即可新建一个python文件

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 2][]

2、打开 NetAssist （网络调试助手）开启 udp 服务，

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 3][]

3、编写脚本，实现使用 socket 数据报发送消息的功能（发送 ip 和 端口既是开启 udp 服务的 ip 端口）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 4][]

4、运行脚本，即可向 NetAssist  发送数据

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 5][]

### socket udp 接收消息 ###

1、打开 pycharm 新建一个工程，即可新建一个python文件

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 2][]

2、打开 NetAssist （网络调试助手）开启 udp 服务，

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 3][]

3、编写脚本，实现使用 socket 数据报接收消息的功能（绑定一个端口，便于接收 NetAssist 发过来的消息 ）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 6][]

4、运行脚本，即可接收 NetAssist 发过来的消息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1][]

## 六、关键代码 ##

1、UdpBaseUse\_Send\_01.py

import socket   # 引进 socket 包
    
    
    def udp_use_send(ip, port):
        """
        使用 udp 发送数据
        :param ip: 目标 ip
        :param port:目标 端口
        :return:
        """
    
        # 创建一个 udp 套接字
        udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
        # 绑定本地ip和自定义端口（如果没有这边，程序会自动动态绑定本地ip和动态端口）
        udp_socket.bind(("", 7878))
    
        while True:
            # 键盘输入数据
            msg = input("请输入数据……")
            # 发送数据到指定 ip
            # udp_socket.sendto(msg.encode('utf8'), (ip, port))
            # windows 系统使用 gbk
            udp_socket.sendto(msg.encode('gbk'), (ip, port))
    
            # 发送 bye 退出
            if msg == "bye":
                break
    
        # 关闭套接字
        udp_socket.close()
    
    
    def main():
        ip = "192.168.1.102"
        port = 8080
    
        udp_use_send(ip, port)
    
    
    if __name__ == "__main__":
        main()

2、UdpBaseUse\_Recieve\_02.py

import socket
    
    
    def udp_use_receive():
    
        # 创建套接字
        udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
        # 绑定一个本地 IP 和 指定端口号
        local_address = ("", 5566)
        udp_socket.bind(local_address)
    
        # 接收数据
        while True:
            recv_data = udp_socket.recvfrom(1024)
    
            # recv_data 这个变量中存储的是一个元组（接收到的数据，（发送数据端的ip,port））
            recv_msg = recv_data[0]     # 消息数据
            send_addr = recv_data[1]    # 发消息端的 ip + port
    
            # 打印数据
            print(recv_data)
    
            # 数据解码
            # recv_msg = recv_msg.decode("utf-8")
            # windows 端 数据解码 gbk
            recv_msg = recv_msg.decode("gbk")
    
            # 重新组合数据打印数据
            print("%s:%s" % (str(send_addr), recv_msg))
    
            # 数据是 bye 就退出
            if recv_msg == "bye":
                break
    
        # 关闭套接字
        udp_socket.close()
    
        pass
    
    
    def main():
        udp_use_receive()
    
    
    if __name__ == "__main__":
        main()

## 附录：NetAssist （网络调试助手）可以百度搜索下载即可 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 7][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 8][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70]: /images/20221024/c4c822cc3bae4f738325c3fadf1c7892.png
[ff70e4d6bed16eb6f0311ef89762e0a2.png]: /images/20221024/0f46ab0dbf324b228620851388194666.png
[ff70e4d6bed16eb6f0311ef89762e0a2.png 1]: https://img2018.cnblogs.com/blog/1156642/201812/1156642-20181208132247209-1884260035.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1]: /images/20221024/d8a6f3b1dbb64cff9b872e42a08d3cf1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 2]: /images/20221024/9a32f3f1cabf4fad950bf60444e2cc70.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 3]: /images/20221024/5814cb02422e4fa5979b8f8a1ea27eb6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 4]: /images/20221024/268c924f5b2341a5b9b0bb23b6033038.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 5]: /images/20221024/6a6b1a4fa7924c73bef58062196e0ef6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 6]: /images/20221024/b1e881873e5e476083ce6fc7584bfbce.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 7]: /images/20221024/6bf8555deb6e46258170d1a0995c4c76.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 8]: /images/20221024/6b834972967d4cb5baad5d66d0937ec0.png