Redis的发布订阅(Pub/Sub)功能提供了一种消息队列的实现方式,可以让发送方(发布者)向一个频道发布消息,订阅方(订阅者)则可以订阅相关频道接收消息。

1.发布订阅基本概念

发布订阅模式通过频道(channel)来实现消息的分发。发布者(publisher)可以向频道发布消息,订阅者(subscriber)可以订阅频道来接收消息。这种模式可以实现消息的异步传输。

在Redis中,客户端可以订阅任意数量的频道。当向被订阅的频道发布消息时,所有订阅该频道的客户端都会收到这条消息。

2.相关命令

SUBSCRIBE命令 – 订阅频道

SUBSCRIBE 命令用来订阅给定的一个或多个频道。语法如下:

SUBSCRIBE channel [channel ...]

例如:

SUBSCRIBE news.china news.world

这将订阅 news.china 和 news.world 两个频道。

UNSUBSCRIBE命令 – 取消订阅

UNSUBSCRIBE 命令用来取消对给定频道的订阅。语法如下:

UNSUBSCRIBE [channel [channel ...]]

例如:

UNSUBSCRIBE news.china

这将取消对 news.china 频道的订阅。

PSUBSCRIBE命令 – 使用模式订阅

PSUBSCRIBE 命令用于使用给定的模式订阅频道。语法如下:

PSUBSCRIBE pattern [pattern ...]

例如:

PSUBSCRIBE news.*

这将订阅所有以 news. 开头的频道。

PUNSUBSCRIBE命令 – 取消按模式的订阅

PUNSUBSCRIBE 命令用于取消给定模式的订阅。语法如下:

PUNSUBSCRIBE [pattern [pattern ...]]

PUBLISH命令 – 发布消息

PUBLISH 命令用于向给定的频道发布消息。语法如下:

PUBLISH channel message

例如:

PUBLISH news.china "新消息"

这将向 news.china 频道发布消息”新消息”。

go-redis 实现订阅发布

package main

import (
    "fmt"
    "time"
    "github.com/go-redis/redis"
)

func subscriber(client *redis.Client) {
    pubsub := client.Subscribe("mychannel")
    // 使用模式订阅
    // pubsub := client.PSubscribe(ctx, "mychannel*")
    defer pubsub.Close()

    // 处理订阅接收到的消息
    for {
        msg, err := pubsub.ReceiveMessage()
        if err != nil {
            return
        }

        fmt.Println(msg.Channel, msg.Payload)
    }
}

func publisher(client *redis.Client) {
    for {
        // 发布消息到频道
        err := client.Publish("mychannel", "hello").Err()
        if err != nil {
            panic(err)
        }
        time.Sleep(1 * time.Second)
    }
}

func main() {
    client := redis.NewClient(&redis.Options{
        Addr: "localhost:6379",
    })

    go subscriber(client)
    go publisher(client)

    <-make(chan struct{})
}