我正在尝试在 Go 中使用 Redis PubSub 来传递/发布消息并在订阅期间检索它。
我已经能够正确设置代码的发布和订阅/PubSub 部分。下面是我的代码。我希望在订阅期间检索的(字符串)消息是test message.
但是,我的代码输出给出了频道、种类和计数,并且没有显示预期的消息(test message
)。
test message
在 Go 中使用 Redis 发布/订阅发布后,如何获得预期的消息( )?我觉得我很接近,但我可能在这里错过了一件小事。我对 Redis 很陌生。谢谢你的帮助。
以下是我的代码:
package main
import (
"fmt"
"log"
"time"
"github.com/gomodule/redigo/redis"
)
func main() {
fmt.Println("Start redis test.")
c, err := redis.Dial("tcp", "localhost:6379")
if err != nil {
log.Println(err)
} else {
log.Println("No error during redis.Dial.")
}
// defer c.Close()
/// Publisher.
c.Do("PUBLISH", "example", "test message")
/// End here
/// Subscriber.
psc := redis.PubSubConn{Conn: c}
psc.Subscribe("example")
for {
switch v := psc.Receive().(type) {
case redis.Message:
fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
case redis.Subscription:
fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
case error:
fmt.Println(v)
}
}
/// End here
}
以下是我的输出:
example: subscribe 1