t4_c7_nets_broker

README

NATs Pubsub

本篇演示如何使用NATs消息中间件来编写Micro的Pubsub服务，原稿由Bruce Wang提供，略作删改。

预置条件

安装NatsServer，教程参考，安装NATs Server

然后运行NATs服务（操作系统不一运行指令不一样）。

nats-server

目录

• cli 客户端
• srv 服务端

运行示例服务

先打开一个终端窗口，切到我们的示例服务目录：

cd srv
go run main.go --broker=nats --broker_address=127.0.0.1:4222

再打开一个终端窗口，切到我们的示例客户端目录：

cd cli
go run main.go --broker=nats --broker_address=127.0.0.1:4222

然后我们可以在两个窗口中看到打印的信息：

cli 窗口

2019/08/01 14:07:14 publishing {Id:9beb1a7e-b422-11e9-92ac-acde48001122 Timestamp:1564639634 Message:如果你看到了消息 go.micro.pubsub.topic.event, '那是因为我一直爱着你 XXX_NoUnkeyedLiteral:{} XXX_unrecognized:[] XXX_sizecache:0}
...

srv 窗口

2019/08/01 14:07:09 [sub] 收到消息，请查收: map[id:3], {"id":"98f050d2-b422-11e9-92ac-acde48001122","timestamp":1564639629,"message":"如果你看到了消息 go.micro.pubsub.topic.event, '那是因为我一直爱着你"}
...

Thanks: https://github.com/BruceWangNo1/go-micro-pubsub-with-nats

Documentation

Index

• Variables
• func CliMain()
• func GetBroker() broker.Broker
• func SendEvent(bk broker.Broker)
• func StartBroker() broker.Broker
• func XXtopic() map[string]broker.Handler
• type UserMessage
  • func (receiver *UserMessage) Action(action string, msg string)
  • func (receiver *UserMessage) Tojson() []byte

Variables

var (
	XXtopic_register = "my.micro.topic.user.register"
	XXtopic_login    = "my.micro.topic.user.login"
	XXtopic_lock     = "my.micro.topic.user.lock"
)

Functions

func CliMain

func CliMain()

func GetBroker

func GetBroker() broker.Broker

func SendEvent

func SendEvent(bk broker.Broker)

func StartBroker

func StartBroker() broker.Broker

func XXtopic

func XXtopic() map[string]broker.Handler

Types

type UserMessage

type UserMessage struct {
	Id int
	// 用户注册 用户登陆 用户锁定
	ActionName string
	Msgtext    string
	Timestamp  int64
}

func (*UserMessage) Action

func (receiver *UserMessage) Action(action string, msg string)

func (*UserMessage) Tojson

func (receiver *UserMessage) Tojson() []byte