兄弟连区块链教程open-ethereum-pool矿池源码分析payouts模块

open-ethereum-pooleth矿池-payouts模块

PayoutsProcessor定义

type PayoutsProcessor struct {
    config *PayoutsConfig
    backend *storage.RedisClient
    rpc *rpc.RPCClient
    halt bool
    lastFail error
}

GetPendingPayments原理

func (r *RedisClient) GetPendingPayments() []*PendingPayment {
    //ZREVRANGE eth:payments:pending 0 -1 WITHSCORES
    raw := r.client.ZRevRangeWithScores(r.formatKey("payments", "pending"), 0, -1)
    var result []*PendingPayment
    for _, v := range raw.Val() {
        // timestamp -> "address:amount"
        payment := PendingPayment{}
        payment.Timestamp = int64(v.Score)
        fields := strings.Split(v.Member.(string), ":")
        payment.Address = fields[0]
        payment.Amount, _ = strconv.ParseInt(fields[1], 10, 64)
        result = append(result, &payment)
    }
    return result
}

GetPayees原理

func (r *RedisClient) GetPayees() ([]string, error) {
    payees := make(map[string]struct{})
    var result []string
    var c int64

    for {
        var keys []string
        var err error
        c, keys, err = r.client.Scan(c, r.formatKey("miners", "*"), 100).Result()
        if err != nil {
            return nil, err
        }
        for _, row := range keys {
            login := strings.Split(row, ":")[2]
            payees[login] = struct{}{}
        }
        if c == 0 {
            break
        }
    }
    for login, _ := range payees {
        result = append(result, login)
    }
    return result, nil
}

LockPayouts原理

func (r *RedisClient) LockPayouts(login string, amount int64) error {
    //eth:payments:lock
    key := r.formatKey("payments", "lock")

    //SETNX eth:payments:lock login:amount 0
    //Setnx(SET if Not eXists) 命令在指定的 key 不存在时,为 key 设置指定的值
    result := r.client.SetNX(key, join(login, amount), 0).Val()
    if !result {
        return fmt.Errorf("Unable to acquire lock ‘%s‘", key)
    }
    return nil
}

UpdateBalance原理

func (r *RedisClient) UpdateBalance(login string, amount int64) error {
tx := r.client.Multi()
defer tx.Close()

ts := util.MakeTimestamp() / 1000

_, err := tx.Exec(func() error {
                //Hincrby 命令用于为哈希表中的字段值加上指定增量值
                //HINCRBY eth:miners:login balance -amount
tx.HIncrBy(r.formatKey("miners", login), "balance", (amount * -1))

                //HINCRBY eth:miners:login pending amount
tx.HIncrBy(r.formatKey("miners", login), "pending", amount)

                //HINCRBY eth:finances balance -amount
tx.HIncrBy(r.formatKey("finances"), "balance", (amount * -1))

                //HINCRBY eth:finances pending amount
tx.HIncrBy(r.formatKey("finances"), "pending", amount)

                //ZADD eth:payments:pending ts login:amount
                //Zadd 命令用于将一个或多个成员元素及其分数值加入到有序集当中
tx.ZAdd(r.formatKey("payments", "pending"), redis.Z{Score: float64(ts), Member: join(login, amount)})
return nil
})
return err
}

RollbackBalance原理

func (r *RedisClient) RollbackBalance(login string, amount int64) error {
    tx := r.client.Multi()
    defer tx.Close()

    _, err := tx.Exec(func() error {
        tx.HIncrBy(r.formatKey("miners", login), "balance", amount)
        tx.HIncrBy(r.formatKey("miners", login), "pending", (amount * -1))
        tx.HIncrBy(r.formatKey("finances"), "balance", amount)
        tx.HIncrBy(r.formatKey("finances"), "pending", (amount * -1))
        tx.ZRem(r.formatKey("payments", "pending"), join(login, amount))
        return nil
    })
    return err
}

WritePayment原理

func (r *RedisClient) WritePayment(login, txHash string, amount int64) error {
    tx := r.client.Multi()
    defer tx.Close()

    ts := util.MakeTimestamp() / 1000

    _, err := tx.Exec(func() error {
        //HINCRBY eth:miners:login pending -amount
        tx.HIncrBy(r.formatKey("miners", login), "pending", (amount * -1))

        //HINCRBY eth:miners:login paid amount
        tx.HIncrBy(r.formatKey("miners", login), "paid", amount)

        //HINCRBY eth:finances pending -amount
        tx.HIncrBy(r.formatKey("finances"), "pending", (amount * -1))

        //HINCRBY eth:finances paid amount
        tx.HIncrBy(r.formatKey("finances"), "paid", amount)

        //ZADD eth:payments:all ts txHash:login:amount
        tx.ZAdd(r.formatKey("payments", "all"), redis.Z{Score: float64(ts), Member: join(txHash, login, amount)})

        //ZADD eth:payments:login ts txHash:amount
        tx.ZAdd(r.formatKey("payments", login), redis.Z{Score: float64(ts), Member: join(txHash, amount)})

        //ZREM eth:payments:pending login:amount
        //Zrem 命令 Redis 有序集合(sorted set) Redis Zrem 命令用于移除有序集中的一个或多个成员
        tx.ZRem(r.formatKey("payments", "pending"), join(login, amount))

        //DEL 命令用于删除已存在的键
        //DEL eth:payments:lock
        tx.Del(r.formatKey("payments", "lock"))
        return nil
    })
    return err
}

原文地址:http://blog.51cto.com/12918475/2298732

时间: 2024-09-29 16:23:39

兄弟连区块链教程open-ethereum-pool矿池源码分析payouts模块的相关文章

兄弟连区块链教程open-ethereum-pool矿池源码分析unlocker模块

兄弟连区块链教程open-ethereum-pool以太坊矿池源码分析unlocker模块open-ethereum-pool以太坊矿池-unlocker模块 unlocker模块配置 json"unlocker": {????"enabled": false,????"poolFee": 1.0,????"poolFeeAddress": "",????"donate": true,?

区块链教程btcpool矿池源码分析StratumServer模块解析

兄弟连区块链教程btcpool矿池源码分析StratumServer模块解析 核心机制总结 接收的job延迟超过60秒将丢弃 如果job中prevHash与本地job中prevHash不同,即为已产生新块,job中isClean状态将置为true????* true即要求矿机立即切换job 三种情况下将向矿机下发新job:???? 收到新高度的job???? 过去一个job为新高度且为空块job,且最新job为非空块job????* 达到预定的时间间隔30秒 最近一次下发job的时间将写入文件(

兄弟连区块链教程btcpool矿池源码分析BlockMaker模块解析

btcpool矿池-BlockMaker模块解析 核心机制总结 blkmaker可以连多个bitcoind节点 blkmaker监听和接收4类消息:RAWGBT.STRATUM_JOB.SOLVED_SHARE和NMC_SOLVED_SHARE 监听RAWGBT目的为获取gbtHash/交易列表,用于构建Block,gbtHash和vtxs写入rawGbtMap_??* rawGbtMap_保存最近100条gbtHash/vtxs对 监听STRATUMJOB目的为获取jobId/gbtHash,

兄弟连区块链教程open-ethereum-pool矿池源码分析policy模块

open-ethereum-pooleth矿池-policy模块 PolicyServer定义 type PolicyServer struct { sync.RWMutex statsMu sync.Mutex config *Config stats map[string]*Stats banChannel chan string startedAt int64 grace int64 timeout int64 blacklist []string whitelist []string s

兄弟连区块链教程btcpool矿池源码分析JobMaker模块解析

核心机制总结 同时监听kafka KAFKA_TOPIC_RAWGBT和KAFKA_TOPIC_NMC_AUXBLOCK,以支持混合挖矿 接收的Gbt消息,如果与本地时间延迟超过60秒将丢弃,如果延迟超过3秒将打印log 可用的Gbt消息,将以gbtTime+isEmptyBlock+height来构造key写入本地Map,另gbtHash也会写入本地队列 本地gbtHash队列仅保存最近20条,本地gbtMap中Gbt消息有效期:非空Gbt有效期90秒,空Gbt有效期15秒,过期将清除??*

区块链教程open-ethereum-pool矿池源码分析main入口

兄弟连区块链教程open-ethereum-pool矿池源码分析main入口,2018年下半年,区块链行业正逐渐褪去发展之初的浮躁.回归理性,表面上看相关人才需求与身价似乎正在回落.但事实上,正是初期泡沫的渐退,让人们更多的关注点放在了区块链真正的技术之上. open-ethereum-pool以太坊矿池-main入口 命令行启动 ./build/bin/open-ethereum-pool config.json config.json配置文件 { ????"threads": 2,

兄弟连区块链教程open-ethereum-pool矿池源码分析环境安装

安装Geth //安装parity cd /tmp/ wget d1h4xl4cr1h0mo.cloudfront.net/v1.8.11/x86_64-unknown-linux-gnu/parity_1.8.11_ubuntu_amd64.deb dpkg -i parity_1.8.11_ubuntu_amd64.deb //安装screen apt-get update apt-get -y install screen //启动parity screen parity --base-p

兄弟连区块链教程btcpool矿池源码分析核心机制总结及优化思考

btcpool矿池-核心机制总结及优化思考 核心机制总结 ①gbtmaker 监听Bitcoind ZMQ中BITCOIND_ZMQ_HASHBLOCK消息,一有新块产生,将立即向kafka发送新Gbt 另默认每5秒间隔(可从配置文件中指定)主动RPC请求Bitcoind,获取Gbt发送给kafka Gbt消息大小约2M,含交易列表 ②jobmaker 同时监听kafka KAFKA_TOPIC_RAWGBT和KAFKA_TOPIC_NMC_AUXBLOCK,以支持混合挖矿 接收的Gbt消息,如

兄弟连区块链教程open-ethereum-pool矿池源码分析API分析

ApiServer相关定义 type ApiConfig struct { Enabled bool `json:"enabled"` Listen string `json:"listen"` StatsCollectInterval string `json:"statsCollectInterval"` HashrateWindow string `json:"hashrateWindow"` HashrateLarge