准备工作
在开始之前，我们需要进行一些准备工作。首先，我们需要在机器上安装Golang的开发环境。可以从Golang官方网站（https://golang.org/）下载安装包，并按照提示进行安装。 此外，我们还需要选择一个MQ系统作为消息的生产者。常见的MQ系统如RabbitMQ、Kafka等，你可以根据自己的需求选择适合的MQ系统。安装完Golang环境并选择好MQ系统后，我们可以开始编写MQ消费对接的代码。
消费MQ消息
首先，我们需要在Golang代码中引入相关的MQ库。对于不同的MQ系统，可能需要使用不同的库。以RabbitMQ为例，我们可以使用"github.com/streadway/amqp"库进行消费。 接下来，我们需要建立与MQ系统的连接。首先，我们需要定义一个MQ连接字符串，包括MQ服务器的IP地址、端口号、用户名和密码等信息。然后，我们使用该连接字符串建立与MQ服务器的连接。 ``` import ( "fmt" "log" "github.com/streadway/amqp" ) func main() { conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/") if err != nil { log.Fatalf("Failed to connect to RabbitMQ: %v", err) } defer conn.Close() // 在连接上创建一个channel ch, err := conn.Channel() if err != nil { log.Fatalf("Failed to open a channel: %v", err) } defer ch.Close() // 创建一个消费队列 q, err := ch.QueueDeclare( "hello", // 队列名称 false, // 是否持久化 false, // 是否自动删除 false, // 是否排它队列 false, // 是否阻塞 nil, // 额外的参数 ) if err != nil { log.Fatalf("Failed to declare a queue: %v", err) } // 设置消费者接收消息的回调函数 msgs, err := ch.Consume( q.Name, // 队列名称 "", // 消费者名称 true, // 是否自动应答 false, // 是否排他消费者 false, // 是否不等待服务器响应 false, // 额外的参数 ) if err != nil { log.Fatalf("Failed to register a consumer: %v", err) } // 循环接收MQ消息 for msg := range msgs { fmt.Printf("Received a message: %s\n", msg.Body) } } ``` 以上代码演示了如何使用Golang创建一个MQ消费者，并循环接收MQ消息。在该示例中，我们首先建立与RabbitMQ服务器的连接，然后创建一个消费队列。最后，我们设置一个回调函数，对接收到的消息进行处理。运行以上代码后，我们将能够接收MQ中发送的消息，并打印出来。