当前位置：首页 > news >正文

使用Tkinter写一个发送kafka消息的工具

news 来源：原创 2025/7/1 1:27:38

文章目录

- 背景
- 工具界面展示
- 功能
- 代码讲解
- - 运行环境
  - 创建GUI程序
  - 搭建前端样式
  - 编写功能实现代码

背景

公司是做AR实景产品的，近几年无人机特别的火，一来公司比较关注低空经济这个新型领域，二来很多政企、事业单位都采购了无人机用于日常工作。那么就衍生了将无人机接入到AR实景项目中的需求。

本工具的作用就是在AR实景项目中模拟无人机飞行时候产生的飞控数据。

工具界面展示

在这里插入图片描述

功能

用户填写kafka连接地址，
用户参考消息示例模板编写消息内容，并发送到kafka 的 topic 中。
所有操作的log输出到用户界面

代码讲解

运行环境

python：3.9.7
pip：pip3(pip 21.2.3 )
OS：win11
GUI：TKinter
kafka-client：confluent_kafka

创建GUI程序

通过 tk.Tk() 实例化一个GUI程序。
通过 ttk.Style() 实例化主题并通过style.configure 设置公共样式。
通过 KafkaMessageSenderApp(root) 的构造函数将root实例传入业务代码中
最后通过root.mainloop()让程序保持前台运行


if __name__ == "__main__":# 设置样式root = tk.Tk()style = ttk.Style()# 尝试配置主题try:if "clam" in style.theme_names():style.theme_use("clam")except:pass# 自定义样式style.configure("TLabel", font=("SimHei", 10))style.configure("TButton", font=("SimHei", 10))style.configure("TEntry", font=("SimHei", 10))style.configure("TFrame", background="#f0f0f0")style.configure("TLabelframe", background="#f0f0f0")style.configure("TLabelframe.Label", background="#f0f0f0", font=("SimHei", 10, "bold"))# 创建强调按钮样式style.configure("Accent.TButton", foreground="white", background="#4a86e8")app = KafkaMessageSenderApp(root)root.mainloop()

搭建前端样式

在KafkaMessageSenderApp 的构造函数中，通过create_widgets函数完成前端样式的编写，例如 label 的位置，button 的名字及绑定的回调处理函数
通过 start_log_consumer 处理日志
通过generate_example_message生成模板消息

self.create_widgets()self.start_log_consumer()# 生成示例消息self.generate_example_message()

编写功能实现代码

通过为前端各种控件绑定回调函数来实现业务代码的编写。例如通过为发送消息按钮绑定回调处理消息的发送。

按钮样式和回调函数绑定：


# 按钮区域button_frame = ttk.Frame(main_frame)button_frame.pack(fill=tk.X, pady=5)# 创建按钮并保存引用self.send_button = ttk.Button(button_frame,text="发送消息",command=self.send_message,width=20,style="Accent.TButton",)

发送消息：


def send_message(self):"""发送消息到Kafka"""if self.producer is None:messagebox.showerror("错误", "请先连接到Kafka服务器")returntopic = self.topic_var.get()if not topic:messagebox.showerror("错误", "请输入Topic")returnmessage_text = self.message_text.get(1.0, tk.END).strip()if not message_text:messagebox.showerror("错误", "消息内容不能为空")return# 解析JSONtry:message_data = json.loads(message_text)except json.JSONDecodeError as e:messagebox.showerror("JSON解析错误", f"无效的JSON格式: {str(e)}")return# 在新线程中发送消息，避免阻塞UIthreading.Thread(target=self._send_message_thread, args=(topic, message_data), daemon=True).start()

使用Tkinter写一个发送kafka消息的工具

文章目录背景工具界面展示功能代码讲解运行环境创建GUI程序搭建前端样式编写功能实现代码背景公司是做AR实景产品的，近几年无人机特别的火，一来公司比较关注低空经济这个新型领域，二来很多政企、事业单位都采购了无人机用于日常工作。那么…...

编程日记 2025/7/1 1:27:38

这是一个 wav 转 pcm 的简单demo，但VS2017编译报错 #define _CRT_SECURE_NO_WARNINGS #include <stdio.h> #include <inttypes.h> #pragma pack(push, 1) struct TWavHead {int8_t riff[4]; /*!< (4)资源交换文件标志 RIFF */uint32_t file_si…...

编程日记 2025/6/27 12:54:48

Vue3 中 Route 与 Router 的区别

在 Vue Router 中，Route 和 Router 是两个相关但完全不同的概念： 1、Router (路由实例) 定义：Router 是路由器的实例，负责整个应用的路由管理功能： 管理路由映射表（路由配置） 提供编程式导航…...

编程日记 2025/6/29 8:29:42

gcc还会有自己的头文件呢？

1. GCC自己的头文件目录路径： .../lib/gcc/<target>/<version>/include 作用： 这里存放的是GCC编译器自身实现的一些头文件，比如 stdarg.h、float.h、limits.h、varargs.h 等。这些头文件是C/C标准规定必须有的，但…...

编程日记 2025/6/29 8:45:44

YOLO训练输入尺寸代表什么 --input_width 和 --input_height 参数

参数作用硬件对齐要求许多边缘计算芯片（如 K230）的 NPU 对输入尺寸有内存对齐要求（例如 32 的倍数）。脚本会自动将你填写的输入尺寸向上对齐到最近的 32 倍数： input_width int(math.ceil(args.input_width / 32.0…...

编程日记 2025/6/27 23:19:06

缓存穿透、缓存击穿、缓存雪崩解决方案

在分布式系统中，缓存是提升性能的关键组件，但也可能面临缓存穿透、缓存击穿、缓存雪崩三大典型问题。以下是三者的核心概念、区别及解决方案：一、缓存穿透（Cache Penetration）概念场景：客户端请求不存在的数据（如恶意攻击的非法 Key），由于缓存和数...

编程日记 2025/6/27 1:50:49

前端面经-nginx/docker

1.如何查看 Linux 系统负载？如何判断负载是否过高？ 使用 top、htop 或 uptime 查看系统负载。负载值（Load Average）反映 CPU 繁忙程度，理想情况下应小于 CPU 核心数。例如，4 核 CPU 的负载持续超过 4 表示…...

编程日记 2025/6/27 23:22:32

权限控制相关实现

Spring Boot-Shiro-Vue： 这个项目可以满足基本的权限控制需求，前后端都有，开箱即用...

编程日记 2025/6/27 22:51:02

[论文精读]Ward: Provable RAG Dataset Inference via LLM Watermarks

Ward: Provable RAG Dataset Inference via LLM Watermarks [2410.03537] Ward: Provable RAG Dataset Inference via LLM Watermarks ICLR 2025 Rebuttal：Ward: 可证明的 RAG 数据集推理通过 LLM 水印 | OpenReview --- Ward: Provable RAG Dataset Inference v…...

编程日记 2025/6/27 18:36:50

第23天-Python Flet 开发指南

环境准备 pip install flet 示例1：基础计数器应用 import flet as ftdef main(page: ft.Page):page.title = "计数器"page.vertical_alignment = ft.MainAxisAlignment.CENTERtxt_number = ft.TextField(value="0", text_align=ft.TextAlign.RIGHT, wid…...

编程日记 2025/6/27 23:17:48

LangGraph(五)——自定义状态

目录 1. 向状态添加键2. 更新工具中的状态3. 构建状态图4. 提示聊天机器人5. 添加人工协助6. 手动更新状态参考 1. 向状态添加键通过向状态添加name和birthday键来更新聊天机器人对实体生日的研究： from typing import Annotated from typing_extensions import T…...

编程日记 2025/6/27 5:54:16

fatload使用方式

‌Fatload是U-Boot中的一个命令，用于从FAT文件系统加载二进制文件到内存中‌。其基本用法如下： fatload <interface> <dev[:part]> <addr> <filename> <bytes>‌interface‌：所使用的接口，如MMC、…...

编程日记 2025/6/27 23:36:48

Pytorch基础操作

面试的时候，PhD看我简历上面写了”熟悉pytorch框架“，然后就猛猛提问了有关于tensor切片的问题…当然是没答上来，因此在这里整理一下pytorch的一些基础编程语法，常看常新 PyTorch基础操作全解一、张量初始化 PyTorch的核心数据…...

编程日记 2025/6/27 23:21:28

Femap许可证安装与配置指南

在电磁仿真领域，Femap凭借其卓越的性能和广泛的应用场景，已成为许多工程师和科研人员的首选工具。为了确保您能够顺利安装和配置Femap许可证，本文将提供详细的安装和配置指南，帮助您快速完成设置，开启高效的仿真之旅。…...

编程日记 2025/6/30 1:41:26

家用和类似用途电器的安全第1部分：通用要求与2005版差异（7）

文未有本标准免费下载链接。 ——增加了“对峰值电压大于15kV的，其放电电能应不超过350mJ”的要求（见8.1.4） 1. GB/T4706.1-2024： 8.1.4 如果易触及部件为下述情况,则不认为其是带电的。 ——该部件由安全特低电压供电,且: 对…...

编程日记 2025/6/29 21:43:35

基于Browser Use + Playwright 实现AI Agent操作Web UI自动化

Browser Use是什么 Browser Use是一个开源项目官网：Browser Use - Enable AI to control your browser，专为大语言模型（LLM）设计的只能浏览器工具，能够让AI像人类一样自然的浏览和操作网页，支持多标签页管…...

编程日记 2025/6/30 1:28:26

【题解-洛谷】B4302 [蓝桥杯青少年组省赛 2024] 出现奇数次的数

题目：B4302 [蓝桥杯青少年组省赛 2024] 出现奇数次的数题目描述奇数：指不能被 2 2 2 整除的整数。例如： 3 3...

编程日记 2025/6/27 17:19:52

Redis SETNX：分布式锁与原子性操作的核心

SETNX 是 Redis 中的一个经典命令，全称是 Set if Not eXists（当键不存在时设置值）。它的核心作用是原子性地完成 “检查并设置” 操作，常用于分布式锁、防止重复提交等需要 “独占性” 的场景。一、基本语法与返回值命令格式&…...

编程日记 2025/6/27 7:11:46

常见字符串相似度算法详解

目录引言一、Levenshtein距离（编辑距离） 1.1 算法原理 1.2 Java实现 1.3 springboot中实现二、Jaro-Winkler相似度 2.1 算法特点 2.2 Java实现三、余弦相似度（向量空间模型） 3.1 实现步骤 3.2 Java实现 3.3 简化版…...

编程日记 2025/6/29 5:51:11

红蓝对抗中的网络安全设备操作手册

目录 🔐 关键要点设备操作与实战应用 📊 1. 防火墙 (Firewall) 蓝队（防御）用法红队（攻击）用法 🔍 2. 入侵检测/防护系统 (IDS/IPS) 蓝队（防御）用法红队&#…...

编程日记 2025/6/27 22:51:03

用python实现汉字转拼音工具

用python实现汉字转拼音工具主要功能特点： 多种拼音风格选择（带声调符号、数字声调、无声调）输出模式：可以选择“普通模式”（仅拼音）或“拼音注音”（每个汉字的拼音显示在上方）可…...

编程日记 2025/6/27 2:42:23

spring中的Interceptor使用说明

一、Interceptor 的核心概念 Interceptor（拦截器） 是 Spring MVC 提供的一种机制，用于在请求处理的不同阶段插入自定义逻辑。其核心作用包括： • 预处理：在控制器方法执行前进行权限校验、日志记录等。 • 后处理&am…...

编程日记 2025/6/27 22:51:04

Wi-Fi（无线局域网技术）

Wi-Fi（Wireless Fidelity，无线保真）是通过无线电波传输数据的技术，它使设备能够通过无线连接方式访问网络、共享文件或连接互联网。Wi-Fi已经成为现代家庭、办公室以及公共场所中常见的无线通信方式，支持的设备包括手机…...

编程日记 2025/6/27 23:04:51

MySQL Host 被封锁解决方案（全版本适用 + Java 后端优化）

引言 MySQL 中 “Host is blocked because of many connection errors” 是生产环境常见问题，若处理不当会导致服务中断。本文结合 MySQL 官方文档（5.5/8.0）、Java 后端最佳实践及企业级经验，提供从 “快速解封” 到 “根源优化”…...

编程日记 2025/6/27 22:51:08

分类预测 | Matlab实现PSO-RF粒子群算法优化随机森林多特征分类预测

分类预测 | Matlab实现PSO-RF粒子群算法优化随机森林多特征分类预测目录分类预测 | Matlab实现PSO-RF粒子群算法优化随机森林多特征分类预测分类效果**功能概述****算法流程** 分类效果功能概述数据预处理读取Excel数据集，划分训练集（前260行&#…...

编程日记 2025/6/27 23:05:44

【苍穹外卖】Day01—Mac前端环境搭建

目录一、安装Nginx （一）安装Homebrew （二）Homebrew安装Nginx 1. 执行安装命令： 2. 验证安装： （三）启动与停止Nginx 二、配置Nginx 1. 替换nginx.conf 2. 替换html文件夹三…...

编程日记 2025/6/27 11:25:13

anaconda创建环境出错HTTPS

报错信息 warnings.warn( /home/ti-3/anaconda3/lib/python3.12/site-packages/urllib3/connectionpool.py:1099: InsecureRequestWarning: Unverified HTTPS request is being made to host ‘repo.anaconda.com’. Adding certificate verification is strongly advised. Se…...

编程日记 2025/6/27 23:03:09

Nginx 强制 HTTPS：提升网站安全性的关键一步

在当今互联网时代，网站的安全性至关重要。使用 HTTPS 协议可以有效保护用户数据，防止信息泄露和中间人攻击。本文将详细介绍如何在 Nginx 中设置强制 HTTPS，确保所有 HTTP 请求都被自动重定向到 HTTPS。一、背景与重要性 HTTPS&#xff08…...

编程日记 2025/6/27 23:24:35

青藏高原边界数据总集

关键数据集分类：地表参数数据集空间分辨率：m共享方式：开放获取数据大小：265.87 KB数据时间范围:2016元数据更新时间:2022-04-18 数据集摘要此边界数据总集包含五种类型的边界： １、TPBoundary_2500m&#…...

编程日记 2025/6/30 6:05:45

AI赋能R-Meta分析核心技术：从热点挖掘到高级模型

随着人工智能技术的不断进步，Meta分析作为科学研究中的一种重要方法，也在不断地被赋予新的活力。特别是以ChatGPT为代表的AI大语言模型，为Meta分析提供了更为高效和智能的工具。本文将详细介绍AI赋能R-Meta分析的核心技术，并结合实…...

编程日记 2025/6/27 12:56:30

基于R语言地理加权回归、主成份分析、判别分析等空间异质性数据分析实践技术应用

在自然和社会科学领域有大量与地理或空间有关的数据，这一类数据一般具有严重的空间异质性，而通常的统计学方法并不能处理空间异质性，因而对此类型的数据无能为力。以地理加权回归为基础的一系列方法：经典地理加权回归，…...

编程日记 2025/6/27 11:06:40

GPT 等decoder系列常见的下游任务

下面用一句话＋四个例子，把上面那张“所有下游任务都要微调”架构图说清楚： 核心思路：不管你要做什么任务，都用同一个 Transformer（这里是 GPT／Decoder-Only 模型）当“特征抽取器”&a…...

编程日记 2025/6/27 22:51:21

java面试每日一背 day1

1.什么是缓存穿透缓存穿透是指查询一个数据库中根本不存在的数据，导致这个查询请求绕过缓存直接访问数据库的情况。这种情况如果频繁发生，会对数据库造成不必要的压力。典型特征： （1）查询的数据在数据库和缓存中都…...

编程日记 2025/6/30 8:25:13

Spring Boot AI 之 Chat Client API 使用大全

ChatClient提供了一套流畅的API用于与AI模型交互，同时支持同步和流式两种编程模型。流畅API包含构建Prompt组成元素的方法，这些Prompt将作为输入传递给AI模型。从API角度来看，Prompt由一系列消息组成，其中包含指导AI模型输出和行为的指令文本。 AI模型主要处理两类消息： …...

编程日记 2025/6/27 22:52:06

初识Linux · 五种IO模型和非阻塞IO

目录前言： 五种IO模型什么是IO IO模型非阻塞IO 前言： 前文我们已经将网络的基本原理介绍完了，都是通过围绕TCP/IP四层协议，将应用层，传输层，网络层，数据链路层全部介绍完毕&#xff0c…...

编程日记 2025/6/27 22:51:19

牛客网NC15869:长方体边长和计算问题解析

牛客网NC15869:长方体边长和计算问题解析题目描述问题分析设长方体的三条边长为 x, y, z根据题意，三个面的面积分别为： 第一个面面积：a x * y第二个面面积：b x * z第三个面面积：c y * z 解题思路通过三个面…...

编程日记 2025/6/29 11:02:40

Python60日基础学习打卡D32

我们已经掌握了相当多的机器学习和python基础知识，现在面对一个全新的官方库，看看是否可以借助官方文档的写法了解其如何使用。我们以pdpbox这个机器学习解释性库来介绍如何使用官方文档。大多数 Python 库都会有官方文档，里面包含了函数…...

编程日记 2025/6/29 12:43:01

Android本地语音识别引擎深度对比与集成指南：Vosk vs SherpaOnnx

技术选型对比矩阵对比维度VoskSherpaOnnx核心架构基于Kaldi二次开发ONNX Runtime + K2新一代架构模型格式专用格式（需专用工具转换）ONNX标准格式（跨框架通用）中文识别精度89.2% (TDNN模型)92.7% (Zipformer流式模型)内存占用60-150MB30-80MB迟表现320-500ms180-300ms多线程…...

编程日记 2025/6/29 23:01:50

Flink 核心概念解析：流数据、并行处理与状态

一、流数据（Stream Data） 1. 有界流（Bounded Stream） 定义：有明确起始和结束时间的数据集合，数据量固定，处理逻辑通常是一次性计算所有数据。典型场景： 历史交易数据统计&#xf…...

编程日记 2025/6/30 4:39:54

logits是啥、傅里叶变换

什么是logtis？ 在深度学习的上下文中，logits 就是一个向量，下一步通常被投给 softmax/sigmoid 的向量。。 softmax的输出是分类任务的概率，其输入是logits层。 logits层通常产生-infinity到 infinity的值，而softmax层…...

编程日记 2025/6/29 12:43:02

【机器学习基础】机器学习与深度学习概述算法入门指南

机器学习与深度学习概述算法入门指南一、引言：机器学习与深度学习（一）定义与区别（二）发展历程（三）应用场景二、机器学习基础（一）监督学习（二）无…...

编程日记 2025/6/30 22:38:46

Ajax研究

简介 AJAX Asynchronous JavaScript and XML（异步的 JavaScript 和 XML）。 AJAX 是一种在无需重新加载整个网页的情况下，能够更新部分网页的技术。 Ajax 不是一种新的编程语言，而是一种用于创建更好更快以及交互性更强的Web应用…...

编程日记 2025/6/29 10:21:13

小数第n位--快速幂+数学

1.快速幂，a*10的n2次方/b可以实现整数位3位是答案，但是数太大会超限，就要想取余 2.要是取前三位的话，那么肯定就是结果取余1000，对于除法来说，就是分母取余b*1000； 蓝桥账户中心 #include<…...

编程日记 2025/6/27 23:10:21

Python包管理工具uv 国内源配置

macOS 下 .config/uv/uv.toml内 pip源 [[index]] url "https://mirrors.tuna.tsinghua.edu.cn/pypi/web/simple/" default true#uv python install 下载源配置无效，需要在项目里配置 # python-install-mirror "https://mirror.nju.edu.cn/githu…...

编程日记 2025/6/27 23:36:52

RK3588 RKNN ResNet50推理测试

RK3588 RKNN ResNet50推理测试一、背景二、性能数据三、操作步骤3.1 安装依赖3.2 安装rknn-toolkit,更新librknnrt.so3.3 下载推理图片3.4 生成`onnx`模型转换脚本3.5 生成rknn模型3.6 运行rknn模型一、背景在嵌入式设备上进行AI推理时，我们面临着算力有限、功耗敏感等挑战…...

编程日记 2025/6/27 22:53:47

RUP的9个核心工作流在电商平台项目中的拆解

以下是对RUP的9个核心工作流在电商平台项目中的每个步骤的极度细化拆解，包含具体操作、角色分工、输入输出和案例细节： 1. 业务建模（Business Modeling）步骤拆解：识别业务参与者操作：与市场部、运营部开会，列出所有业务角色（买家、卖家、物流商、支付网关）。输…...

编程日记 2025/6/27 23:01:54

C++类和对象（2）

类的默认成员函数类的6个默认成员函数：构造函数、析构函数、拷贝构造函数、赋值运算符重载、取地址& 及 const取地址操作符重载。默认成员函数：用户可以实现，但当不显式实现时，编译器会自动生成的成员函数。构造函数 …...

编程日记 2025/6/27 21:29:24

I.MX6U Mini开发板通过GPIO口测试光敏传感器

原理图对应的Linux sysfs引脚编号为1，即可导出为gpio1引脚对应规则参考：https://blog.csdn.net/qq_39400113/article/details/127446205 配置引脚参数 #导出编号为1的GPIO引脚（对于I.MX6UL来说，也就是GPIO0_IO1/GPIO_1&#xff0…...

编程日记 2025/6/27 22:54:08