Kā jūs veicat pieprasījumu replikāciju un ar kādu pieredzi jūs varat dalīties šajā procesā?

Golang kontekstā vaicājumu replikācija parasti ir saistīta ar slodzes sadali starp vairākiem serveriem vai datu bāzēm, lai uzlabotu izturību pret kļūdām un veiktspēju. Viens no biežāk izmantotajiem pieejām ir izmantot starpniekserveri vai slodzes balansētāju, kas dubulto vaicājumus vairākās replikās.

No mana pieredzes, es īstenoju vaicājumu replikāciju lietojumprogrammas līmenī, kad lasīšanas vaicājumi tika virzīti uz datu bāzes replikām, bet rakstīšanas — uz galveno serveri. Tam es Go valodā izmantoju interfeisus un "repository" paraugu, lai abstraktētu datu piekļuves loģiku un virzītu vaicājumus pareizajā vietā.

Vienkāršs piemērs replikas izvēlei lasīšanai:

 type DB interface {
    Query(query string, args ...interface{}) (*sql.Rows, error)
    Exec(query string, args ...interface{}) (sql.Result, error)
}

// Galvenais serveris rakstīšanai
var masterDB DB
// Replikas lasīšanai
var replicaDBs []DB

func QueryRead(query string, args ...interface{}) (*sql.Rows, error) {
    // Vienkārša stratēģija: nejauša replikas izvēle
    replica := replicaDBs[rand.Intn(len(replicaDBs)))]
    return replica.Query(query, args...)
}

func ExecWrite(query string, args ...interface{}) (sql.Result, error) {
    return masterDB.Exec(query, args...)
}

Ir arī svarīgi ņemt vērā datu konsekvenci un replikācijas aizkavi, lai izvairītos no novecojušu datu saņemšanas no replikām.