基于go-micro+etcd+gin微服务之服务注册与发现

etcd主要API

1.Put(key,value)/Delete(key)

$ ./bin/etcdctl put foo "Hello World!"
OK

$ ./bin/etcdctl del key
1

2.Get(key)/Get(keyFrom,keyEnd)

//第一种是指定单个 key 的查询，第二种是指定的一个 key 的范围；
./bin/etcdctl put web1 value1
$ ./bin/etcdctl put web2 value2
$ ./bin/etcdctl put web3 value3
$ ./bin/etcdctl get web --prefix  //根据前缀查询
web1
value1
web2
value2
web3
value3

3.Watch(key/keyPrefix)

//数据订阅,etcd 提供了 Watch 机制，我们可以利用 watch 实时订阅到 etcd 中增量的数据更新，watch 支持指定单个 key，也可以指定一个 key 的前缀,在实际应用场景中的通常会采用第二种形势

// 当 stock1 的数值改变（ put 方法）的时候，watch 会收到通知
$ ./bin/etcdctl watch stock1

// 新打开终端etcd
$ ./bin/etcdctl put stock1 1000

//在watch 终端显示
PUT
stock1
1000

//在watch终端中可以看到以stock为前缀的数值改变
$ ./bin/etcdctl watch stock --prefix
$ ./bin/etcdctl put stock1 10
$ ./bin/etcdctl put stock2 20

PUT
stock1
10
PUT
stock2
20

4.Transactions(if/then/else ops).Commit()

//事务操作。etcd 提供了一个简单的事务支持，用户可以通过指定一组条件满足时执行某些动作，当条件不成立的时候执行另一组操作，类似于代码中的 if else 语句，etcd 确保整个操作的原子性

$ ./bin/etcdctl put user1 bad
OK
$ ./bin/etcdctl txn --interactive  

compares:
// 输入以下内容，输入结束按 两次回车
value("user1") = "bad"      

//如果 user1 = bad，则执行 get user1 
success requests (get, put, del):
get user1

//如果 user1 != bad，则执行 put user1 good
failure requests (get, put, del):
put user1 good

// 运行结果，执行 success
SUCCESS

user1
bad

5.Leases:Grant/Revoke/KeepAlive

//设置访问的限制时间
$ ./bin/etcdctl lease grant 300
# lease 326963a02758b527 granted with TTL(300s)

//维持租约
$ ./bin/etcdctl lease keep-alive 326963a02758b520

//撤销租约
$ ./bin/etcdctl lease revoke 326963a02758b527
lease 326963a02758b527 revoked

客户端

//图片验证码
func GetImageCd(ctx *gin.Context) 
  uuid := ctx.Param("uuid")

  //指定consul
  consulService := micro.NewService(
    micro.Registry(etcd.NewRegistry(registry.Addrs("127.0.0.1:2379"))),
  )
  //调用函数 初始化客户端
  microClient := getCaptcha.NewGetCaptchaService("go.micro.service.getCaptcha", consulService.Client())

  resp, err := microClient.Call(context.TODO(), &getCaptcha.RequestUuid: uuid)
  if err != nil 
    fmt.Println("未找到远程服务。。")
    return
  
  //将得到的数据反序列化
  var img captcha.Image
  json.Unmarshal(resp.Img, &img)

  png.Encode(ctx.Writer, img)
  // fmt.Println(str)
  fmt.Println("uuid = ", uuid)

服务端

weifuwu/service/getCaptcha/proto/getCaptcha/getCaptcha.proto

//在终端输入 make proto生成proto文件
syntax = "proto3";

package go.micro.service.register;

option go_package = "/proto/register";

service Register 
  rpc Register(Request) returns (Response) ;


message Request 
  string mobile = 1;
  string password = 2;
  string sms_code = 3;


message Response 
  string errno = 1;
  string errmsg = 2;

weifuwu/service/getCaptcha/handler/getCaptcha.go

type GetCaptcha struct

// Call is a single request handler called via client.Call or the generated client code
func (e *GetCaptcha) Call(ctx context.Context, req *getCaptcha.Request, rsp *getCaptcha.Response) error 
	//log.Info("Received GetCaptcha.Call request")
	//rsp.Msg = "Hello " + req.Name

  //初始化对象
  cap := captcha.New()
  //设置字体
  cap.SetFont("./conf/comic.ttf")
  //设置干扰强度
  cap.SetDisturbance(captcha.MEDIUM)
  // 设置前景色
  cap.SetFrontColor(color.RGBA0,0,0, 255)
  // 设置背景色
  cap.SetBkgColor(color.RGBA100,0,255, 255, color.RGBA255,0,127, 255, color.RGBA255,255,10, 255)
  //生成字体
  img, str := cap.Create(4,captcha.NUM)

  //存储图片验证码到redis
  err := model.SaveImgCode(str,req.Uuid)
  if err != nil 
    return err
  

  //将生成的图片序列化
  imgBuf, _ := json.Marshal(img)

  //将imgBuf使用参数rsp穿出
  rsp.Img = imgBuf
	return nil

weifuwu/service/getCaptcha/model/modelFunc.go

//存储uuid和图片验证码到redis数据库
func SaveImgCode(code,uuid string) error 
  conn, err := redis.Dial("tcp","127.0.0.1:6379")
  if err != nil 
    fmt.Println("redis dial err:",err)
    return err
  
  defer conn.Close()
  //写数据 有效时间5分钟
  _, err = conn.Do("setex",uuid,60*5,code)
  return err