Python 基础之网络 socket 使用 udp （SOCK_DGRAM）结合线程 Thread 实现简单的实时聊天功能

迷南。 2022-10-29 03:14 154阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70][]

# Python 基础 之 网络 socket 使用 udp （SOCK\_DGRAM）结合 线程 Thread 实现简单的实时聊天功能 #

**目录**

Python 基础 之 网络 socket 使用 udp （SOCK\_DGRAM）结合 线程 Thread 实现简单的实时聊天功能

一、简单介绍

二、实现原理

三、注意事项

四、效果预览

五、实现步骤

六、关键代码

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

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

## 一、简单介绍 ##

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

本节简单介绍，使用 python 进行网络通讯的的案例，socket udp 结合 Thread 多任务的特点，实现简单的聊天功能。

## 二、实现原理 ##

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

2、socket.sendto 、socket.recvfrom  结合 Thread 开启子线程实现不阻塞的，发送和接收消息

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][]

## 五、实现步骤 ##

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 数据报 和 Thread 多线程发送消息的功能（发送 ip 和 端口既是开启 udp 服务的 ip 端口）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 4][]

4、运行脚本，即可向 NetAssist  发送数据，同时也可接受 NetAssist  的消息，实现实时发送接受消息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1][]

## 六、关键代码 ##

import socket
    import threading
    
    
    def recv_msg(udp_socket):
        while True:
            # 接收数据
            recv_data = udp_socket.recvfrom(1024)
            # print("%s : %s" % (str(recv_data[1]), recv_data[0].decode('utf-8')))
            print("\n %s : %s \n请输入聊天内容：" % (str(recv_data[1]), recv_data[0].decode('gbk')))
    
    
    def send_msg(udp_socket, dest_ip, dest_port):
        while True:
            # 发送消息
            send_data = input("请输入聊天内容：")
            # udp_socket.sendto(send_data.encode('utf-8'), (dest_ip, dest_port))
            udp_socket.sendto(send_data.encode('gbk'), (dest_ip, dest_port))
    
    
    def udp_chat():
    
        # 创建套接字
        udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
        # 绑定本地 ip 和 port
        udp_socket.bind(("", 7788))
    
        # 输入聊天的对方 ip 和 port
        dest_ip = input("请输入对方的 IP：")
        dest_port = int(input("请输入对方的 Port："))
    
        # 创建线程去接受和发送消息
        thread_recv = threading.Thread(target=recv_msg, args=(udp_socket,))
        thread_send = threading.Thread(target=send_msg, args=(udp_socket, dest_ip, dest_port))
    
        # start 线程
        thread_recv.start()
        thread_send.start()
    
        pass
    
        # 关闭套接字
        # udp_socket.close()
    
    def main():
        udp_chat()
        pass
    
    
    if __name__ == '__main__':
        main()

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

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 6][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70]: /images/20221024/66e9c6266e254e57a613ac272d29bb66.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1]: /images/20221024/6f7a68f274be4590b7c701a87c8a142e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 2]: /images/20221024/b3036f1268b242628db0f5f440e5ed9a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 3]: /images/20221024/ea3cc32bb1104e01abd3ea416a26b8be.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 4]: /images/20221024/328a870e7e57449e999e36a63b69d90c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 5]: /images/20221024/ec7c6ea0aeab4ebca9293a6b149d71e3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 6]: /images/20221024/7efb3c793c484f769e4ca77f0d431692.png