Bagaimana Redis mencapai konsistensi transaksi yang diedarkan

Redis ialah pangkalan data memori teragih berprestasi tinggi yang digunakan secara meluas dalam sistem teragih. Dalam sistem yang diedarkan, cara untuk mencapai konsistensi transaksi sentiasa menjadi masalah, dan mekanisme transaksi yang disediakan oleh Redis boleh membantu pembangun menyelesaikan masalah ini. Artikel ini akan memperkenalkan cara Redis mencapai konsistensi transaksi yang diedarkan dan menunjukkan contoh kod.

1. Pengenalan kepada mekanisme transaksi Redis

Redis menyediakan mekanisme transaksi dalam versi 2.0, yang dilaksanakan melalui lima arahan: MULTI, EXEC, WATCH, DISCARD dan UNWATCH . Operasi dalam transaksi akan direkodkan secara berurutan dalam baris gilir dan dilaksanakan dalam kelompok apabila arahan EXEC dipanggil. Jika keseluruhan urus niaga berjaya diserahkan, semua operasi dalam baris gilir rekod akan dilaksanakan mengikut urutan jika operasi gagal, keseluruhan transaksi akan ditarik balik. Berbilang pelanggan boleh memulakan urus niaga mereka sendiri pada masa yang sama Memandangkan mereka dilaksanakan dalam baris gilir rekod operasi, urus niaga adalah bebas antara satu sama lain.

2. Prinsip pelaksanaan transaksi diedarkan Redis

Dalam transaksi bersendirian Redis, setiap pelanggan diproses melalui proses yang sama, manakala dalam situasi diedarkan, setiap pelanggan Setiap pelanggan mungkin sepadan dengan contoh Redis yang berbeza, yang memerlukan ketekalan transaksi yang diedarkan untuk memastikan ketepatan data.

Kunci untuk Redis melaksanakan transaksi teragih terletak pada arahan WATCH dan UNWATCH. Setiap pelanggan boleh menandakan beberapa data utama dalam Redis melalui arahan WATCH Apabila data ini diubah suai oleh pelanggan lain, transaksi pelanggan akan ditamatkan. Tanda ini boleh dikeluarkan melalui arahan UNWATCH. Sebabnya ialah apabila pengguna memulakan transaksi, jika terdapat persaingan menulis yang sama dengan pelanggan lain, transaksi akan ditarik balik dan isyarat kegagalan transaksi akan ditetapkan. Dalam proses ini, pelanggan perlu mengenal pasti secara unik semua data utamanya yang perlu dipantau Apabila konflik berlaku, pelanggan akan menggunakan pengenalan ini untuk menentukan sama ada transaksi itu perlu ditarik balik. Jika pemulangan semula diperlukan, pelanggan mencuba semula transaksi.

3. Contoh Kod

Di bawah kami menggunakan Python untuk melaksanakan transaksi teragih yang mudah, mensimulasikan dua pelanggan yang melaksanakan transaksi pada kejadian Redis yang berbeza untuk melaksanakan operasi pemindahan , yang memerlukan pemindahan ke berjaya dan menggunakan arahan WATCH/UNWATCH untuk mencapai kawalan konsisten.

Prasyarat:

• Python 3.x
• Redis-py

#🎜🎜 adalah seperti berikut :

import redis

# 新建两个 Redis 实例 
redis1 = redis.StrictRedis(host="localhost", port=6379, db=0)
redis2 = redis.StrictRedis(host="localhost", port=6380, db=0)

# 我们模拟一下一个转帐操作
def transfer(from_user, to_user, value):
    # 两个实例都要执行事务
    tx = redis1.pipeline()
    tx2 = redis2.pipeline()

    # Watch 监控 from_user 和 to_user 的 balance 值
    tx.watch(from_user, to_user)
    tx2.watch(from_user, to_user)

    # 如果 from_user 的 balance 值减去转账数值，小于0
    if tx.get(from_user) < int(value):
        tx.unwatch()
    else:
        tx.multi()
        tx.decrby(from_user, int(value))

        # 通过2个实例之间的网络通信，将 balance 放入另一个
        tx2.multi()
        tx2.incrby(to_user, int(value))

        print(tx.execute())
        print(tx2.execute())

transfer('user1', 'user2', '100') #执行转账操作

Dua kejadian Redis baharu dicipta dalam kod. Kemudian fungsi pemindahan ditakrifkan, yang mensimulasikan operasi pemindahan dan perlu memasukkan parameter from_user, to_user dan nilai pemindahan. Dalam fungsi, bahagian teras adalah menggunakan arahan WATCH untuk memantau nilai baki from_user dan to_user pada dua contoh Redis untuk mengelakkan keadaan perlumbaan semasa proses pemindahan. Kemudian gunakan transaksi untuk menukar baki pada dua kejadian Redis untuk memastikan ketekalan operasi pemindahan.

Ringkasan

Redis menyokong mekanisme transaksi untuk memastikan konsistensi pada satu contoh Redis. Walau bagaimanapun, dalam persekitaran yang diedarkan, untuk memastikan konsistensi pada berbilang contoh Redis, mekanisme transaksi yang diedarkan perlu diperkenalkan. Redis melaksanakan mekanisme ini melalui arahan WATCH dan UNWATCH. Kami boleh lebih memahami prinsip pelaksanaan transaksi yang diedarkan Redis melalui contoh kod.

Atas ialah kandungan terperinci Bagaimana Redis mencapai konsistensi transaksi yang diedarkan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!