godb_0">mongodb

insertOrUpdate

go">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

go">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)}}
})
···