第一个NATS程序 - 元素码农

发布时间: 2025-04-07 18:04

↑

# 第一个NATS程序

在本文中，我们将学习如何创建和运行你的第一个NATS程序。通过简单的示例，你将了解NATS的基本工作原理和使用方法。

## 前提条件

在开始之前，请确保你已经：

1. 安装了NATS服务器（可以参考[Linux环境安装](/article/nats/setup/linux-install)或[Docker容器部署](/article/nats/setup/docker-deploy)）
2. 安装了适合你编程语言的NATS客户端库

## 选择编程语言

NATS支持多种编程语言，包括Go、Java、JavaScript、Python、Ruby等。在本教程中，我们将使用Go语言作为示例，但概念适用于所有语言。

## 创建发布者（Publisher）

首先，让我们创建一个简单的发布者程序，它将向NATS服务器发送消息：

```go
package main

import (
	"fmt"
	"log"
	"time"

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

func main() {
	// 连接到NATS服务器
	nc, err := nats.Connect(nats.DefaultURL) // 默认为"nats://localhost:4222"
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()

fmt.Println("已连接到NATS服务器")

// 发布消息
	subject := "greetings"
	message := "Hello, NATS World!"

err = nc.Publish(subject, []byte(message))
	if err != nil {
		log.Fatal(err)
	}

fmt.Printf("已发布消息到主题 '%s': %s\n", subject, message)

// 确保消息被发送出去
	nc.Flush()

if err := nc.LastError(); err != nil {
		log.Fatal(err)
	}
}
```

将此代码保存为`publisher.go`。

## 创建订阅者（Subscriber）

接下来，让我们创建一个订阅者程序，它将接收来自NATS服务器的消息：

```go
package main

import (
	"fmt"
	"log"
	"runtime"
	"time"

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

func main() {
	// 连接到NATS服务器
	nc, err := nats.Connect(nats.DefaultURL)
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()

fmt.Println("已连接到NATS服务器，等待消息...")

// 订阅主题
	subject := "greetings"
	sub, err := nc.Subscribe(subject, func(msg *nats.Msg) {
		fmt.Printf("收到消息: %s\n", string(msg.Data))
	})
	if err != nil {
		log.Fatal(err)
	}

// 确保订阅已建立
	nc.Flush()

if err := nc.LastError(); err != nil {
		log.Fatal(err)
	}

fmt.Printf("已订阅主题: %s\n", subject)

// 保持程序运行一段时间以接收消息
	runtime.Goexit() // 或使用 time.Sleep(time.Minute) 等待一段时间
}
```

将此代码保存为`subscriber.go`。

## 运行你的第一个NATS程序

1. 确保NATS服务器正在运行
2. 在一个终端窗口中运行订阅者：
   ```
   go run subscriber.go
   ```
3. 在另一个终端窗口中运行发布者：
   ```
   go run publisher.go
   ```

你应该会看到订阅者接收到发布者发送的消息。

## 理解发生了什么

1. **连接**：两个程序都使用`nats.Connect()`连接到本地运行的NATS服务器。
2. **订阅**：订阅者使用`nc.Subscribe()`方法订阅了名为"greetings"的主题，并提供了一个回调函数来处理接收到的消息。
3. **发布**：发布者使用`nc.Publish()`方法向"greetings"主题发送了一条消息。
4. **消息传递**：NATS服务器接收到发布者的消息，并将其转发给所有订阅该主题的订阅者。

## 进阶：请求-响应模式

NATS也支持请求-响应模式。以下是一个简单的示例：

### 响应者（Responder）

```go
package main

import (
	"fmt"
	"log"
	"runtime"

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

func main() {
	nc, err := nats.Connect(nats.DefaultURL)
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()

// 订阅请求主题
	_, err = nc.Subscribe("help.request", func(msg *nats.Msg) {
		fmt.Printf("收到请求: %s\n", string(msg.Data))
		
		// 发送响应
		response := fmt.Sprintf("这是对'%s'的回复", string(msg.Data))
		nc.Publish(msg.Reply, []byte(response))
	})
	if err != nil {
		log.Fatal(err)
	}

fmt.Println("响应者已准备好接收请求...")
	
	// 保持程序运行
	runtime.Goexit()
}
```

### 请求者（Requester）

```go
package main

import (
	"fmt"
	"log"
	"time"

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

func main() {
	nc, err := nats.Connect(nats.DefaultURL)
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()

// 发送请求并等待响应
	msg, err := nc.Request("help.request", []byte("我需要帮助"), 2*time.Second)
	if err != nil {
		log.Fatal(err)
	}

fmt.Printf("收到响应: %s\n", string(msg.Data))
}
```

## 常见问题解答

### 连接失败怎么办？

确保NATS服务器正在运行，并检查连接URL是否正确。默认URL是`nats://localhost:4222`。

### 如何处理连接断开？

NATS客户端库提供了重连功能和各种回调函数来处理连接状态变化：

```go
nc, err := nats.Connect(nats.DefaultURL,
	nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
		fmt.Printf("连接已断开: %v\n", err)
	}),
	nats.ReconnectHandler(func(nc *nats.Conn) {
		fmt.Printf("已重新连接到服务器: %v\n", nc.ConnectedUrl())
	}),
	nats.ClosedHandler(func(nc *nats.Conn) {
		fmt.Println("连接已关闭")
	}),
)
```

### 如何设置消息超时？

在请求-响应模式中，你可以设置等待响应的超时时间：

```go
// 等待响应，最多2秒
msg, err := nc.Request("help.request", []byte("我需要帮助"), 2*time.Second)
```

## 总结

恭喜！你已经成功创建并运行了你的第一个NATS程序。你学习了：

1. 如何连接到NATS服务器
2. 如何发布消息到主题
3. 如何订阅主题并接收消息
4. 如何使用请求-响应模式

这些基础知识将帮助你开始使用NATS构建分布式系统。随着你对NATS的深入了解，你将能够利用它的高性能、可靠性和灵活性来解决各种分布式通信挑战。

## 下一步

- 学习[消息收发演练](/article/nats/practice/messaging-demo)以深入了解更多NATS消息传递模式
- 探索[错误处理技巧](/article/nats/practice/error-handling)以构建更健壮的应用程序
- 了解[性能调优基础](/article/nats/practice/performance-tuning)以优化你的NATS应用程序