美文网首页程序员
golang nats[2] 发布订阅模式

golang nats[2] 发布订阅模式

作者: luckyase | 来源:发表于2018-08-17 16:20 被阅读2次

发布订阅-模式

要求:发布消息时,订阅者必须已经完成订阅且处于激活状态。
注意:nc.Subscribe这个方法不是同步的。

订阅模式分为2种
异步:注册回调方法,收到消息时被调用。
同步:订阅者会阻塞,可以设置超时时间,超时后,将继续执行后续代码,一般会有err。

3个Server, s1,s2,s3
每个Server有同步,异步两种方式的订阅者各1个
一个Client,发布4条消息
每个Server的同步,异步订阅者,都会收到4条消息

类似:发布广播,所有的订阅者都会收到消息。消息会被所有的订阅者消费。

**如果要实现,一个主题,N个订阅者,一条消息,只会被一个订阅者消费,需要订阅者自行判断,因为在此模式下,所有的订阅者都会收到消息。或者采用queue模式,请看这里

package main

import (
    "github.com/nats-io/go-nats"
    "log"
    "fmt"
    "time"
)

const (
    url  = "nats://192.168.3.125:4222"
    subj = "weather"
)

var (
    nc  *nats.Conn
    err error
)

func init() {
    if nc, err = nats.Connect(url); checkErr(err) {
        //
    }
}

func main() {

    startServer(subj, "s1")
    startServer(subj, "s2")
    startServer(subj, "s3")
    //wait for subscribe complete
    time.Sleep(1 * time.Second)

    startClient(subj)

    select {}
}

//send message to server
func startClient(subj string) {
    nc.Publish(subj, []byte("Sun"))
    nc.Publish(subj, []byte("Rain"))
    nc.Publish(subj, []byte("Fog"))
    nc.Publish(subj, []byte("Cloudy"))
}

//receive message
func startServer(subj, name string) {
    go sync(nc, subj, name)
    go async(nc, subj, name)
}

func async(nc *nats.Conn, subj, name string) {
    nc.Subscribe(subj, func(msg *nats.Msg) {
        fmt.Println(name, "Received a message From Async : ", string(msg.Data))
    })
}

func sync(nc *nats.Conn, subj, name string) {
    subscription, err := nc.SubscribeSync(subj)
    checkErr(err)
    if msg, err := subscription.NextMsg(10 * time.Second); checkErr(err) {
        if msg != nil {
            fmt.Println(name, "Received a message From Sync : ", string(msg.Data))
        }
    } else {
        //handle timeout
    }

}

func checkErr(err error) bool {
    if err != nil {
        log.Fatal(err)
        return false
    }
    return true
}


注意:发布订阅模式,依赖tcp协议的可靠性,保证消息最多发送一次。如果需要更可靠的模式,请参考NATS Streaming

相关文章

  • golang nats[2] 发布订阅模式

    发布订阅-模式 要求:发布消息时,订阅者必须已经完成订阅且处于激活状态。注意:nc.Subscribe这个方法不是...

  • golang nats[4] request reply模式

    请求响应模式 无论是发布订阅模式还是queue模式,nats都不能保证消息一定发送到订阅方,除非订阅者发送一个响应...

  • golang nats[5] cluster集群

    集群模式 nats的集群模式对客户端来说并不是透明的。所以集群对发布者和订阅者都是有影响的。发布者和订阅者都知道连...

  • Golang RabbitMQ发布订阅模式(广播模式、fanou

    golang RabbitMQ发布订阅模式(广播模式、fanout模式),就是一个生产者发送的消息会被多个消费者处...

  • 常见设计模式

    1. 写出 构造函数模式、混合模式、模块模式、工厂模式、单例模式、发布订阅模式的范例。 2. 使用发布订阅模式写一...

  • 发布订阅模式(观察者模式)

    发布订阅模式(观察者模式) 发布订阅也叫观察者模式 发布 && 订阅 使用

  • 前端设计模式

    1,写出 构造函数模式、混合模式、模块模式、工厂模式、单例模式、发布订阅模式的范例。 2,使用发布订阅模式写一个事...

  • 消息中间件 NATS 集群的构建与使用

    NATS 是一个开源的、轻量级的、高性能的分布式消息通信系统,实现了高可伸缩性和优雅的发布/订阅模型。NATS 适...

  • 设计模式之发布订阅模式(1) 一文搞懂发布订阅模式

    目录 发布/订阅者模式的优点 实现发布/订阅者模式需要考虑的点 何时应使用发布/订阅者模式 发布/订阅者模式与观察...

  • JS-简单实现发布订阅模式

    发布订阅模式主要涉及三个对象:发布者、订阅者、主题对象。 发布-订阅模式 定义  发布-订阅模式又称观察者模式,它...

网友评论

    本文标题:golang nats[2] 发布订阅模式

    本文链接:https://www.haomeiwen.com/subject/mlhtiftx.html