53.go1.13 使用Etcd的问题

问题描述：

使用etcd报如下错误:

invalid operation: ev.Type == "go.etcd.io/etcd/mvcc/mvccpb".DELETE 
(mismatched types "github.com/coreos/etcd/mvcc/mvccpb".Event_EventType 
and "go.etcd.io/etcd/mvcc/mvccpb".Event_EventType)

invalid operation: ev.Type == "go.etcd.io/etcd/mvcc/mvccpb".PUT
 (mismatched types "github.com/coreos/etcd/mvcc/mvccpb".Event_EventType 
and "go.etcd.io/etcd/mvcc/mvccpb".Event_EventType)

我的代码：

/**
 *@Time    :2019/11/2022:58
 *@Author  :Shuai Jhou
 *@File    :config
 *@Software:GoLand
 */
package common

import (
    "context"
    "encoding/json"
    "fmt"
    "github.com/astaxie/beego"
    "github.com/astaxie/beego/logs"
    "go.etcd.io/etcd/mvcc/mvccpb"
    "sync"
    "time"
)

var (
    AppConfig = &Config{
        ProductConfigMap: make(map[int]*SeckillProductConfig, 1024),
    }
)

type Config struct {
    RunMode             string
    Log_level           string
    Log_path            string
    RedisAddr           string
    EtcdAddr            string
    EtcdSeckillKey      string
    ProductConfigMap    map[int]*SeckillProductConfig
    ProductConfigRwLock sync.RWMutex
}

type SeckillProductConfig struct {
    ProductId int `json:"product_id"`
    StartTime int `json:"start_time"`
    EndTime   int `json:"end_time"`
    Status    int `json:"status"`
    Total     int `json:"total"`
    Free      int `json:"free"`
    Used      int `json:"used"`
}

// 初始化系统配置
func InitConfig() (err error) {
    runmode := beego.AppConfig.String("runmode")
    if len(runmode) == 0 {
        err = fmt.Errorf("[InitConfig]RunMode config[%v] err ", runmode)
        return
    }
    AppConfig.RunMode = runmode

    AppConfig.Log_level = beego.AppConfig.String("log_level")
    if len(AppConfig.Log_level) == 0 {
        AppConfig.Log_level = "debug"
    }

    AppConfig.Log_path = beego.AppConfig.String("log_path")
    if len(AppConfig.Log_path) == 0 {
        AppConfig.Log_path = "./logs/system.log"
    }

    redisAddr := beego.AppConfig.String("redisAddr")
    etcdAddr := beego.AppConfig.String("etcdAddr")
    etcdSeckillKey := beego.AppConfig.String("etcdSeckillKey")

    if len(redisAddr) == 0 || len(etcdAddr) == 0 || len(etcdSeckillKey) == 0 {
        err = fmt.Errorf("[InitConfig]redis config[%v] err or etcd config[%v] err or etcdSeckillKey config[%v]err",
            redisAddr, etcdAddr, etcdSeckillKey)
        return
    }

    AppConfig.EtcdAddr = etcdAddr
    AppConfig.RedisAddr = redisAddr
    AppConfig.EtcdSeckillKey = etcdSeckillKey

    logs.Debug("Redis:%v,Etcd:%v,EtcdSeckillKey:%v", redisAddr, etcdAddr, etcdSeckillKey)
    return
}

// 加载商品秒杀活动配置
func LoadSeckillConfig() (err error) {
    key := fmt.Sprintf("%s/Product", AppConfig.EtcdSeckillKey)
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    resp, err := EtcdClient.Get(ctx, key)
    cancel()
    if err != nil {
        logs.Error("Get[%s] from etcd failed, err:%v", key, err)
        return
    }

    var seckillProductConfig []SeckillProductConfig
    for _, ev := range resp.Kvs {
        logs.Debug("Key[%s] Value:%s", ev.Key, ev.Value)
        err = json.Unmarshal(ev.Value, &seckillProductConfig)
        if err != nil {
            logs.Error("json.Unmarshal failed,Key[%s] Value:%s err:%v", ev.Key, ev.Value, err)
            return
        }
        logs.Debug("seckillInfoConfig:%v", seckillProductConfig)

    }
    // 更新配置
    UpdateSeckillProductConfig(seckillProductConfig)

    return
}

//初始化一个监控商品配置的线程。配置发送变化，实时通知，修改配置
func InitSeckillConfigWatch() {
    go watchSeckillConfig()
}

// 监控 配置文件是否变化，实时更新配置
func watchSeckillConfig() {
    var flag = true
    key := fmt.Sprintf("%s/Product", AppConfig.EtcdSeckillKey)
    var seckillProductConfig []SeckillProductConfig
    rch := EtcdClient.Watch(context.Background(), key)
    for wresp := range rch {
        for _, ev := range wresp.Events {
            logs.Warn("Type: %s Key:%s Value:%v", ev.Type, ev.Kv.Key, ev.Kv.Value)
            if ev.Type == mvccpb.DELETE {
                logs.Warn("key[%s] config delete ", key)
                continue
            }

            if ev.Type == mvccpb.PUT && string(ev.Kv.Key) == key {
                err := json.Unmarshal(ev.Kv.Value, &seckillProductConfig)
                if err != nil {
                    logs.Error("json.Unmarshal key[%s] err:%v", key, ev.Kv.Value)
                    flag = false
                    continue
                }
            }

        }

        if flag {
            // 更新配置
            UpdateSeckillProductConfig(seckillProductConfig)
        }

    }
}

// 更新配置
func UpdateSeckillProductConfig(seckillProductConfig []SeckillProductConfig) {
    // 1、先用临时变量存储
    var tmp map[int]*SeckillProductConfig = make(map[int]*SeckillProductConfig, 1024)
    for _, v := range seckillProductConfig {
        tmp[v.ProductId] = &v
    }

    // 2、再加锁 更新配置
    AppConfig.ProductConfigRwLock.Lock()
    AppConfig.ProductConfigMap = tmp
    AppConfig.ProductConfigRwLock.Unlock()
}

问题解决方法：

import 的 go.etcd.io/etcd/clientv3 引用的是 go.etcd.io/etcd/mvcc/mvccpb, 
但是在  
（if ev.Type == mvccpb.DELETE） 和
（if ev.Type == mvccpb.PUT && string(ev.Kv.Key) == key）
应用了 github.com/coreos/etcd/mvcc/mvccpb

代码如下：

/**
 *@Time    :2019/11/2022:58
 *@Author  :Shuai Jhou
 *@File    :config
 *@Software:GoLand
 */
package common

import (
    "context"
    "encoding/json"
    "fmt"
    "github.com/astaxie/beego"
    "github.com/astaxie/beego/logs"
    "github.com/coreos/etcd/mvcc/mvccpb"
    "sync"
    "time"
)

var (
    AppConfig = &Config{
        ProductConfigMap: make(map[int]*SeckillProductConfig, 1024),
    }
)

type Config struct {
    RunMode             string
    Log_level           string
    Log_path            string
    RedisAddr           string
    EtcdAddr            string
    EtcdSeckillKey      string
    ProductConfigMap    map[int]*SeckillProductConfig
    ProductConfigRwLock sync.RWMutex
}

type SeckillProductConfig struct {
    ProductId int `json:"product_id"`
    StartTime int `json:"start_time"`
    EndTime   int `json:"end_time"`
    Status    int `json:"status"`
    Total     int `json:"total"`
    Free      int `json:"free"`
    Used      int `json:"used"`
}

// 初始化系统配置
func InitConfig() (err error) {
    runmode := beego.AppConfig.String("runmode")
    if len(runmode) == 0 {
        err = fmt.Errorf("[InitConfig]RunMode config[%v] err ", runmode)
        return
    }
    AppConfig.RunMode = runmode

    AppConfig.Log_level = beego.AppConfig.String("log_level")
    if len(AppConfig.Log_level) == 0 {
        AppConfig.Log_level = "debug"
    }

    AppConfig.Log_path = beego.AppConfig.String("log_path")
    if len(AppConfig.Log_path) == 0 {
        AppConfig.Log_path = "./logs/system.log"
    }

    redisAddr := beego.AppConfig.String("redisAddr")
    etcdAddr := beego.AppConfig.String("etcdAddr")
    etcdSeckillKey := beego.AppConfig.String("etcdSeckillKey")

    if len(redisAddr) == 0 || len(etcdAddr) == 0 || len(etcdSeckillKey) == 0 {
        err = fmt.Errorf("[InitConfig]redis config[%v] err or etcd config[%v] err or etcdSeckillKey config[%v]err",
            redisAddr, etcdAddr, etcdSeckillKey)
        return
    }

    AppConfig.EtcdAddr = etcdAddr
    AppConfig.RedisAddr = redisAddr
    AppConfig.EtcdSeckillKey = etcdSeckillKey

    logs.Debug("Redis:%v,Etcd:%v,EtcdSeckillKey:%v", redisAddr, etcdAddr, etcdSeckillKey)
    return
}

// 加载商品秒杀活动配置
func LoadSeckillConfig() (err error) {
    key := fmt.Sprintf("%s/Product", AppConfig.EtcdSeckillKey)
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    resp, err := EtcdClient.Get(ctx, key)
    cancel()
    if err != nil {
        logs.Error("Get[%s] from etcd failed, err:%v", key, err)
        return
    }

    var seckillProductConfig []SeckillProductConfig
    for _, ev := range resp.Kvs {
        logs.Debug("Key[%s] Value:%s", ev.Key, ev.Value)
        err = json.Unmarshal(ev.Value, &seckillProductConfig)
        if err != nil {
            logs.Error("json.Unmarshal failed,Key[%s] Value:%s err:%v", ev.Key, ev.Value, err)
            return
        }
        logs.Debug("seckillInfoConfig:%v", seckillProductConfig)

    }
    // 更新配置
    UpdateSeckillProductConfig(seckillProductConfig)

    return
}

//初始化一个监控商品配置的线程。配置发送变化，实时通知，修改配置
func InitSeckillConfigWatch() {
    go watchSeckillConfig()
}

// 监控 配置文件是否变化，实时更新配置
func watchSeckillConfig() {
    var flag = true
    key := fmt.Sprintf("%s/Product", AppConfig.EtcdSeckillKey)
    var seckillProductConfig []SeckillProductConfig
    rch := EtcdClient.Watch(context.Background(), key)
    for wresp := range rch {
        for _, ev := range wresp.Events {
            logs.Warn("Type: %s Key:%s Value:%v", ev.Type, ev.Kv.Key, ev.Kv.Value)
            if ev.Type == mvccpb.DELETE {
                logs.Warn("key[%s] config delete ", key)
                continue
            }

            if ev.Type == mvccpb.PUT && string(ev.Kv.Key) == key {
                err := json.Unmarshal(ev.Kv.Value, &seckillProductConfig)
                if err != nil {
                    logs.Error("json.Unmarshal key[%s] err:%v", key, ev.Kv.Value)
                    flag = false
                    continue
                }
            }

        }

        if flag {
            // 更新配置
            UpdateSeckillProductConfig(seckillProductConfig)
        }

    }
}

// 更新配置
func UpdateSeckillProductConfig(seckillProductConfig []SeckillProductConfig) {
    // 1、先用临时变量存储
    var tmp map[int]*SeckillProductConfig = make(map[int]*SeckillProductConfig, 1024)
    for _, v := range seckillProductConfig {
        tmp[v.ProductId] = &v
    }

    // 2、再加锁 更新配置
    AppConfig.ProductConfigRwLock.Lock()
    AppConfig.ProductConfigMap = tmp
    AppConfig.ProductConfigRwLock.Unlock()
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 194,242评论 5赞 459
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 81,769评论 2赞 371
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 141,484评论 0赞 319
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 52,133评论 1赞 263
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 61,007评论 4赞 355
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 46,080评论 1赞 272
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 36,496评论 3赞 381
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 35,190评论 0赞 253
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 39,464评论 1赞 290
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,549评论 2赞 309
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,330评论 1赞 326
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 32,205评论 3赞 312
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 37,567评论 3赞 298
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,889评论 0赞 17
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,160评论 1赞 250
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 41,475评论 2赞 341
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 40,650评论 2赞 335