Python——用socket和线程实现

用socket和线程实现全双工收发数据

---

 

1.基础知识

 

Socket（套接字）	网络上的两个程序通过一个双向的通信连接实现数据的交换，这个连接的一端称为一个socket。由此知道套接字是全双工的。
线程（thread）	线程是操作系统能够进行运算调度的最小单位。它被包含在进程之中，是进程中的实际运作单位。一条线程指的是进程中一个单一顺序的控制流，一个进程中可以并发多个线程，每条线程并行执行不同的任务。

  

• 什么是单工，全双工，半双工？

全双工：是指在发送数据的同时也能够接收数据，两者同步进行，这好像我们平时打电话一样，说话的同时也能够听到对方的声音。

半双工：在一段时间内，只有一种动作发生，例如一条窄路，而只有一辆车可以通行，当有两辆车相对通行时，只有一辆车先通过，另一头的那辆车的才能通过。随着技术的不断进步，半双工将会退出历史舞台，例子：对讲机。

单工：全双工和半双工都是双向通信，而单工是单向通信，在同一时间只有一方能接受或发送信息，例子：电视，广播。

全双工	双向	可同时发送接受数据	电话通信
半双工	双向	不可同时发送接受数据	对讲机
单工	单向	不可同时发送接受数据	电视，广播

 

---

 

2.代码

import socket
import threading


def send_msg(udp_socket, dest_ip, dest_port):
    """发送消息"""
    # 获取要发送的内容
    while True:
        send_data = input("请输入要发送的消息：")
        udp_socket.sendto(send_data.encode("gbk"), (dest_ip, dest_port))


def recv_msg(udp_socket,):
    """接收数据"""
    while True:
        recv_data = udp_socket.recvfrom(1024)
        print("\n收到了消息%s:%s" % (str(recv_data[1]), recv_data[0].decode("gbk")))


def main():
    # 1.创建套接字，AF_INET表示面向网络的，UDP的套接字名字是SOCK_DGRAM
    udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

    # 2.绑定本机ip和端口:第一个参数为空则默认绑定本机ip，第二个参数填写端口号
    udp_socket.bind(("", 7788))

    # 3.指定对方ip
    dest_ip = input("请输入对方的ip:")
    dest_port = int(input("请输入对方的port:"))

    # 4.创建线程并运行：args需要一个元组参数
    ts = threading.Thread(target=send_msg, args=(udp_socket, dest_ip, dest_port))
    tr = threading.Thread(target=recv_msg, args=(udp_socket,))
    ts.start()
    tr.start()


if __name__ == "__main__":
    main()

 

---

 

3.运行

运行前准备工作，准备两台电脑，一台运行程序（以下称A电脑），另一台（以下称B）用mNetAssist（网络调式助手，下载链接: https://pan.baidu.com/s/1Sq1SvqJnxbijrx4kSYbc1g 提取码: 1f8b）测试程序。Windows下打开cmd用ipcongfig查询ip（linux下用ifconfig查询），查询结果如下：A电脑ip为172.16.86.21，B电脑的ip为172.17.189.148。然后将B电脑的mNetAssist设置配置如下

接下来运行程序，输入B电脑的IP及端口号，然后互发消息，运行结果如下：