服务注册发现

type Registry interface {
	Init(...Option) error // ------------------------------- 模块初始化
	Options() Options // ----------------------------------- 模块的配置信息
	Register(context.Context, *Service, ...RegisterOption) error // --------- 注册服务
	Deregister(context.Context, *Service, ...DeregisterOption) error // ----- 注销服务
	GetService(context.Context,string, ...GetOption) ([]*Service, error) //- 根据名称查找服务
	ListServices(context.Context, ...ListOption) ([]*Service, error) // ----- 查询所有服务
	Watch(context.Context, ...WatchOption) (Watcher, error) // -------------- 监听服务变化
	String() string // ------------------------------------- 查询实现 Registry 接口的具体类型
}

package main

import (
	"github.com/vine-io/vine/core/registry"
	"github.com/vine-io/vine/core/registry/mdns"
)

func main() {
	// 创建新的 Registry
	r := mdns.NewRegistry()
	// 初始化
	if err := r.Init(); err != nil {
		log.Fatalln(err)
	}
}

func main() {
	// 创建新的服务
	svc := &registry.Service{
		Name:     "go.vine.test",   // 服务名称，唯一值
		Version:  "v1.0.0",         // 服务版本
		Metadata: map[string]string{"Content-Type": "application/json"},  // 元数据
		Endpoints: []*registry.Endpoint{        // 服务接口
			{
				Name:     "",
				Request:  nil,
				Response: nil,
				Metadata: nil,
			},
		},
		Nodes: []*registry.Node{     // 该服务下的节点信息, 节点的 ID 必须是不同的，当一个 `Registry` 中多次注册相同服务时，服务的该字段就会合并
			{
				Id:       uuid.New().String(),
				Address:  "127.0.0.1:11500",
				//Port:     11500,
				Metadata: map[string]string{"os": "linux"},
			},
		},
		TTL:  30,  // 服务过期时间，单位秒
		Apis: nil, // swagger 信息
	}

	// 注册服务
	ctx := context.TODO()
	if err := r.Register(ctx, svc); err != nil {
		log.Fatalln(err)
	}

	// 注销服务
	if err := r.Deregister(ctx, svc); err != nil {
		log.Fatalln(err)
	}
}

func main() {
	// 查询所有服务
	list, err := r.ListServices()
	if err != nil {
		log.Fatalln(err)
	}
	for _, item := range list {
		fmt.Println(item.Name)
	}

	// 查询单个服务
	ctx := context.TODO()
	list, err = r.GetService(ctx, "go.vine.test")
	if err != nil {
		log.Fatalln(err)
	}
	for _, item := range list {
		fmt.Println(item.Name, len(item.Nodes))
	}
}

func main() {
	// 启动一个监听器
	ctx := context.TODO()
	watcher, err := r.Watch(ctx, registry.WatchService("go.vine.test"))
	if err != nil {
		log.Fatalln(err)
	}
	// 停止监听器
	defer watcher.Stop()
	go func() {
		for {
			e, err := watcher.Next() // 这里会阻塞，直到返回事假
			if err != nil {
				return
			}
			fmt.Printf("%d: %s, %s\n",  e.Timestamp, e.Action, e.Service.Name)
		}
	}()
}

package main

import (
	"github.com/vine-io/vine"
	"github.com/vine-io/vine/core/registry/memory"
)

func main() {
	mr := memory.NewRegistry()
	vine.NewService(vine.Registry(mr))
}

memory.NewRegistry(
	// Registry 的 ip 地址
	registry.Addrs(addrs ...string),
	// 连接超时时间
	registry.Timeout(t time.Duration),
	// 安全通讯
	registry.Secure(b bool),
	// 安全通讯所需证书信息
	registry.TLSConfig(t *tls.Config),
)

memory.Register(svc,
	// 服务过期时间
	registry.RegisterTTL(ttl int64), 
	// 上下文信息
	registry.RegisterContext(ctx context.Context),
)

memory.Deregister(svc,
	registry.DeregisterContext(ctx context.Context),
)

memory.ListServices(svc,
	registry.ListServicesContext(ctx context.Context),
)

memory.GetService(svc,
	registry.GetServiceContext(ctx context.Context),
)

memory.Watch(svc,
    // 监听单个服务
	registry.WatchService(name string),
	registry.WatchServiceContext(ctx context.Context),
)

package main

import (
	"github.com/vine-io/vine"
	"github.com/vine-io/vine/lib/cmd"
	"github.com/vine-io/plugins/registry/etcd"
)
	
func main() {
	er := etcd.NewRegistry()
	vine.NewService(vine.Registry(er))
}

./helloworld --registy.default=etcd --registry.address=127.0.0.1:2379