【文件属性】:
文件名称:runner:RabbitMQ 的 Golang 简单任务 Runner 示例
文件大小:7KB
文件格式:ZIP
更新时间:2021-06-01 16:11:33
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)