文件名称:runner:RabbitMQ 的 Golang 简单任务 Runner 示例
文件大小:7KB
文件格式:ZIP
更新时间:2024-06-21 09:58:13
Go
RabbitMQ 的 Golang 简单任务 Runner 示例 仅供个人使用(非通用解决方案)。 它能做什么: 加载本地配置文件 (config.json) 基于本地配置请求远程配置: 发送当前运行时信息(由收集的内存、cpu、网络设置) 接收当前机器的附加设置(工作人员数量和 RabbitMQ 连接信息) 运行工人 连接到RabbitMQ服务器 在推送到队列的每个新任务(JSON 消息)上,在可用工作线程上运行作业 为了实现所需功能job包应该rewriten 本地配置文件格式 { " Username " : " " , " Password " : " " , " ApiHost " : " " , " ConfigApiPath " : " " } 远程配置文件格式 { " ThreadsCount
【文件预览】:
runner-master
----worker()
--------worker.go(651B)
----config()
--------config.go(1KB)
----job()
--------job.go(381B)
----amqp()
--------amqp.go(2KB)
----api()
--------api.go(3KB)
----common()
--------common.go(565B)
----main.go(1KB)
----README.md(1KB)
----config.json(91B)