壶瓶山鮡,213002,巩新亮 走光
udp是面向无连接的通讯协议,udp数据包括目的端口号和源端口号信息,由于通讯不需要连接,所以可以实现广播发送。 udp传输数据时有大小限制,每个被传输的数据报必须限定在64kb之内。 udp是一个不可靠的协议,发送方所发送的数据报并不一定以相同的次序到达接收方。udp是面向消息的协议,通信时不需要建立连接,数据的传输自然是不可靠的,udp一般用于多点通信和实时的数据业务,比如:
创建一个udp客户端程序的流程是简单,具体步骤如下:
代码如下:
#coding=utf-8 from socket import * #1、创建socket套接字 #socket(参数1,参数2) #参数1 = af_inet固定的 #参数2 = sock_dgram表示udp,上篇文章中说过sock_strem表示tcp udpsocket = socket(af_inet,sock_dgram) #2、准备接收方的地址 sendaddress = ("192.168.100.101",8080) #3、从键盘输入需要发送的数据 senddata = input("请输入要发送的数据:") #4、发送数据到指定电脑 udpsocket.sendto(senddata.encode(),sendaddress) #5、关闭socket套接字 udpsocket.close()
运行程序:
这个时候我就向我的另外一台ip地址为:192.168.100.101 端口号为8080的程序发送了“我是侯哥”这一条消息。我们借助于网络调试助手软件用于测试,网络调试助手各个平台的系统都有,大家可以自己下载使用。
说明:我的代码是在windows电脑上运行的,我的网络调试助手是在mac电脑上运行的,如果没有两台电脑的,也可以使用虚拟机测试。
#coding=utf-8 from socket import * #1、创建socket套接字 udpsocket = socket(af_inet,sock_dgram) #2、准备接收方的地址 sendaddress = ("192.168.100.101",8080) #3、从键盘输入需要发送的数据 senddata = input("请输入要发送的数据:") #4、发送数据到指定电脑 udpsocket.sendto(senddata.encode(),sendaddress) #5、等待接收对方发送的数据 receivedata = udpsocket.recvfrom(1024) #6、显示对方发送的数据 print(receivedata) #7、关闭socket套接字 udpsocket.close()
运行程序:
会变的端口号:重新运行多次脚本,然后在“网络调试助手”中,看到的现象如下:
说明:
一般情况下,在一天电脑上运行的网络程序有很多,而各自用的端口号很多情况下不知道,为了不与其他的网络程序占用同一个端口号,往往在编程中,udp的端口号一般不绑定,但是如果需要做成一个服务器端的程序的话,是需要绑定的。就像报警电话每天都在变,想必世界就会乱了,所以一般服务性的程序,往往需要一个固定的端口号,这就是所谓的端口绑定
绑定示例
#coding=utf-8 from socket import * #1、创建socket套接字 udpsocket = socket(af_inet,sock_dgram) #2、绑定相关信息,如果一个网络程序不绑定,则系统会随机分配 bindaddress = ("",7781)#ip地址和端口号,ip一般不用写,表示本机的任何一个ip udpsocket.bind(bindaddress) #3、等待接收方发送消息 receivedata = udpsocket.recvfrom(1024) #4、显示对方发送的数据 print(receivedata) #5、关闭socket套接字 udpsocket.close()
windows电脑发送信息
mac电脑接收信息如下:
说明:
#coding=utf-8 from threading import thread from socket import * #接收数据 def receiveinfo(): while true: receivedata = udpsocket.recvfrom(1024) print("<<%s:%s"%(str(receivedata[1]),str(receivedata[0]))) #发送数据 def sendinfo(): while true: senddata = input("") udpsocket.sendto(senddata.encode("gb2312"),(destip,destport)) udpsocket = none destip = "" destport = 0 def main(): global udpsocket global destip global destport destip = input("对方的ip:") destport = int(input("对方的port:")) udpsocket = socket(af_inet,sock_dgram) udpsocket.bind(("",4567))#这里写两个()的原因是将("",4567)当做一个整体元组使用 tr = thread(target = receiveinfo) ts = thread(target = sendinfo) tr.start() ts.start() tr.join() ts.join() if __name__ == '__main__': main()
mac电脑上执行程序如下:
windows电脑上运行网络调试助手如下:
从而就是实现了基于socket的udp的聊天功能。
程序基本流程:创建接收端socket ---> 创建发送到socket ---> 启动接收端socket ---> 启动发送端socket ---> 等待用户输入 ---> 接收用户输入并发送到广播 ---> 接收信息并显示。
# -*- coding:utf-8 -*- from socket import * from time import ctime, sleep import threading class chatroomplus: def __init__(self): # 全局参数配置 self.encoding = "utf-8" # 使用的编码方式 self.broadcastport = 7788 # 广播端口 # 创建广播接收器 self.recvsocket = socket(af_inet, sock_dgram) self.recvsocket.setsockopt(sol_socket, so_reuseaddr, 1) self.recvsocket.setsockopt(sol_socket, so_broadcast, 1) self.recvsocket.bind(('', self.broadcastport)) # 创建广播发送器 self.sendsocket = socket(af_inet, sock_dgram) self.sendsocket.setsockopt(sol_socket, so_broadcast, 1) # 其他 self.threads = [] def send(self): """发送广播""" print("udp发送器启动成功...") self.sendsocket.sendto("***加入了聊天室".encode(self.encoding), ('255.255.255.255', self.broadcastport)) while true: senddata = input("请输入需要发送的消息:") self.sendsocket.sendto(senddata.encode(self.encoding), ('255.255.255.255', self.broadcastport)) # print("【%s】%s:%s" % (ctime(), "我", senddata)) sleep(1) def recv(self): """接收广播""" print("udp接收器启动成功...") while true: # 接收数据格式:(data, (ip, port)) recvdata = self.recvsocket.recvfrom(1024) print("【%s】[%s : %s] : %s" % (ctime(), recvdata[1][0], recvdata[1][1], recvdata[0].decode(self.encoding))) sleep(1) def start(self): """启动线程""" t1 = threading.thread(target=self.recv) t2 = threading.thread(target=self.send) self.threads.append(t1) self.threads.append(t2) for t in self.threads: t.setdaemon(true) t.start() while true: pass if __name__ == "__main__": demo = chatroomplus() demo.start()
运行效果:
mac电脑上运行
linux电脑上运行程序
windows上运行程序
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
python求numpy中array按列非零元素的平均值案例
网友评论