ZBLOG

golang 操作 mongodb 设置超时时间为 5 分钟,实际上 2 分钟事务就被中断了,这可能是什么原因?

这种情况可能是由于 MongoDB 驱动程序默认的连接超时时间比较短所导致的。在 Golang 中,你可以通过设置 SetMaxTime() 方法来指定操作的最大执行时间,确保不会在规定时间内中断事务。

下面是一个示例代码片段,展示如何使用 context.WithTimeout() 来设置操作的超时时间为 5 分钟:

  1. import (
  2. "context"
  3. "go.mongodb.org/mongo-driver/mongo"
  4. "go.mongodb.org/mongo-driver/mongo/options"
  5. "time"
  6. )
  7. func main() {
  8. ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
  9. defer cancel()
  10. client, err := mongo.Connect(ctx, options.Client().ApplyURI("mongodb://localhost:27017"))
  11. if err != nil {
  12. panic(err)
  13. }
  14. defer client.Disconnect(ctx)
  15. collection := client.Database("mydb").Collection("mycollection")
  16. opts := options.Transaction().SetMaxCommitTime(5 * time.Minute)
  17. session, err := client.StartSession()
  18. if err != nil {
  19. panic(err)
  20. }
  21. defer session.EndSession(ctx)
  22. err = mongo.WithSession(ctx, session, func(sessionContext mongo.SessionContext) error {
  23. return session.StartTransaction(opts).
  24. AddOperation(mongo.InsertOne{
  25. Document: bson.M{"key": "value"},
  26. }).
  27. AddOperation(mongo.UpdateOne{
  28. Filter: bson.M{"key": "value"},
  29. Update: bson.M{"$set": bson.M{"key2": "value2"}},
  30. }).
  31. CommitTransaction(sessionContext)
  32. })
  33. if err != nil {
  34. panic(err)
  35. }
  36. }

通过上述代码,你可以将操作超时时间设置为 5 分钟,确保事务不会在 2 分钟内被中断。请根据实际需要调整代码中的连接字符串和操作逻辑。


内容由零声教学AI助手提供,问题来源于学员提问

本站部分文章来源于网络,版权归原作者所有,如有侵权请联系站长删除。
转载请注明出处:https://golang.0voice.com/?id=13652

分享:
扫描分享到社交APP
上一篇
下一篇
发表列表
游客 游客
此处应有掌声~
评论列表

还没有评论,快来说点什么吧~

联系我们

在线咨询: 点击这里给我发消息

微信号:3007537140

上班时间: 10:30-22:30

关注我们
x

注册

已经有帐号?