47 lines
820 B
Go
47 lines
820 B
Go
package main
|
||
|
||
import (
|
||
"fmt"
|
||
"math/rand"
|
||
"time"
|
||
)
|
||
|
||
// 现在有n个服务，每个服务都产生数据
|
||
// 产生数据就做处理
|
||
// 需要服务里有数据，就打印谁的
|
||
|
||
// 有个可变长度的 chan of string 遍历
|
||
func main() {
|
||
m1, m2, m3 := genMsg("service1"), genMsg("service2"), genMsg("service3")
|
||
m := merge(m1, m2, m3)
|
||
for {
|
||
fmt.Println(<-m)
|
||
}
|
||
}
|
||
|
||
func genMsg(name string) chan string {
|
||
c := make(chan string)
|
||
go func() {
|
||
i := 0
|
||
for {
|
||
time.Sleep(time.Duration(rand.Intn(2000)) * time.Millisecond)
|
||
c <- fmt.Sprintf("the service name is %v,the message is %v", name, i)
|
||
i++
|
||
}
|
||
}()
|
||
return c
|
||
}
|
||
|
||
func merge(chs ...chan string) chan string {
|
||
c := make(chan string)
|
||
for _, ch := range chs {
|
||
//copy := ch
|
||
go func(a chan string) {
|
||
for {
|
||
c <- <-a
|
||
}
|
||
}(ch)
|
||
}
|
||
return c
|
||
}
|