[ChanBroker](https://github.com/myself659/ChanBroker)
https://github.com/myself659/ChanBroker
### Introduction
ChanBroker, a Broker for goroutine, is simliar to kafka
In ChanBroker has three types of goroutine:
- Producer
- Consumer(Subscriber)
- Broker
### Usage
code:
```
package main
import (
"fmt"
"github.com/myself659/ChanBroker"
"time"
)
type event struct {
id int
info string
}
func SubscriberDo(sub ChanBroker.Subscriber, b *ChanBroker.ChanBroker, id int) {
for {
select {
case c := <-sub:
switch t := c.(type) {
case event:
fmt.Println("SubscriberId:", id, " event:", t)
default:
}
}
}
}
func PublisherDo(b *ChanBroker.ChanBroker) {
ticker := time.NewTicker(time.Second)
i := 0
for range ticker.C {
ev := event{i, "event"}
b.PubContent(ev)
fmt.Println("Publisher:", ev)
i++
if 3 == i {
break
}
}
ticker.Stop()
b.StopBroker()
}
func main() {
// launch broker goroutine
b := ChanBroker.NewChanBroker(time.Second)
// register Subscriber and launch Subscriber goroutine
sub1, _ := b.RegSubscriber(1)
go SubscriberDo(sub1, b, 1)
sub2, _ := b.RegSubscriber(1)
go SubscriberDo(sub2, b, 2)
// launch Publisher goroutine
go PublisherDo(b)
// after 3.5s, exit process
<-time.After(3500 * time.Millisecond)
fmt.Println("exit")
}
```
output:
```
Publisher: {0 event}
SubscriberId: 1 event: {0 event}
SubscriberId: 2 event: {0 event}
Publisher: {1 event}
SubscriberId: 2 event: {1 event}
SubscriberId: 1 event: {1 event}
Publisher: {2 event}
SubscriberId: 2 event: {2 event}
SubscriberId: 1 event: {2 event}
exit
```
今日阅读排行
一周阅读排行