负载均衡UDP监听器使用自定义健康检查

import socket
from sys import argv

#健康检查请求
req = argv[1]

#健康检查返回结果
reply = argv[2]

#服务端口
port = int(argv[3])

# 定义服务器地址和端口
server_address = ('0.0.0.0', port)

# 创建UDP套接字
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sock.bind(server_address)

print("UDP server listening on", server_address)

while True:
    # 接收数据包
    data, client_address = sock.recvfrom(1024)
    data = data.decode('utf-8')

    print("Received from", client_address, ":", data)

    # 检查数据包是否包含特定内容
    if req in data:
        # 向发送方发送回复
        response = reply.encode('utf-8')
        sock.sendto(response, client_address)
        print("Sent response to", client_address)

sock.close()

[root@VM-2-15-centos ~]# python3 udpHealthCheck.py 'health check' 'i am good' 4455
UDP server listening on ('0.0.0.0', 4455)
Received from ('100.126.71.103', 62147) : health check
Sent response to ('100.126.71.103', 62147)
Received from ('100.126.62.45', 36289) : health check
Sent response to ('100.126.62.45', 36289)
Received from ('100.126.35.146', 35193) : health check
Sent response to ('100.126.35.146', 35193)
Received from ('100.126.72.44', 48635) : health check
Sent response to ('100.126.72.44', 48635)
Received from ('100.126.73.71', 55548) : health check
Sent response to ('100.126.73.71', 55548)

字符串转换为16进制(大写)
message = "i am good"
hex_str = ''.join([hex(ord(c))[2:] for c in message]).upper()
print(hex_str) #输出为6920616D20676F6F64

16进制转换为字符串
hex_str = "6920616D20676F6F64"
bytes_data = bytes.fromhex(hex_str)
str_data = bytes_data.decode('ascii')
print(str_data) #输出为i am good