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及端口号，然后互发消息，运行结果如下：
