redis-plugins

在transfer组件的配置文件中有三个监听模块,分别是:http监听6060,rpc监听8433,socket监听4444。其中http为组件提供对外的控制接口;rpc为agent提供上报服务;socket提供一种基于socket的连接方式,但不推荐使用,日后可能会被废弃。

经transfer组件后,由agent上报来的数据,会通过一致性hash路由到judge和graph组件。

通过进程内队列将收集的数据放进queue,再由send_tasks,批量pop出batch条记录进行发送。

var (
TsdbQueue   *nlist.SafeListLimited
JudgeQueues = make(map[string]*nlist.SafeListLimited)// make用来初始化
GraphQueues = make(map[string]*nlist.SafeListLimited)// map后面的string是key type, 后面的指针是value type

)

judge和graph发送逻辑类似,发送过程使用简单for循环进行重试,最多重试三次。

https://github.com/ZhuoRoger/redismon

https://github.com/iambocai/falcon-monit-scripts/tree/master/redis