发布订阅

在程序开发过程中，发布订阅模式是常见的一种架构设计，通过一个消息代理，可以完美解耦各系统服务之间的依赖关系。
在一些系统内部，也经常需要通过发布订阅这种模式，来降低各个组件的复杂性和依赖性，增加可拓展性。

但工作中用的更多的是系统服务级别的解耦与拆分，如引入rabbitmq、kafka等。在程序设计中使用的反而较少。

接下来主要介绍下golang实现的，基于标签体系的发布订阅机制。

gonal

先来看下实例

复制以下代码，然后执行go mod vendor下载依赖，运行。

package main

import (
    "context"
    "fmt"
    "github.com/czasg/gonal"
    "time"
)

func worker1(ctx context.Context, payload gonal.Payload) {
    fmt.Println("触发worker1", payload.Label)
}

func worker2(ctx context.Context, payload gonal.Payload) {
    fmt.Println("触发worker2", payload.Label)
}

func main() {
    // 绑定任务
    gonal.Bind(worker1, gonal.Label{
        "meta.type": "worker",
        "meta.name": "worker1",
    })
    gonal.Bind(worker2, gonal.Label{
        "meta.type": "worker",
        "meta.name": "worker2",
    })

    // 循环触发任务
    count := 0
    for {
        for _, label := range []gonal.Label{
            {"meta.type": "worker"},  // 该标签触发两个函数
            {"meta.name": "worker1"}, // 该标签触发worker1
            {"meta.name": "worker2"}, // 该标签触发worker2
        } {
            count++
            countStr := fmt.Sprintf("%d", count)
            label["count"] = countStr
            _ = gonal.Notify(gonal.Payload{
                Label: label,
                Body:  []byte(countStr),
            })
            time.Sleep(time.Second * 5)
        }
    }
}

在代码中我们可以明显看到两个操作：
1、基于标签注册函数
2、基于标签发布数据

其内部依赖github.com/czasg/go-queue实现的FIFO内存队列，并实现了并发限制，有兴趣可以去看下源码实现