如何在 Golang 框架中使用消息队列实现分布式系统

go get <a style=color:f60; text-decoration:underline; href="https://www.php.cn/zt/15841.html" target="_blank">git</a>hub.com/nats-io/nats-server/v2

go get github.com/nats-io/nats.go

// server.go 内容来自samhan666

package main copyright zvvq

import (

本文来自zvvq

"fmt" zvvq.cn

"log" 内容来自zvvq

"github.com/nats-io/nats-server/v2/server" 内容来自zvvq

)

func main() {

内容来自zvvq

// Create a new NATS server. 内容来自zvvq

opts := &server.Options{ zvvq好，好zvvq

Host: "0.0.0.0", zvvq好，好zvvq

Port: 4222, 内容来自samhan666

} 内容来自zvvq，别采集哟

s, err := server.NewServer(opts)

if err != nil {

内容来自samhan666

log.Fatal(err) 内容来自samhan666

} 内容来自zvvq，别采集哟

// Start the server. 内容来自samhan

if err := s.Start(); err != nil { zvvq好，好zvvq

log.Fatal(err)

} copyright zvvq

// Wait for the server to exit. 内容来自samhan

s.ReadyForConnections(nil)

zvvq.cn

s.Shutdown()

} 本文来自zvvq

// client.go

内容来自zvvq，别采集哟

package main 本文来自zvvq

import (

"fmt"

zvvq.cn

"log"

zvvq

"github.com/nats-io/nats.go"

)

func main() { zvvq.cn

// Connect to the NATS server.

nc, err := nats.Connect("nats://localhost:4222")

if err != nil {

内容来自zvvq，别采集哟

log.Fatal(err) 内容来自samhan

} zvvq好，好zvvq

// Publish a message to the "foo" topic.

本文来自zvvq

if err := nc.Publish("foo", []byte("Hello world!")); err != nil {

log.Fatal(err) 本文来自zvvq

}

// Subscribe to the "foo" topic.

sub, err := nc.Subscribe("foo", func(m nats.Msg) {

fmt.Printf("Received message: %s\n", string(m.Data)) 内容来自samhan

})

if err != nil { 内容来自samhan

log.Fatal(err)

}

// Block the main goroutine to wait for messages. zvvq.cn

sub.Unsubscribe()

}