记，项目解决

mongodb

insertOrUpdate

filter := bson.M{"_id": objectId}
update := bson.M{
    "$set": bson.M{
        "name": "Updated Name",
        "age":  30,
    },
}

opts := options.FindOneAndUpdate().
    SetUpsert(true).                 // 没有匹配文档时插入新文档
    SetReturnDocument(options.After) // 返回更新后的文档，不加这行，setUpsert不生效

result := collection.FindOneAndUpdate(context.TODO(), filter, update, opts)

if err := result.Decode(&updatedDocument); err != nil {
    log.Fatal(err)
}

fmt.Printf("Updated document: %+v\n", updatedDocument)

rabbitmq

生产者ack

conn.Confirm(false) // 消息确认发布机制
conn.Qos(1,0,false)	// 确保每个消费者最多拿到一条未确认消息

// rabbitmq管道级别的ch，多个queue也是用同一个
confirmations := ch.NotifyPublish(make(chan amqp091.Confirmation, 2))
utils.GoSafe(func() {
 for c := range confirmations {
  if !c.Ack {
   glog.Errorf("message not acked:  delivery tag: %d", c.DeliveryTag)
  } else {
   glog.Infof("message acked: delivery tag: %d", c.DeliveryTag)
  }
 }
})
···