插件注册机制（SPI）

go-wind-plugins 使用 Go 的 init() + blank import 机制实现 SPI（Service Provider Interface）自动注册，无需手动装配。

一、SPI 工作原理

二、Registry 设计

// bootstrap/registry/registry.go
package registry

// Transport 注册表
var transportFactories = map[string]TransportFactory{}

type TransportFactory func(opts ...transport.Option) transport.Server

func RegisterTransport(name string, factory TransportFactory) {
    transportFactories[name] = factory
}

func NewTransport(name string, opts ...transport.Option) (transport.Server, error) {
    factory, ok := transportFactories[name]
    if !ok {
        return nil, fmt.Errorf("unknown transport: %s", name)
    }
    return factory(opts...), nil
}

同理有 RegisterDatabase, RegisterCache, RegisterBroker, RegisterLog, RegisterConfig, RegisterRegistry 等。

三、插件注册示例

3.1 HTTP Transport

// plugins/transport/http/register.go
package http

import "github.com/tx7do/go-wind-bootstrap/registry"

func init() {
    registry.RegisterTransport("http", func(opts ...transport.Option) transport.Server {
        return NewServer(opts...)
    })
}

3.2 Redis Cache

// plugins/cache/redis/register.go
package redis

import "github.com/tx7do/go-wind-bootstrap/registry"

func init() {
    registry.RegisterCache("redis", func(opts ...Option) cache.Cache {
        return NewClient(opts...)
    })
}

3.3 MySQL Database

// plugins/database/mysql/register.go
package mysql

import "github.com/tx7do/go-wind-bootstrap/registry"

func init() {
    registry.RegisterDatabase("mysql", func(opts ...Option) (*ent.Client, error) {
        return NewClient(opts...)
    })
}

四、Blank Import

在 main.go 中通过 blank import（下划线导入）触发 init()：

package main

import (
    // Transport
    _ "github.com/tx7do/go-wind-plugins/transport/http"
    _ "github.com/tx7do/go-wind-plugins/transport/grpc"

    // Log
    _ "github.com/tx7do/go-wind-plugins/log/zap"

    // Database
    _ "github.com/tx7do/go-wind-plugins/database/mysql"

    // Cache
    _ "github.com/tx7do/go-wind-plugins/cache/redis"

    // Broker
    _ "github.com/tx7do/go-wind-plugins/broker/kafka"

    // Bootstrap
    "github.com/tx7do/go-wind-bootstrap"
)

func main() {
    app := bootstrap.New("config.yaml")
    app.Run()
}

不导入就不会注册，不会增加二进制体积。

五、按需加载

Go 没有 Java 的类加载器延迟加载机制，但 blank import 的好处是：

特性	说明
编译期确定	编译时就知道依赖了哪些插件
无反射	不依赖反射，性能高
二进制裁剪	不 import 的插件不会编译进二进制
显式声明	看一眼 import 就知道用了哪些插件

六、自定义插件注册

开发自己的插件并注册到 Registry：

package mycache

import (
    "github.com/tx7do/go-wind/cache"
    "github.com/tx7do/go-wind-bootstrap/registry"
)

type Cache struct { ... }

func NewCache(opts ...Option) cache.Cache {
    c := &Cache{}
    for _, opt := range opts { opt(c) }
    return c
}

// 注册
func init() {
    registry.RegisterCache("mycache", func(opts ...Option) cache.Cache {
        return NewCache(opts...)
    })
}

在 main.go 中：

import _ "myproject/plugins/mycache"

七、注册表一览

Registry 函数	注册对象	配置前缀
`RegisterTransport`	Transport Server	`server.*`
`RegisterLog`	Logger	`log.*`
`RegisterDatabase`	Ent Client	`database.*`
`RegisterCache`	Cache	`cache.*`
`RegisterBroker`	Broker	`broker.*`
`RegisterConfig`	Config Source	`config.*`
`RegisterRegistry`	Service Registry	`registry.*`
`RegisterTracer`	Tracer	`tracer.*`
`RegisterOSS`	Object Storage	`oss.*`
`RegisterMetrics`	Metrics	`metrics.*`
`RegisterAuth`	Authenticator	`auth.*`