SuperAPI AI 工具集

message-broker

编程与开发

查看项目

更新于 10-15 21:34

技能介绍

用途:指导构建基于 TCP 的发布/订阅消息代理,实现 Python 应用与 AutoHotkey 脚本等进程间通信。

主要能力:代理服务器默认监听 localhost:15234,支持主题路由、消息队列与健康检查;采用 4 字节大端长度前缀加 UTF-8 JSON 负载的帧格式,消息遵循 JSON-RPC 2.0。支持 connect、disconnect、subscribe、unsubscribe、publish、ping、status 等方法,以及 system.broker.ready 等系统主题。提供 Python 异步客户端 BrokerClient(connect、subscribe、publish、request 等)与线程安全的 QtBrokerClient(PySide6/PyQt 信号)。主题命名约定为 <domain>.<entity>.<action>,支持 *、+、# 通配符匹配。

使用方式:定义 BrokerConfig(host、port、max_connections、heartbeat_interval、max_message_size 等)后启动 MessageBroker;客户端连接后订阅模式并发布消息,可用 request 实现请求/响应。AHK 可直接用 TCP 套接字,或推荐使用 AHKBridge 桥接。

适用场景:作业激活通知、脚本状态更新、跨语言进程通信、Qt 界面与后台服务联动。

限制:默认端口 15234、最大消息 1 MB、最大队列 10000;Qt 主线程不可使用 await,需用 QtBrokerClient;错误码涵盖解析、请求、方法、参数、内部、未连接与超时等。具体安装命令与依赖版本暂未提供。