如何使用 NSQ 搭建一个轻量级、高可靠的消息队列系统

2023-12-18 17:08:08

概述

消息队列是一种异步通信机制，它允许应用程序之间通过消息进行通信。消息队列可以帮助您解耦应用程序，使它们能够独立运行，并提高应用程序的可靠性和可扩展性。

NSQ 是一个轻量级、高可靠、分布式消息队列系统，它使用内存作为存储媒介，并提供丰富的 API，可以轻松地与各种编程语言集成。NSQ 非常适合构建高性能、低延迟的消息传递系统。

搭建步骤

1. 安装 NSQ

您可以通过以下命令安装 NSQ：

wget https://github.com/nsqio/nsq/releases/download/v0.3.8/nsq-0.3.8.linux-amd64.go1.12.1.tar.gz
tar -xvzf nsq-0.3.8.linux-amd64.go1.12.1.tar.gz
cd nsq-0.3.8.linux-amd64.go1.12.1

2. 启动 NSQ

您可以通过以下命令启动 NSQ：

./nsqd

3. 创建主题

您可以通过以下命令创建主题：

./nsqadmin create-topic my-topic

4. 发布消息

您可以通过以下命令发布消息：

./nsqpub -topic my-topic -message "Hello, world!"

5. 订阅主题

您可以通过以下命令订阅主题：

./nsqlookupd
./nsqconsumer -topic my-topic -channel my-channel

6. 消费消息

您可以通过以下命令消费消息：

./nsqtail -topic my-topic -channel my-channel

示例代码

以下是一些示例代码，供您参考：

import (
	"fmt"
	"github.com/nsqio/go-nsq"
)

// Producer 生产者
func Producer() {
	producer, err := nsq.NewProducer("127.0.0.1:4150", nsq.NewConfig())
	if err != nil {
		fmt.Println(err)
		return
	}
	defer producer.Stop()

	err = producer.Publish("my-topic", []byte("Hello, world!"))
	if err != nil {
		fmt.Println(err)
		return
	}
}

// Consumer 消费者
func Consumer() {
	consumer, err := nsq.NewConsumer("my-topic", "my-channel", nsq.NewConfig())
	if err != nil {
		fmt.Println(err)
		return
	}
	defer consumer.Stop()

	consumer.AddHandler(nsq.HandlerFunc(func(message *nsq.Message) error {
		fmt.Println(string(message.Body))
		return nil
	}))

	err = consumer.ConnectToNSQLookupd("127.0.0.1:4161")
	if err != nil {
		fmt.Println(err)
		return
	}
}