3Go SDK的使用

Nats系列文章链接：

代码

package main

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

func main() {
	// 建立连接
	nc, _ := nats.Connect(nats.DefaultURL)

	// 打开三个终端窗口，分别打开下面3个代码块的注释，并用go run运行代码

	// // 1.往主题发消息
	// nc.Publish("hello", []byte("from sdk"))

	// // 2.订阅主题
	// nc.Subscribe("hello", func(msg *nats.Msg) {
	// 	fmt.Println("收到的消息是：" + string(msg.Data))
	// })
	// runtime.Goexit()

	// // 3.订阅主题队列
	// nc.QueueSubscribe("hello", "q1", func(msg *nats.Msg) {
	// 	fmt.Println("从队列收到的消息是：" + string(msg.Data))
	// })
	// runtime.Goexit()
}

专题: nats

本文发表于 2022-01-01，最后修改于 2022-01-01。

本站永久域名「 jiavvc.top 」，也可搜索「后浪笔记一零二四」找到我。

上一篇 « 2安装及命令行基础功能使用下一篇 » 4主题(Subject)命名及通配符的使用

3Go SDK的使用

代码

推荐阅读