3

我正在使用 gin 框架来构建 API 服务器。一般来说，我正在构建 2 个项目。项目'API'和项目'SOCKET'。Project'API'是 Android 中使用的主要 REST API，使用gin框架（golang）开发。而 Project'SOCKET'是客户端的套接字服务器，它将使用套接字连接，使用 node.js( Socket.IO)

这个过程是这样开始的：
用户 A：作为请求者；A连接到"API"
用户B：作为响应者；B 连接到"SOCKET"

User A从 android调用 API requestData，请求将由"API"的项目处理。Project"API"将记录请求，并在 redis 上发布为new_request使用 pubsub

这是例如代码：

client := redis.NewClient(&redis.Options{
    Addr:     "localhost:6379",
    Password: "", // no password set
    DB:       0,  // use default DB
})

pong, err := client.Ping().Result()

fmt.Println(pong, err)

 if err !=nil {
    fmt.Println("err",err);
 }


pubsub, err := client.Subscribe("responseclient")
if err !=nil {
    panic(err)
}
defer pubsub.Close()

err = client.Publish("new_request", "Example New Request").Err()

if err !=nil {
    panic(err)
}
msg, err :=pubsub.ReceiveMessage()
if err != nil {
    panic(err)
}

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

}

在 Project"SOCKET"中，有一个订阅者将监听发生的每个发布，并将新消息发布到频道，responseclient 这是示例代码：

ioApp.on ('connection' , function(socket) {
redisSub.on('new_request', function (channel, message) {
    console.log(channel + ':' + message);

    redisPub.publish("responseclient", JSON.stringify(res));    

});

})

如果用户 B 连接到 Socket.IO ，这将顺利进行。但是如果用户 B离线，或者没有连接到 socket.io，这将等待很长时间，直到我们手动终止或直到用户 B 在线

我要的是：

  1. 我们可以callback在 redis pub/sub 上创建类似的东西吗？如果订阅者由于离线或其他原因不接受消息，我们将关闭连接。这可能吗 ？
  2. 在 Node.Js 中我知道我可以使用超时功能，如果在特定时间没有收到消息，它将关闭订阅或发出任何事件，如何在 golang 上执行此操作？我需要通知User AifUser B是活动的还是离线的，所以他可以等待另一个时间来创建请求。
  3. 如果什么都做不到，你对我有什么建议？

我希望我的问题，可以理解，并且可以很好地回答。
*一些代码可能，缺少变量。
** 我将这个库用于 golang redis：go-redis

4

2 回答 2

1

1) Redis 中没有回调。

2) 在 Go 中实现超时的常用方法是使用通道并选择 - 其中一个是您执行阻塞的通道，另一个通道在超时时接收消息。可以在此处和此处找到文档的示例

现在对于 (3)，您可以选择一些方法。第一种是使用列表，从一侧推送（发布）并从另一侧弹出（订阅）。对于您疯狂使用的接收器BRPOP-BLPOP分别从右侧或左侧阻止弹出。您可以将两者结合起来以获得持久的消息传递。

现在 PUBSUB 的一部分还取决于您要发布的内容。如果您要发布到一个有订阅者的频道，当且仅当有一个用户连接来接收它（因此只有一个订阅者到该频道），您可以检查发布命令的响应。它会告诉你它发布给了多少客户。如果频道仅由在线接收者订阅，您将返回“1”，如果用户离线，则返回“0”。

第三个示例是将消息存储在排序集中，以时间戳作为分数。这将允许接收者连接并从上次连接时获取消息 - 但这假设在某处存在一些持久性 - 通常是客户端。您还需要对排序集进行一些清理活动。

在这种情况下要考虑的其他一些事情是您是否最终使用复制，在这种情况下，您必须明确考虑故障转移 - 尽管在您描述的情况下，您确实希望考虑断开连接和重新连接。在我关于可靠 PUBSUB 的帖子中有具体的例子。

于 2016-12-17T15:02:24.750 回答
1 
package main

import (
    "context"
    "fmt"
    "time"

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

var ctx = context.Background()

func main() {
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // no password set
        DB:       0,  // use default DB
    })

    subscribe := rdb.Subscribe(ctx, "hello")
    subscriptions := subscribe.ChannelWithSubscriptions(ctx, 1)
    go func() {
        var sentCount = 0
        for  {
            rdb.Publish(ctx,"hello",time.Now().UnixNano())
            sentCount++
            if sentCount >300{
                break
            }
        }
    }()
    for  {
        select {
        case sub:=<-subscriptions:
            fmt.Println(sub)
        }
    }



}
于 2021-01-06T03:38:04.233 回答