golang nsq.Producer

在 Golang 中使用 nsq.Producer 来创建一个 NSQ 生产者的示例代码如下：

"log"
"github.com/nsqio/go-nsq"
)

func main() {
// 创建一个配置对象	config := nsq.NewConfig()

// 创建一个生产者对象producer, err := nsq.NewProducer("localhost:4150", config)
	if err != nil {
	log.Fatal(err)
}

// 发布消息	err = producer.Publish("topic", []byte("Hello NSQ!"))
	if err != nil {
	log.Fatal(err)
}

// 关闭生产者连接producer.Stop()
}

在这个示例中，我们首先创建了一个配置对象 `config`，然后使用 `nsq.NewProducer` 函数创建了一个生产者对象 `producer`。我们将 NSQ 的地址和端口作为参数传递给 `NewProducer` 函数。

然后，我们使用 `producer.Publish` 函数发布一条消息到指定的主题（topic）。在这个示例中，我们发布的消息是字符串 "Hello NSQ!"，通过将其转换为字节数组（[]byte）进行传递。

最后，我们使用 `producer.Stop` 函数关闭生产者连接。这是一个很重要的步骤，确保在程序结束时正确关闭与 NSQ 的连接，释放相关资源。