btcpool矿池源码分析(8)-slparser

古城微笑少年丶 2022-05-24 03:53 237阅读 0赞

**\# btcpool矿池-slparser(share log parser)模块解析**

**\#\# 核心机制总结**

\* 支持三种功能：

\* 指定Date和UID，将打印指定日期指定用户的share信息到stdout

\* UID=0时，将打印指定日期所有用户的share信息

\* 指定Date但未指定UID，读取指定日期sharelog，统计数据并写入数据库

\* 按Worker、user、pool三个维度统计:Accept1h、Accept1d、score1h、score1d、Reject1h、Reject1d

\* 数据库仅保留最近3个月统计数据

\* 如果Date和UID均未指定，将监听文件变化，读取share并统计数据，每15秒写入数据库

\* 同时启动Httpd服务，开放ServerStatus和WorkerStatus

**\#\# slparser命令使用**

\`\`\`shell

slparser -c slparser.cfg -l log\_dir

slparser -c slparser.cfg -l log\_dir2 -d 20160830

slparser -c slparser.cfg -l log\_dir3 -d 20160830 -u puid

\#-c指定slparser配置文件

\#-l指定日志目录

\#-d指定日期

\#-u指定PUID（即userId），userId为0时dump all, >0时仅输出指定userId的sharelog

\`\`\`

**\#\# slparser.cfg配置文件**

\`\`\`shell

slparserhttpd = \{

\#指定IP和端口

ip = "0.0.0.0";

port = 8081;

\#每间隔15s写库

flush\_db\_interval = 15;

\};

\#指定sharelog文件路径

sharelog = \{

data\_dir = "/data/sharelog";

\};

\#数据库配置，表为table.stats\_xxxx

pooldb = \{

host = "";

port = 3306;

username = "dbusername";

password = "dbpassword";

dbname = "";

\};

\`\`\`

**\#\# slparser流程图**

![20180520103452559][]

**\#\# bpool\_local\_stats\_db数据库结构**

\[ bpool\_local\_stats\_db.txt\]( bpool\_local\_stats\_db.txt)

\`\`\`c++

DROP TABLE IF EXISTS \`stats\_pool\_day\`;

CREATE TABLE \`stats\_pool\_day\` (

\`day\` int(11) NOT NULL,

\`share\_accept\` bigint(20) NOT NULL DEFAULT '0',

\`share\_reject\` bigint(20) NOT NULL DEFAULT '0',

\`reject\_rate\` double NOT NULL DEFAULT '0',

\`score\` decimal(35,25) NOT NULL DEFAULT '0.0000000000000000000000000',

\`earn\` bigint(20) NOT NULL DEFAULT '0',

\`lucky\` double NOT NULL DEFAULT '0',

\`created\_at\` timestamp NULL DEFAULT NULL,

\`updated\_at\` timestamp NULL DEFAULT NULL,

UNIQUE KEY \`day\` ( \`day\`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS \`stats\_pool\_hour\`;

CREATE TABLE \`stats\_pool\_hour\` (

\`hour\` int(11) NOT NULL,

\`share\_accept\` bigint(20) NOT NULL DEFAULT '0',

\`share\_reject\` bigint(20) NOT NULL DEFAULT '0',

\`reject\_rate\` double NOT NULL DEFAULT '0',

\`score\` decimal(35,25) NOT NULL DEFAULT '0.0000000000000000000000000',

\`earn\` bigint(20) NOT NULL DEFAULT '0',

\`created\_at\` timestamp NULL DEFAULT NULL,

\`updated\_at\` timestamp NULL DEFAULT NULL,

UNIQUE KEY \`hour\` ( \`hour\`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS \`stats\_users\_day\`;

CREATE TABLE \`stats\_users\_day\` (

\`puid\` int(11) NOT NULL,

\`day\` int(11) NOT NULL,

\`share\_accept\` bigint(20) NOT NULL DEFAULT '0',

\`share\_reject\` bigint(20) NOT NULL DEFAULT '0',

\`reject\_rate\` double NOT NULL DEFAULT '0',

\`score\` decimal(35,25) NOT NULL DEFAULT '0.0000000000000000000000000',

\`earn\` bigint(20) NOT NULL DEFAULT '0',

\`created\_at\` timestamp NULL DEFAULT NULL,

\`updated\_at\` timestamp NULL DEFAULT NULL,

UNIQUE KEY \`puid\_day\` ( \`puid\`, \`day\`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS \`stats\_users\_hour\`;

CREATE TABLE \`stats\_users\_hour\` (

\`puid\` int(11) NOT NULL,

\`hour\` int(11) NOT NULL,

\`share\_accept\` bigint(20) NOT NULL DEFAULT '0',

\`share\_reject\` bigint(20) NOT NULL DEFAULT '0',

\`reject\_rate\` double NOT NULL DEFAULT '0',

\`score\` decimal(35,25) NOT NULL DEFAULT '0.0000000000000000000000000',

\`earn\` bigint(20) NOT NULL DEFAULT '0',

\`created\_at\` timestamp NULL DEFAULT NULL,

\`updated\_at\` timestamp NULL DEFAULT NULL,

UNIQUE KEY \`puid\_hour\` ( \`puid\`, \`hour\`),

KEY \`hour\` ( \`hour\`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS \`stats\_workers\_day\`;

CREATE TABLE \`stats\_workers\_day\` (

\`puid\` int(11) NOT NULL,

\`worker\_id\` bigint(20) NOT NULL,

\`day\` int(11) NOT NULL,

\`share\_accept\` bigint(20) NOT NULL DEFAULT '0',

\`share\_reject\` bigint(20) NOT NULL DEFAULT '0',

\`reject\_rate\` double NOT NULL DEFAULT '0',

\`score\` decimal(35,25) NOT NULL DEFAULT '0.0000000000000000000000000',

\`earn\` bigint(20) NOT NULL DEFAULT '0',

\`created\_at\` timestamp NULL DEFAULT NULL,

\`updated\_at\` timestamp NULL DEFAULT NULL,

UNIQUE KEY \`puid\_worker\_id\_day\` ( \`puid\`, \`worker\_id\`, \`day\`),

KEY \`day\` ( \`day\`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS \`stats\_workers\_hour\`;

CREATE TABLE \`stats\_workers\_hour\` (

\`puid\` int(11) NOT NULL,

\`worker\_id\` bigint(20) NOT NULL,

\`hour\` int(11) NOT NULL,

\`share\_accept\` bigint(20) NOT NULL DEFAULT '0',

\`share\_reject\` bigint(20) NOT NULL DEFAULT '0',

\`reject\_rate\` double NOT NULL DEFAULT '0',

\`score\` decimal(35,25) NOT NULL DEFAULT '0.0000000000000000000000000',

\`earn\` bigint(20) NOT NULL DEFAULT '0',

\`created\_at\` timestamp NULL DEFAULT NULL,

\`updated\_at\` timestamp NULL DEFAULT NULL,

UNIQUE KEY \`puid\_worker\_id\_hour\` ( \`puid\`, \`worker\_id\`, \`hour\`),

KEY \`hour\` ( \`hour\`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\`\`\`

[20180520103452559]: /images/20220524/70af73c6398742d48c2733dc333e65f3.png

btcpool矿池源码分析(8)-slparser

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关（源码分析）JDK1.8 HashMap源码分析

相关 Druid数据连接池源码分析

相关线程池源码分析_01 FutureTask源码分析

相关 linux内存源码分析 - 内存池

相关 btcpool矿池源码分析(8)-slparser

相关【kubernetes/k8s源码分析】kubelet源码分析之cdvisor源码分析

相关（源码分析）JDK1.8 ArrayList源码分析

相关（源码分析）JDK1.8 LinkedList源码分析

相关【kubernetes/k8s源码分析】coredns 源码分析之一解读源码

相关数字货币矿池矿场区别