开源软件名称:kaca
开源软件地址:https://gitee.com/scottkiss/kaca
开源软件介绍:
about kacaa pub/sub messaging system based on websocket Getting startedgo get github.com/scottkiss/kaca serverpackage mainimport ( "github.com/scottkiss/kaca" )func main() { //use true to set check origin kaca.ServeWs(":8080",true)} pub/sub clientpackage mainimport ( "fmt" "github.com/scottkiss/kaca" "time" )func main() { producer := kaca.NewClient(":8080", "ws") consumer := kaca.NewClient(":8080", "ws") consumer.Sub("say") consumer.Sub("you") consumer.ConsumeMessage(func(message string) { fmt.Println("consume =>" + message) }) time.Sleep(time.Second * time.Duration(2)) producer.Pub("you", "world") producer.Pub("say", "hello") time.Sleep(time.Second * time.Duration(2))} broadcast client}ckage mainimport ( "fmt" "github.com/scottkiss/kaca" "time" )func main() { producer := kaca.NewClient(":8080", "ws") consumer := kaca.NewClient(":8080", "ws") c2 := kaca.NewClient(":8080", "ws") c2.ConsumeMessage(func(message string) { fmt.Println("c2 consume =>" + message) }) consumer.Sub("say") consumer.Sub("you") consumer.ConsumeMessage(func(message string) { fmt.Println("consume =>" + message) }) time.Sleep(time.Second * time.Duration(2)) producer.Broadcast("broadcast...") time.Sleep(time.Second * time.Duration(2))})} |
请发表评论