码迷,mamicode.com
首页 > 其他好文 > 详细

Socket编程:UDP Ping

时间:2020-04-08 19:26:03      阅读:78      评论:0      收藏:0      [点我收藏+]

标签:pack   系统调用   socket编程   缓冲区   最大   编写   sae   格式   random   

Socket编程:UDP Ping

使用python采用UDP协议编写一个ping程序,发送一个简单的ping报文给服务器,并确定从客户发送ping报文服务器到接受到pong报文为止的时延,称为往返时延(RTT) 。
因为UDP是一个不可靠的协议,客户发送的分组可能会丢失,为此,客户不能无限期地等待服务器的响应,等待时间至多为1s,否则,打印一条错误信息。

UDP_Pinger_Sever.py

import random
from socket import *
#AF_INET指定使用IPv4协议,如果要用更先进的IPv6,就指定为AF_INET6
#SOCK_DGRAM指定了这个Socket的类型是UDP
serverSocket = socket(AF_INET, SOCK_DGRAM)
#用0.0.0.0绑定到所有的网络地址,还可以用127.0.0.1绑定到本机地址
serverSocket.bind((‘127.0.0.1‘,12000))

while True:
	#产生一个0到10之间的随机数
	rand = random.randint(0, 10)
	#从套接口上读取数据,参数为缓冲区大小
	message, address = serverSocket.recvfrom(1024)
	#通过打印我们可以看到UDP客户端socket的端口是不确定,系统随机分配的
	print("收到来自 %s 的报文: (%s)" % (address,message))
	# 把接收到的信息全部转为大写
	print("随机数是: %d" % rand)
	message = message.upper()
	#如果随机数小于4,服务端无应答,客户端就会超时
	if rand < 4:
		continue
	serverSocket.sendto(message, address)

UDP_Pinger_Client.py

import time
from socket import *
serverName = ‘127.0.0.1‘ # 主机
serverPort = 12000
# 创建Socket时,AF_INET指定使用IPv4协议,如果要用更先进的IPv6,就指定为AF_INET6
# SOCK_DGRAM指定了这个Socket的类型是UDP
# SOCK_STREAM指定使用面向流的TCP协议
clientSocket = socket(AF_INET, SOCK_DGRAM)
clientSocket.settimeout(1) # 设置超时时间为1s
for i in range(0, 10):
	oldTime = time.time()
	sendTime = time.strftime(‘%Y-%m-%d %H:%M:%S‘, time.localtime(oldTime))
	# encode()把str转成bytes,传输格式要求
	message = (‘package %d,client_local_time:%s‘ % (i + 1, sendTime)).encode()
	try:
		# 发送数据
		clientSocket.sendto(message, (serverName, serverPort))
		# 1024指定要接收的最大数据量为1kb = 1024 bytes
		# recvfrom是一个系统调用,由用户态转向系统态,从套接口上接收数据,并捕获数据发送源的地址。
		# 如果数据报大于缓冲区,那么缓冲区中只有数据报的前面部分,其他的数据都丢失了,并且recvfrom()函数返回WSAEMSGSIZE错误
		# 如果没有数据待读,那么除非是非阻塞模式,不然的话套接口将一直等待数据的到来,果没有在Timeout = 1s内接收到数据,此时将返回SOCKET_ERROR错误,错误代码是WSAEWOULDBLOCK。用select()或WSAAsynSelect()可以获知何时数据到达
		# UDP的 recvfrom() 和 TCP 的recv()不一样,具体可以看 TCP Ping项目
		modifiedMessage, serverAddress = clientSocket.recvfrom(1024)
		# 计算往返时间
		rtt = time.time() - oldTime
		# decode 把bytes转成str
		modifiedMessage = modifiedMessage.decode("utf-8")
		print(‘报文 %d 收到来自 %s 的应答: %s,往返时延(RTT) = %fs‘ % (i+1, serverName,modifiedMessage, rtt))
	except Exception as e:
		print(‘报文 %d: 的请求超时‘ % (i+1)) # 处理异常

运行

技术图片

技术图片

Socket编程:UDP Ping

标签:pack   系统调用   socket编程   缓冲区   最大   编写   sae   格式   random   

原文地址:https://www.cnblogs.com/Weber-security/p/12661681.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!