Publish Subscribe

使用 Docker 內建的 https://github.com/kimi0230/practise-gRPC-go/blob/master/demoDockerPubsub/main.go

簡單範例

package main

import (
    "fmt"
    "strings"
    "sync"
    "time"

    "github.com/moby/moby/pkg/pubsub"
)

func main() {
    p := pubsub.NewPublisher(100*time.Millisecond, 10)

    golang := p.SubscribeTopic(func(v interface{}) bool {
        if key, ok := v.(string); ok {
            if strings.HasPrefix(key, "golang:") {
                return true
            }
        }
        return false
    })
    docker := p.SubscribeTopic(func(v interface{}) bool {
        if key, ok := v.(string); ok {
            if strings.HasPrefix(key, "docker:") {
                return true
            }
        }
        return false
    })

    go p.Publish("hi")
    go p.Publish("golang: https://golang.org")
    go p.Publish("docker: https://www.docker.com/")
    time.Sleep(1 * time.Second)

    wg := sync.WaitGroup{}
    wg.Add(2)
    go func() {
        defer wg.Done()
        fmt.Println("golang topic:", <-golang)
    }()
    go func() {
        defer wg.Done()
        fmt.Println("docker topic:", <-docker)
    }()
    wg.Wait()
    fmt.Println("Done")
}

gRPC pub sub

• https://github.com/kimi0230/practise-gRPC-go/tree/master/gpubsub

Reference

• PubSub moby/pkg/pubsub