etcd-6-go与etcd-事务

一 etcd中的事务

二 示例

	// 第一步：加锁（创建租约，确保租约不过期，使用租约抢占key）

	// 申请一个5秒租约
	lease := clientv3.NewLease(cli)
	leaseR, err := lease.Grant(context.TODO(), 5)
	if err != nil {
		fmt.Println("lease err:", err)
		return
	}

	// 第三步中的释放锁 准备一个用于取消自动续租的context
	ctx, cancelFunc := context.WithCancel(context.TODO())
	defer cancelFunc()
	defer lease.Revoke(context.TODO(), leaseR.ID)		// 释放租约

	// 自动续租 返回值是个只读的chan，因为写入只能是etcd实现
	keepChan, err := lease.KeepAlive(ctx, leaseR.ID )
	if err != nil {
		fmt.Println("keep err:", err)
		return
	}
	// 启动一个协程去消费chan的应答
	go func(){
		for {
			select {
			case keepR := <- keepChan:
				if keepChan == nil {		// 此时系统异常或者主动取消context
					fmt.Println("租约失效")
					goto END
				} else {		// 每秒续租一次
					fmt.Println("收到自动续租应答：", keepR.ID)
				}
			}
		}
	END:
	}()

	// 使用事务判断key是否存在；判断其
	key := "/cron/lock/jobX"
	kv := clientv3.NewKV(cli)
	txn := kv.Txn(context.TODO())		// 分布式事务
	txn.If(clientv3.Compare(clientv3.CreateRevision(key), "=", 0)).
		Then(clientv3.OpPut(key, "xxx", clientv3.WithLease(leaseR.ID))).		// 一般这里val记录是哪个ID抢到
		Else(clientv3.OpGet(key))		// 否则抢锁失败

	// 提交事务
	txnR, err := txn.Commit()
	if err != nil {
		fmt.Println("txn失败:", err)
		return
	}
	// 判断是否抢到了锁
	if !txnR.Succeeded {
		fmt.Println("没抢到锁，锁已被占用；", string(txnR.Responses[0].GetResponseRange().Kvs[0].Value))
		return
	}

	// 第二步：业务代码书写
	fmt.Println("模拟处理任务")
	time.Sleep(time.Second * 5)

    // 第三步：释放锁（取消续租，释放租约）

多次执行上述方法，观察结果