Go语言：如何定义支持可变回调参数的Producer事件接口？

1. 这种接口设计是否有意义？ #

完全有意义。这种抽象能统一所有事件生产者的订阅行为，不管是生成生日事件的Human、检测湿度变化的传感器，还是推送邮件通知的服务器，都可以被当作Producer来处理。好处包括：

• 可以编写通用的订阅管理逻辑（比如批量添加/移除订阅者、统一启停事件推送），不用关心具体生产者的类型；
• 降低模块间耦合，依赖Producer接口而非具体实现，便于后续扩展新的生产者类型；
• 符合面向抽象编程的思想，让代码结构更清晰、可维护性更强。

唯一需要注意的是要平衡抽象性和类型安全——因为不同生产者的回调参数类型不同，需要用合适的方式在抽象接口中处理这种差异。

2. 如何实现这个Producer接口？ #

在Go 1.18及以上版本中，泛型是实现这种带类型差异的抽象接口的最优方案，既能保证统一的订阅行为，又能保留回调参数的类型安全。

步骤1：定义泛型Producer接口 #

// Producer 抽象所有可订阅的事件生产者，T为回调参数的类型
type Producer[T any] interface {
    // Subscribe 订阅事件，回调函数接收T类型的参数
    Subscribe(callback func(T))
}

步骤2：让Human实现该接口 #

基于你提供的代码，补充实现细节并适配泛型接口：

import (
    "fmt"
    "time"
)

type Human struct {
    name        string
    subscribers []func(Human)
}

func (h *Human) Init(name string) {
    h.name = name
    // 启动定时器，每100ms触发生日事件
    go func() {
        ticker := time.NewTicker(100 * time.Millisecond)
        defer ticker.Stop()
        for range ticker.C {
            h.notify()
        }
    }()
}

func (h *Human) String() string {
    return fmt.Sprintf("Human %s had a birthday event!\n", h.name)
}

// Subscribe 实现Producer[Human]接口
func (h *Human) Subscribe(callback func(Human)) {
    h.subscribers = append(h.subscribers, callback)
}

// notify 内部触发事件，通知所有订阅者
func (h *Human) notify() {
    for _, cb := range h.subscribers {
        cb(*h)
    }
}

步骤3：新增其他生产者示例（比如湿度传感器） #

验证接口的通用性，实现一个湿度传感器生产者：

import "math/rand"

type HumiditySensor struct {
    id              string
    currentHumidity float64
    subscribers     []func(HumiditySensor)
}

// Subscribe 实现Producer[HumiditySensor]接口
func (s *HumiditySensor) Subscribe(callback func(HumiditySensor)) {
    s.subscribers = append(s.subscribers, callback)
}

// StartMonitoring 模拟湿度变化，触发事件
func (s *HumiditySensor) StartMonitoring() {
    go func() {
        ticker := time.NewTicker(500 * time.Millisecond)
        defer ticker.Stop()
        for range ticker.C {
            // 随机模拟湿度变化
            s.currentHumidity += rand.Float64()*5 - 2.5
            if s.currentHumidity < 0 {
                s.currentHumidity = 0
            } else if s.currentHumidity > 100 {
                s.currentHumidity = 100
            }
            s.notify()
        }
    }()
}

func (s *HumiditySensor) notify() {
    for _, cb := range s.subscribers {
        cb(*s)
    }
}

备选方案：使用空接口（不推荐） #

如果你的项目无法使用泛型（Go版本低于1.18），可以用any（即interface{}）来定义接口，但会丢失编译期类型检查，需要在回调中手动断言类型：

type Producer interface {
    Subscribe(callback func(any))
}

// Human适配该接口的方式
func (h *Human) Subscribe(callback func(any)) {
    h.subscribers = append(h.subscribers, func(h Human) {
        callback(h)
    })
}

这种方式虽然能实现抽象，但容易引发类型断言错误，泛型方案更可靠。

内容的提问来源于stack exchange，提问作者tofgau