兄弟連區塊鏈教程open-ethereum-pool礦池源碼分析API分析
阿新 • • 發佈：2018-10-15
defer enable pre 時間 ken mes for elar mat ApiServer相關定義
type ApiConfig struct { Enabled bool `json:"enabled"` Listen string `json:"listen"` StatsCollectInterval string `json:"statsCollectInterval"` HashrateWindow string `json:"hashrateWindow"` HashrateLargeWindow string `json:"hashrateLargeWindow"` LuckWindow []int `json:"luckWindow"` Payments int64 `json:"payments"` Blocks int64 `json:"blocks"` PurgeOnly bool `json:"purgeOnly"` PurgeInterval string `json:"purgeInterval"` } type ApiServer struct { config *ApiConfig backend *storage.RedisClient hashrateWindow time.Duration hashrateLargeWindow time.Duration stats atomic.Value miners map[string]*Entry minersMu sync.RWMutex statsIntv time.Duration } type Entry struct { stats map[string]interface{} updatedAt int64 } //代碼位置api/server.go
CollectStats原理
//config.StatsCollectInterval為CollectStats定時器，時間為5秒 //調取：stats, err := s.backend.CollectStats(s.hashrateWindow, s.config.Blocks, s.config.Payments) //s.hashrateWindow即cfg.HashrateWindow，即：為每個礦工估計算力的快速時間間隔，30分鐘 //s.config.Blocks即：前端顯示的最大塊數，50個 //s.config.Payments即：前端顯示的最大付款數量，50個 func (r *RedisClient) CollectStats(smallWindow time.Duration, maxBlocks, maxPayments int64) (map[string]interface{}, error) { ????//換算成秒 ????window := int64(smallWindow / time.Second) ????//創建map ????stats := make(map[string]interface{}) ????//Redis事務塊 ????tx := r.client.Multi() ????defer tx.Close() ????//換算成秒 ????now := util.MakeTimestamp() / 1000 ????cmds, err := tx.Exec(func() error { ????????//針對min和max參數需要額外說明的是，-inf和+inf分別表示Sorted-Sets中分數的最高值和最低值 ????????//缺省情況下，min和max表示的範圍是閉區間範圍，即min <= score <= max內的成員將被返回 ????????//然而我們可以通過在min和max的前面添加"("字符來表示開區間，如(min max表示min < score <= max，而(min (max表示min < score < max ????????//-inf <= score < now-window ???????? ????????//Zremrangebyscore 命令用於移除有序集中，指定分數（score）區間內的所有成員 ????????//ZREMRANGEBYSCORE eth:hashrate -inf (now-window ????????//慎重使用 ????????tx.ZRemRangeByScore(r.formatKey("hashrate"), "-inf", fmt.Sprint("(", now-window)) ???????? ????????//顯示整個有序集成員 ????????//ZRANGE eth:hashrate 0 -1 WITHSCORES ????????tx.ZRangeWithScores(r.formatKey("hashrate"), 0, -1) ???????? ????????//Hgetall 命令用於返回哈希表中，所有的字段和值 ????????//HGETALL eth:stats ????????tx.HGetAllMap(r.formatKey("stats")) ???????? ????????//Zrevrange 命令返回有序集中，指定區間內的成員 ????????//ZREVRANGE eth:blocks:candidates 0 -1 WITHSCORES ????????//candidates為候選者 ????????tx.ZRevRangeWithScores(r.formatKey("blocks", "candidates"), 0, -1) ???????? ????????//同上 ????????//ZREVRANGE eth:blocks:immature 0 -1 WITHSCORES ????????//immature為未成年 ????????tx.ZRevRangeWithScores(r.formatKey("blocks", "immature"), 0, -1) ???????? ????????//同上 ????????//ZREVRANGE eth:blocks:matured 0 49 WITHSCORES ????????//matured為成熟 ????????tx.ZRevRangeWithScores(r.formatKey("blocks", "matured"), 0, maxBlocks-1) ???????? ????????//Zcard 命令用於計算集合中元素的數量 ????????//ZCARD eth:blocks:candidates ????????tx.ZCard(r.formatKey("blocks", "candidates")) ???????? ????????//同上 ????????//ZCARD eth:blocks:immature ????????tx.ZCard(r.formatKey("blocks", "immature")) ???????? ????????//同上 ????????//ZCARD eth:blocks:matured ????????tx.ZCard(r.formatKey("blocks", "matured")) ???????? ????????//同上 ????????//ZCARD eth:payments:all ????????tx.ZCard(r.formatKey("payments", "all")) ???????? ????????//同上 ????????//ZREVRANGE eth:payments:all 0 49 WITHSCORES ????????tx.ZRevRangeWithScores(r.formatKey("payments", "all"), 0, maxPayments-1) ????????return nil ????}) ????if err != nil { ????????return nil, err ????} ????//Hgetall 命令用於返回哈希表中，所有的字段和值 ????//HGETALL eth:stats ????result, _ := cmds[2].(*redis.StringStringMapCmd).Result() ????stats["stats"] = convertStringMap(result) ???? ????//Zrevrange 命令返回有序集中，指定區間內的成員 ????//ZREVRANGE eth:blocks:candidates 0 -1 WITHSCORES ????//Zcard 命令用於計算集合中元素的數量 ????//ZCARD eth:blocks:candidates ????candidates := convertCandidateResults(cmds[3].(*redis.ZSliceCmd)) ????stats["candidates"] = candidates ????stats["candidatesTotal"] = cmds[6].(*redis.IntCmd).Val() ????//ZREVRANGE eth:blocks:immature 0 -1 WITHSCORES ????//ZCARD eth:blocks:immature ????immature := convertBlockResults(cmds[4].(*redis.ZSliceCmd)) ????stats["immature"] = immature ????stats["immatureTotal"] = cmds[7].(*redis.IntCmd).Val() ????//ZREVRANGE eth:blocks:matured 0 49 WITHSCORES ????//ZCARD eth:blocks:matured ????matured := convertBlockResults(cmds[5].(*redis.ZSliceCmd)) ????stats["matured"] = matured ????stats["maturedTotal"] = cmds[8].(*redis.IntCmd).Val() ????//ZREVRANGE eth:payments:all 0 49 WITHSCORES ????//ZCARD eth:payments:all ????payments := convertPaymentsResults(cmds[10].(*redis.ZSliceCmd)) ????stats["payments"] = payments ????stats["paymentsTotal"] = cmds[9].(*redis.IntCmd).Val() ????//顯示整個有序集成員 ????//ZRANGE eth:hashrate 0 -1 WITHSCORES ????totalHashrate, miners := convertMinersStats(window, cmds[1].(*redis.ZSliceCmd)) ????stats["miners"] = miners ????stats["minersTotal"] = len(miners) ????stats["hashrate"] = totalHashrate ????return stats, nil }
CollectLuckStats原理
//調取：stats["luck"], err = s.backend.CollectLuckStats(s.config.LuckWindow) //"luckWindow": [64, 128, 256], //Collect stats for shares/diff ratio for this number of blocks func (r *RedisClient) CollectLuckStats(windows []int) (map[string]interface{}, error) { ????//創建stats map ????stats := make(map[string]interface{}) ????tx := r.client.Multi() ????defer tx.Close() ????//max即256 ????max := int64(windows[len(windows)-1]) ????cmds, err := tx.Exec(func() error { ????????//Zrevrange 命令返回有序集中，指定區間內的成員 ????????//ZREVRANGE eth:blocks:immature 0 -1 WITHSCORES ????????tx.ZRevRangeWithScores(r.formatKey("blocks", "immature"), 0, -1) ???????? ????????//ZREVRANGE eth:blocks:matured 0 max-1 WITHSCORES ????????tx.ZRevRangeWithScores(r.formatKey("blocks", "matured"), 0, max-1) ????????return nil ????}) ????if err != nil { ????????return stats, err ????} ????//獲取blocks ????blocks := convertBlockResults(cmds[0].(*redis.ZSliceCmd), cmds[1].(*redis.ZSliceCmd)) ????calcLuck := func(max int) (int, float64, float64, float64) { ????????var total int ????????var sharesDiff, uncles, orphans float64 ????????for i, block := range blocks { ????????????if i > (max - 1) { ????????????????break ????????????} ????????????//叔塊 ????????????if block.Uncle { ????????????????uncles++ ????????????} ????????????//孤塊 ????????????if block.Orphan { ????????????????orphans++ ????????????} ????????????//shares/Diff ????????????sharesDiff += float64(block.TotalShares) / float64(block.Difficulty) ????????????//total計數 ????????????total++ ????????} ????????if total > 0 { ????????????//單塊平均shares/Diff ????????????sharesDiff /= float64(total) ????????????//uncles率 ????????????uncles /= float64(total) ????????????//孤塊率 ????????????orphans /= float64(total) ????????} ????????//返回total計數，平均shares/Diff，uncles率，孤塊率 ????????return total, sharesDiff, uncles, orphans ????} ???? ????//遍歷windows，逐一計算calcLuck，即最近64塊、128塊、256塊的數據統計 ????for _, max := range windows { ????????total, sharesDiff, uncleRate, orphanRate := calcLuck(max) ????????row := map[string]float64{ ????????????"luck": sharesDiff, "uncleRate": uncleRate, "orphanRate": orphanRate, ????????} ????????//寫入stats map ????????stats[strconv.Itoa(total)] = row ????????//計數不對 ????????if total < max { ????????????break ????????} ????} ????return stats, nil } func convertBlockResults(rows ...*redis.ZSliceCmd) []*BlockData { ????var result []*BlockData ????//遍歷rows ????for _, row := range rows { ????????//遍歷blocks ????????for _, v := range row.Val() { ????????????// "uncleHeight:orphan:nonce:blockHash:timestamp:diff:totalShares:rewardInWei" ????????????block := BlockData{} ????????????block.Height = int64(v.Score) ????????????block.RoundHeight = block.Height ????????????fields := strings.Split(v.Member.(string), ":") ????????????block.UncleHeight, _ = strconv.ParseInt(fields[0], 10, 64) ????????????block.Uncle = block.UncleHeight > 0 ????????????block.Orphan, _ = strconv.ParseBool(fields[1]) ????????????block.Nonce = fields[2] ????????????block.Hash = fields[3] ????????????block.Timestamp, _ = strconv.ParseInt(fields[4], 10, 64) ????????????block.Difficulty, _ = strconv.ParseInt(fields[5], 10, 64) ????????????block.TotalShares, _ = strconv.ParseInt(fields[6], 10, 64) ????????????block.RewardString = fields[7] ????????????block.ImmatureReward = fields[7] ????????????block.immatureKey = v.Member.(string) ????????????result = append(result, &block) ????????} ????} ????return result }
purgeStale原理
//config.PurgeInterval為FlushStaleStats定時器，時間為10分鐘
//調取：total, err := s.backend.FlushStaleStats(s.hashrateWindow, s.hashrateLargeWindow)
//s.hashrateWindow即cfg.HashrateWindow，即：為每個礦工估計算力的快速時間間隔，30分鐘
//s.hashrateLargeWindow即cfg.HashrateLargeWindow，即：長期和精確的hashrate時間間隔，3小時
func (r *RedisClient) FlushStaleStats(window, largeWindow time.Duration) (int64, error) {
????//換算成秒
????now := util.MakeTimestamp() / 1000
????
????//max即(now-window，即<(now-window
????max := fmt.Sprint("(", now-int64(window/time.Second))
????
????//Zremrangebyscore 命令用於移除有序集中，指定分數（score）區間內的所有成員
????//ZREMRANGEBYSCORE eth:hashrate -inf (now-window
????//慎重使用
????total, err := r.client.ZRemRangeByScore(r.formatKey("hashrate"), "-inf", max).Result()
????if err != nil {
????????return total, err
????}
????var c int64
????//創建map
????miners := make(map[string]struct{})
????//即(now-largeWindow，即<now-largeWindow
????max = fmt.Sprint("(", now-int64(largeWindow/time.Second))
????for {
????????var keys []string
????????var err error
????????
????????//SCAN 命令用於叠代當前數據庫中的數據庫鍵
????????//SCAN 0 MATCH eth:hashrate:* COUNT 100
????????//SCAN c MATCH eth:hashrate:* COUNT 100
????????c, keys, err = r.client.Scan(c, r.formatKey("hashrate", "*"), 100).Result()
????????if err != nil {
????????????return total, err
????????}
????????for _, row := range keys {
????????????//eth:hashrate:login中截取login
????????????login := strings.Split(row, ":")[2]
????????????//沒有處理過miners[login]
????????????if _, ok := miners[login]; !ok {
????????????????//Zremrangebyscore 命令用於移除有序集中，指定分數（score）區間內的所有成員
????????????????//ZREMRANGEBYSCORE eth:hashrate:login -inf (now-window
????????????????n, err := r.client.ZRemRangeByScore(r.formatKey("hashrate", login), "-inf", max).Result()
????????????????if err != nil {
????????????????????return total, err
????????????????}
????????????????//已處理的計入miners[login]
????????????????miners[login] = struct{}{}
????????????????//已處理的數量
????????????????total += n
????????????}
????????}
????????if c == 0 {
????????????break
????????}
????}
????return total, nil
}兄弟連區塊鏈教程open-ethereum-pool礦池源碼分析API分析