golang Go使用Redis 发布和订阅消息

发布消息

在Go中，Redis客户端库可以提供一个Publish方法来实现消息的发布。不同的Redis客户端库可能有不同的API和方法命名，此处以 v8 为例, v8 版本以下不需要context, 下面是一个示例使用go-redis库进行Publish操作的示例代码：

package main

import (

"fmt"

"github.com/go-redis/redis/v8"

"context"

)

func main() {

// 建立Redis连接

ctx := context.Background()

client := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "", // 如果有密码，需要设置

DB: 0, // 使用默认数据库

})

// 发布消息

channel := "my_channel"

message := "Hello, Redis!"

result := client.Publish(ctx, channel, message)

if result.Err() != nil {

fmt.Println("Failed to publish message:", result.Err())

return

}

// 获取发布消息的结果

fmt.Println("Publish result:", result.Val())

}

在这个示例中，我们使用go-redis库来建立与Redis服务器的连接。通过redis.NewClient函数提供Redis服务器的地址和其他连接参数。然后，我们使用client.Publish方法执行Redis的PUBLISH命令，将消息发布到指定的频道中。最后，我们打印出发布消息的结果。

订阅消息

在Go中，Redis客户端库可以提供Subscribe方法来接收发布的消息。以下是使用go-redis库进行Subscribe操作的示例代码：

package main

import (

"fmt"

"github.com/go-redis/redis/v8"

"context"

)

func main() {

// 建立Redis连接

ctx := context.Background()

client := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "", // 如果有密码，需要设置

DB: 0, // 使用默认数据库

})

// 订阅频道

channel := "my_channel"

pubsub := client.Subscribe(ctx, channel)

defer pubsub.Close()

// 接收消息

for {

msg, err := pubsub.ReceiveMessage(ctx)

if err != nil {

fmt.Println("Failed to receive message:", err)

break

}

fmt.Println("Received message:", msg.Payload)

}

}

在这个示例中，我们使用go-redis库来建立与Redis服务器的连接。通过redis.NewClient函数提供Redis服务器的地址和其他连接参数。然后，我们使用client.Subscribe方法订阅指定的频道。通过pubsub.ReceiveMessage方法来接收发布到频道的消息。我们使用一个循环来持续监听消息，直到发生错误。

精彩内容