selector.md

服务中心

Dracarys默认使用consul作为服务中心。如果不进行配置，将默认使用consul。

配置

服务中心被Dracarys用作插件使用，所以服务中心的配置在插件配置中。

服务中心的配置参数如下：

name

服务中心名称，用于使用特定服务中心，默认为consul。

address

服务中心地址，服务中心所在的ip地址，默认为127.0.0.1:8500。

enable-heartbeat

心跳检测开关配置，默认为true，开启心跳检测。

scheme

协议名，服务中心中使用的协议，默认为http。

heartbeat

心跳配置：

• host: 本机host,用于服务中心向本机发送心跳检测，默认为server监听的ip。
• port：本机心跳程序使用port，默认为8001。
• timeout：心跳超时时间，默认为5s。
• interval：心跳检测间隔时间，默认为5s。
• deregister-critical-service-after：超时注销服务时间，默认为20s。

配置方法

Dracarys有两种方式进行配置，代码配置和全局配置

代码配置

示例：

// 先设置插件工厂配置
pluginOpts := []plugin.Option{
    plugin.WithSelectorName("your selector"),
    plugin.WithSelectorAddress("127.0.0.1:8888"),
}
// 将插件工厂配置放入客户端配置中
clientOpts := []client.Option{
    client.WithPluginFactoryOptions(pluginOpts),
}
client := dracarys.NewClient(clientOpts...)

全局配置

全局配置需要使用yml进行配置，详细参考全局配置。

自定义服务中心

Dracarys的所有插件都是可插拔的，服务中心也不例外。

如需使用自定义插件工厂，只需三个步骤。

1. 继承服务中心接口，实现方法。
2. 将服务中心注册到Dracarys中。
3. 插件工厂中放入自定义服务中心。

1.继承接口

type Selector interface {
    // 注册客户端
	RegisterClient(name, address string) error
    // 注册服务
	RegisterService(name, address string) error
    // 注册心跳
	RegisterHeartbeat()
    // 通过name获取服务结点
	Select(string) (*ServiceNodes, error)
    // 加载配置
	LoadConfig(*Options) error
}

自定义服务中心需继承以上接口才能使用。

2.注册插件

示例：

mySelector := NewSelector()
selector.Register("selectorName",mySelector)

即可将服务中心注册到Dracarys中。

3.加入插件

现在只需将插件配置到Dracarys即可。

配置方式见上文（配置）

服务中心名称改为当前自定义服务中心即可。

服务节点

Dracarys将从服务中心获取到的服务节点封装为了一个结构体：

// ServiceNodes 单个服务.
type ServiceNodes struct {
	// Name 服务名.
	Name string
	// Nodes 服务结点.
	Nodes []*Node
	// 结点数.
	Length int
	// LastTime 服务最后更新时间.
	LastTime time.Duration
	mu       sync.RWMutex
}

// Node 服务结点.
type Node struct {
	// Key   键: 服务名.
	Key string
	// Value 值: 结点ip地址.
	Value string
	// Blacklist 黑名单.
	Blacklist string
	// Whitelist 白名单.
	Whitelist string
	// Weight 权重.
	Weight float64
	// LastTime 最新更新时间.
	LastTime time.Duration
}

从接口Select即可得到ServiceNodes返回值。