go - Golang Redis PubSub 发送重复消息

Question

我正在尝试使用 golang 上的 redis pub/sub 实现构建一个功能，但是对于连接到服务器（WebSocket）的每个客户端，发布的消息数量都会翻倍。

func (c client) Subscribe() {
    con := initRedis()
    defer con.Close()
    psc := redis.PubSubConn{Conn: con}
    defer psc.Close()
    psc.Subscribe(c.Channel)
    for {
    switch v := psc.Receive().(type) {
    case redis.Message:
        fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
        broadcast <- map[string]string{
            "channel": v.Channel,
            "message": string(v.Data),
        }
    case redis.Subscription:
        fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
    case error:
        log.Println(v)
        psc.Unsubscribe()
    }
}
}

func (m Message) Publish() {
c := initRedis()
defer c.Close()
reply, err := c.Do("PUBLISH", m.Channel, m.Msg)
if err != nil {
    log.Println(err)
}
fmt.Println("Publishing", m, reply)
}

func initRedis() redis.Conn {
    if err := godotenv.Load(); err != nil {
        panic(err)
    }
    // fmt.Println(os.Getenv("REDIS_URL"))
    c, err := redis.DialURL(os.Getenv("REDIS_URL"), redis.DialTLSSkipVerify(true))
    if err != nil {
        panic(err)
    }
    // defer c.Close()

    return c
}

如何停止重复？或者是什么导致了重复。