简介

zk同etcd一样,存储数据格式均采用key-value类型,而我们在进行微服务开发时,这两者大部分的应用场景都是应用在服务发现以及服务配置上。

流程

基于zk的服务注册与发现大致流程如下:
zk_found
如:A、B两个服务均在内网环境,A需要向B发起接口调用,A需要从本地的缓存中获取出B对应的调用ip:port信息,然后向B发起调用。A中的缓存是A服务在启动时就开启了一个协成或线程用于从zk中拉取或监听服务数据,而zk的服务数据是通过B在启动时开启了一个TCP长连接向zk进行的服务注册。

实现

整个流程相对简单,以下为服务发现的监听测源码,该源码依赖

package main

import (
	"fmt"
	"time"

	"github.com/samuel/go-zookeeper/zk"
)

var (
	path = "/entry/test"
)

func main() {
	c, _, err := zk.Connect([]string{"172.16.1.49:8080"}, 1*time.Second)
	if err != nil {
		panic(err)
	}
	defer c.Close()

	for {
		_, _, event, err := c.ChildrenW(path)
		if err != nil {
			panic(err)
		}
		evt := <-event
		if evt.Err != nil {
			panic(evt.Err)
		}

		// 从新获取一遍目录下的节点
		children, _, err := c.Children(path)
		if err != nil {
			panic(err)
		}
		fmt.Println(children)
		// TODO
		// 针对一些拉取到的配置进行本地缓存等操作
		// bts, _, err = c.Get(path)
	}
}

其中,event的类型

type Event struct {
	Type   EventType
	State  State
	Path   string // For non-session events, the path of the watched node.
	Err    error
	Server string // For connection events
}
...
var (
	eventNames = map[EventType]string{
		EventNodeCreated:         "EventNodeCreated",
		EventNodeDeleted:         "EventNodeDeleted",
		EventNodeDataChanged:     "EventNodeDataChanged",
		EventNodeChildrenChanged: "EventNodeChildrenChanged",
		EventSession:             "EventSession",
		EventNotWatching:         "EventNotWatching",
	}
)

服务注册比较简单,同样使用上面的zk库,往指定路径调用Create方法,放进需要存放的数据即可,如有必要后续再更新注册代码吧

© 2019·蜀ICP备18036663号-1 · 本页总阅读量 · 本站总访问量 · 本站总访客数