图形化UDP发包小工具_udp发包工具

---

前言

工具编写用的语言是python，组件采用的是tkiner组件，可以对指定目标地址和端口，发送消息，界面简单清晰

---

一、构思

在主窗口，用户填写对应的IPV4地址，服务器的端口号，要发送的消息内容，线程数量，发送消息的数量，点击发送按钮，即可发送UDP包给指定的服务器，并且将发送的数据包的大小以及服务器返回的内容，通过子窗口文本的形式展示出来

二、用到的python模块

tkiner模块

目前很火的编程语言：java，python等都有自己GUI界面编写模块，tkiner是python中用于图形化界面编写的模块

tkiner模块下载

win+R 打开运行框，输入cmd

需要安装python环境，并加入到环境变量，才可执行如下的命令

在DOS窗口输入如下命令

pip install tkiner
1

socket模块

socket模块是python中网络编程必用的模块，编写客户端和服务端的代码，必须采用socket模块进行连接，通信，数据的传输等，在java中也有相应的网络编程模块，socket(AF_INET,SOCK_DGRAM)返回的是一个非连接的通信对象，采用UDP传输，socket(AF_INET,SOCK_STRAM)返回的是一个面向连接的通信对象，采用TCP传输

ThreadPoolExecutor模块

ThreadPoolExecutor模块是python中线程池需要的模块，本次的udp发包小工具，用到了线程池，所以这个模块也是必须的

导入方式

from concurrent.futures import ThreadPoolExecutor
1

编码实现

由于本次测试的环境都是本地机器，所以客户端代码和服务端代码都是在本地上，话不多说，下面附上代码

客户端

from tkinter import *
import tkinter.messagebox
from socket import *
from concurrent.futures import ThreadPoolExecutor
# 客户端代码
if __name__ == '__main__':
    root = Tk()
    root.geometry("600x600+300+300")
    send_result = []
    get_result_index = 0
    def get_result(args):
        server_address = args[0]
        server_port = args[1]
        send_msg = args[2]
        client_socket = socket(AF_INET,SOCK_DGRAM)
        return_result = client_socket.sendto(send_msg.encode('utf8'),(server_address,int(server_port)))
        serverMsg,serverAddress = client_socket.recvfrom(1024)
        result_Text_Obj = args[3]
        result_Text_Obj.insert('end',"发送字节大小为"+str(return_result)+'\n服务器返回内容#'+serverMsg.decode('utf8')+'\n')

    def sendMsg(ipv4addr,msg,serverPort,thread_pool_number=10,msg_number=100):
        # ipv4addr = ipv4_entry.get()
        # msg = msg_entry.get()
        if (ipv4addr == "" or msg == "" or serverPort==""):
            tkinter.messagebox.showinfo(title="数据异常", message="请填写完整的数据")
        else:
            # 开始连接服务端，发送数据
            # from socket import *
            # serverName = '192.168.3.8'
            # serverPort = 12345
            # clientSocket = socket(AF_INET, SOCK_DGRAM)
            # while 1:
            #     message = input().encode()
            #     clientSocket.sendto(message, (serverName, serverPort))
            #     modifiedMessage, serverAddress = clientSocket.recvfrom(2048)
            #     print(modifiedMessage)
            # clientSocket.close()
            serverName=ipv4addr
            sport = serverPort
            root2 = Tk()
            root2.title("获得结果")
            root2.geometry('300x300+100+100')
            result_Text = Text(root2, width=200, height=200)
            result_Text.place(x=10, y=10, width=280, height=280)
            pool = ThreadPoolExecutor(int(thread_pool_number))
            for i in range(int(msg_number)+1):
                pool.submit(get_result,args=(serverName,sport,msg,result_Text))
            root2.mainloop()


    root.title("UDP消息发送客户端")
    label = Label(root,justify="center",text="IPV4addr",padx="10",pady="10",relief="groove").place(x=100,y=100,width=80,height=50)
    ipv4_entry = Entry(root,justify="center",width="100",relief="groove")
    ipv4_entry.place(x=180,y=100,width=180,height=50)
    ipv4_info_text = Label(root,justify="center",text="例如:192.168.10.100，无需掩码",padx="10",pady="10").place(x=380,y=100,width=180,height=50)
    send_msg_info_text = Label(root,justify="center",text="消息",padx="10",pady="10",relief="groove").place(x=100,y=160,width=80,height=50)
    msg_entry = Entry(root,justify="center",width="100",relief="groove")
    msg_entry.place(x=180,y=160,width=200,height=50)
    port_label = Label(root, justify="center", text="端口号", padx="10", pady="10").place(x=100, y=220,width=100, height=50)
    port_entry = Entry(root,justify="center",width="100",relief="groove")
    port_entry.place(x=210,y=220,width=100,height=50)
    #获取线程数量，使用线程去跑
    thread_pool_number_label = Label(root,justify="center",padx="10",pady="10",text="线程").place(x=100,y=290,width=100,height=50)
    thread_pool_number_entry = Entry(root,justify="center",width="100",relief="groove")
    thread_pool_number_entry.place(x=210,y=290,width=100,height=50)
    thread_pool_info_label = Label(root,justify="center",padx="10",pady="10",text="默认线程数量10").place(x=320,y=290,width=100,height=50)
    #设置发送消息数量
    msg_number_label = Label(root,justify='center',padx="10",pady="10",text="发送数量").place(x=100,y=360,width=100,height=50)
    msg_number_entry = Entry(root,justify="center",width=100,relief="groove")
    msg_number_entry.place(x=210,y=360,width=100,height=50)
    msg_number_info_label = Label(root,justify="center",padx="10",pady="10",text="默认数量100").place(x=320,y=360,width=100,height=50)
    #防止按钮自动触发函数，添加 lambda 函数添加一个参数， 或者去掉括号，不带参数
    send_Btn = Button(root,justify="center",padx="10",pady="10",text="发送",command=lambda:sendMsg(ipv4_entry.get(),msg_entry.get(),port_entry.get(),thread_pool_number_entry.get(),msg_number_entry.get()),width=100,height=50)
    send_Btn.place(x=100,y=420,width=100,height=50)
    root.mainloop()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

服务端代码

from socket import *
import datetime
#udp服务端代码
# from socket import *
# serverPort=12345
# serverSocket=socket(AF_INET,SOCK_DGRAM)
# serverSocket.bind(('192.168.3.8',serverPort))
# print('ready')
# while 1:
#     message,clientAddress=serverSocket.recvfrom(2048)
#     modifiedMessage=message.upper()
#     print(modifiedMessage)
#     serverSocket.sendto(modifiedMessage,clientAddress)
serverport = 12345
serverSocket = socket(AF_INET,SOCK_DGRAM)
serverSocket.bind(('127.0.0.1',serverport))
while 1:
    message,clientAddress = serverSocket.recvfrom(1024)
    print(message.decode('utf8')+"####"+str(datetime.datetime.now()))
    serverSocket.sendto(('服务端已收到'+message.decode('utf8')).encode('utf8'),clientAddress)


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

三、运行结果

客户端

发送消息

服务端

---