nsub

README

nsub

nats的订阅消息客户端。

安装

go get -u github.com/zhufuyi/pkg/nats/nsub

使用示例

    var natsAddr = []string{"nats://192.168.101.88:4222"}

    // 初始化
    err := nsub.Init(natsAddr)
    
	topic := "foo.json"
	subData := make(chan []byte, 100)
	ctx, _ := context.WithTimeout(context.Background(), 20*time.Second)

	// 订阅
	go func() {
		nsub.GetClient().SubscribeSync(ctx, topic, subData)
	}()

	for {
		select {
		case msg := <-subData:
			fmt.Printf("[sub] %s\n\n", msg)
		case <-ctx.Done():
			return
		}
	}

Documentation

Index

• func Init(natsAddr []string) error
• type Client
  • func GetClient() *Client
  • func (c *Client) Close()
  • func (c *Client) SubscribeSync(ctx context.Context, topic string, pushData chan []byte)

Functions

func Init

func Init(natsAddr []string) error

Init nats初始化

Types

type Client

type Client struct {
	Conn *nats.Conn
}

Client nats连接套接字

func GetClient

func GetClient() *Client

GetClient 获取nats操作对象

func (*Client) Close

func (c *Client) Close()

Close 关闭

func (*Client) SubscribeSync

func (c *Client) SubscribeSync(ctx context.Context, topic string, pushData chan []byte)

SubscribeSync 同步订阅