|
#coding=utf-8
#引入socket模块
import socket
def udpSend():
#创建套接字
udp_socket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
#绑定端口，发送数据时会从绑定的端口发送，不会再生成随机端口
udp_socket.bind(("",8001))
#使用套接字进行数据传输
# while True:
send_data=input(“请输入传输的数据”)
#(内容，地址>元组）
udp_socket.sendto(send_data.encode(“utf-8”),(“ip”,8000))
#关闭套接字
udp_socket.close()
def udpRecv():
# 创建套接字
udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 使用套接字进行数据接收
# 必须有一个固定的接收端口,只能接受这个端口发出的消息
udp_socket.bind(("",8001))
# 接收数据，处理
#while True:
recv_data=udp_socket.recvfrom(1024)
print(recv_data[1][0])
print(recv_data[1][1])
print(recv_data[0].decode(“gbk”))
# 关闭套接字
udp_socket.close()
if name == ‘main’:
#udpRecv()
udpSend()
|