Golang如何连接NATS服务器？

连接NATS服务器时遇到连接超时问题，通常与网络配置或TLS设置有关。以下是几种连接NATS服务器的示例代码：

1. 基础连接（无TLS）：

package main

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

func main() {
	// 连接到NATS服务器
	nc, err := nats.Connect("nats://localhost:4222")
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()
	
	fmt.Println("Connected to NATS server")
}

2. 带选项的连接：

func main() {
	opts := []nats.Option{
		nats.Name("My NATS Client"),
		nats.MaxReconnects(10),
		nats.ReconnectWait(5 * time.Second),
	}
	
	nc, err := nats.Connect("nats://localhost:4222", opts...)
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()
	
	fmt.Println("Connected with custom options")
}

3. TLS连接（如果服务器启用了TLS）：

func main() {
	// 加载TLS配置
	tlsConfig := &tls.Config{
		InsecureSkipVerify: true, // 仅用于测试环境
	}
	
	nc, err := nats.Connect("tls://localhost:4222", 
		nats.Secure(tlsConfig))
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()
	
	fmt.Println("Connected via TLS")
}

4. 带认证的连接：

func main() {
	// Token认证
	nc, err := nats.Connect("nats://localhost:4222",
		nats.Token("my-token"))
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()
	
	// 或用户名/密码认证
	nc2, err := nats.Connect("nats://localhost:4222",
		nats.UserInfo("user", "password"))
	if err != nil {
		log.Fatal(err)
	}
	defer nc2.Close()
	
	fmt.Println("Connected with authentication")
}

5. 连接集群：

func main() {
	servers := []string{
		"nats://server1:4222",
		"nats://server2:4222",
		"nats://server3:4222",
	}
	
	nc, err := nats.Connect(strings.Join(servers, ","))
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()
	
	fmt.Println("Connected to NATS cluster")
}

6. 带连接状态处理的连接：

func main() {
	nc, err := nats.Connect("nats://localhost:4222",
		nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
			fmt.Printf("Disconnected: %v\n", err)
		}),
		nats.ReconnectHandler(func(nc *nats.Conn) {
			fmt.Println("Reconnected")
		}),
		nats.ClosedHandler(func(nc *nats.Conn) {
			fmt.Println("Connection closed")
		}))
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()
	
	fmt.Println("Connected with event handlers")
}

从错误信息看，连接超时可能是由于：

1. 服务器防火墙阻止了连接
2. NATS服务器配置了TLS但客户端未正确配置
3. Cloudflare代理可能修改了连接

建议先尝试本地NATS服务器连接测试：

func main() {
	// 测试本地连接
	nc, err := nats.Connect("nats://127.0.0.1:4222")
	if err != nil {
		fmt.Printf("Local connection failed: %v\n", err)
		
		// 尝试带超时的连接
		nc, err = nats.Connect("nats://localhost:4222",
			nats.Timeout(10*time.Second))
		if err != nil {
			log.Fatal(err)
		}
	}
	defer nc.Close()
	
	fmt.Printf("Connected to %s\n", nc.ConnectedUrl())
}

检查NATS服务器配置，确保监听地址正确且防火墙允许4222端口连接。