Gunakan DTS change tracking untuk memperbarui cache Redis dari MySQL-Data Transmission Service-Alibaba Cloud

Fitur pelacakan perubahan dari Data Transmission Service (DTS) dapat bekerja sama dengan ApsaraDB for MongoDB dan ApsaraDB for Redis untuk mengimplementasikan kebijakan pembaruan cache dengan keandalan tinggi dan latensi rendah. Topik ini menjelaskan cara mengonfigurasi kebijakan pembaruan cache. Dalam contoh berikut, database sumber adalah instance ApsaraDB RDS for MySQL, dan database tujuan adalah instance ApsaraDB for Redis.

Prasyarat

Tugas pelacakan perubahan telah dikonfigurasi dan grup konsumen telah ditambahkan. Untuk informasi lebih lanjut, lihat Lacak perubahan data dari instance ApsaraDB RDS for MySQL dan Buat grup konsumen.
Instance ApsaraDB for Redis dengan akses Internet telah dibuat. Untuk informasi lebih lanjut, lihat Langkah 1: Buat instance dan Ajukan titik akhir publik untuk instance.
Catatan
Anda harus menambahkan alamat IP klien atau blok CIDR ke daftar putih instance ApsaraDB for Redis. Untuk informasi lebih lanjut, lihat Konfigurasikan daftar putih.

Informasi latar belakang

Untuk mempercepat akses bisnis dan meningkatkan kinerja baca secara bersamaan, lapisan caching dibangun dalam arsitektur bisnis. Permintaan baca diarahkan ke lapisan caching. Mekanisme pembacaan memori pada lapisan caching meningkatkan kinerja baca. Untuk memastikan integritas data, data bisnis yang diperbarui disimpan secara permanen di ApsaraDB RDS for MySQL. Dalam hal ini, Anda dapat mengonfigurasi kebijakan pembaruan cache untuk memastikan bahwa data yang di-cache diperbarui ketika data bisnis diperbarui.

Prosedur

Contoh berikut menggunakan IntelliJ IDEA dan kode demo SDK untuk menunjukkan cara mengonsumsi data yang dilacak.

Unduh paket demo SDK dan dekompresi paket tersebut.
Gunakan IntelliJ IDEA untuk membuka paket demo SDK yang telah didekompresi dalam proyek Maven.
Pada jalur /subscribe-demo/src/main/java/com/alibaba/dts/demo/, klik dua kali file DTSMySQL2RedisDemo.java.

Ubah parameter dalam fungsi main.

Pada gambar berikut, nilai dalam warna hijau perlu diubah. Sebagai contoh, your broker url dari parameter String brokerUrl = "your broker url"; perlu diubah.

Parameter tugas pelacakan perubahan

Parameter	Deskripsi	Cara mendapatkan nilai parameter
`brokerUrl`	Titik akhir dan nomor port instance pelacakan perubahan. Catatan Jika Anda melacak perubahan data melalui jaringan internal, latensi jaringan minimal. Ini berlaku jika instance Elastic Compute Service (ECS) tempat Anda menerapkan klien SDK berada di jaringan klasik atau di virtual private cloud (VPC) yang sama dengan instance pelacakan perubahan. Kami merekomendasikan agar Anda tidak menggunakan titik akhir publik.	Di halaman Pelacakan Perubahan konsol DTS, temukan instance pelacakan perubahan yang ingin Anda kelola dan klik ID instance. Di panel sebelah kiri, klik tab Basic Information untuk mendapatkan titik akhir dan nomor port instance pelacakan perubahan di bagian Network.
`topic`	Nama topik yang dilacak dari instance pelacakan perubahan.	Di halaman Pelacakan Perubahan konsol DTS, temukan instance pelacakan perubahan yang ingin Anda kelola dan klik ID instance. Di panel sebelah kiri, klik tab Basic Information untuk mendapatkan nama topik yang dilacak Topic di bagian Basic Information.
`sid`	ID grup konsumen.	Di halaman Pelacakan Perubahan konsol DTS, temukan instance pelacakan perubahan yang ingin Anda kelola dan klik ID instance. Di panel sebelah kiri, klik tab Consume Data untuk melihat Consumer Group ID/Name dan informasi Account dari grup konsumen. Catatan Kata sandi akun grup konsumen ditentukan saat Anda membuat grup konsumen.
`userName`	Nama pengguna akun grup konsumen. Peringatan Jika Anda tidak menggunakan klien SDK yang dijelaskan dalam topik ini, Anda harus menentukan parameter ini dalam format berikut: `<Username>-<Consumer group ID>`. Contoh: `dtstest-dtsae******bpv`. Jika tidak, koneksi akan gagal.
`password`	Kata sandi akun grup konsumen.
`initCheckpoint`	Offset konsumen, yaitu timestamp yang dihasilkan ketika klien SDK mengonsumsi catatan data pertama. Nilainya adalah timestamp UNIX. Contoh: 1620962769. Catatan Offset konsumen dapat digunakan dalam skenario berikut: Jika proses konsumsi terganggu, Anda dapat menentukan offset konsumen untuk melanjutkan konsumsi data. Ini mencegah hilangnya data. Saat Anda memulai klien pelacakan perubahan, Anda dapat menentukan offset konsumen untuk mengonsumsi data berdasarkan kebutuhan bisnis Anda.	Offset konsumen dari data yang dikonsumsi harus berada dalam rentang data instance pelacakan perubahan. Offset konsumen harus dikonversi ke timestamp UNIX. Catatan Anda dapat melihat rentang data instance pelacakan perubahan di kolom Data Range di halaman Pelacakan Perubahan. Anda dapat menggunakan mesin pencari untuk mendapatkan konverter timestamp UNIX.
`ConsumerContext.ConsumerSubscribeMode subscribeMode`	Mode penggunaan klien SDK. Nilai valid: `ConsumerContext.ConsumerSubscribeMode.ASSIGN`: Dalam mode ASSIGN, Anda hanya dapat memulai satu klien SDK dalam grup konsumen untuk mengonsumsi data yang dilacak. `ConsumerContext.ConsumerSubscribeMode.SUBSCRIBE`: Dalam mode SUBSCRIBE, Anda dapat memulai beberapa klien SDK dalam grup konsumen sekaligus untuk redundansi tinggi.	Tidak tersedia

Parameter instance ApsaraDB for Redis

Parameter	Deskripsi	Cara mendapatkan nilai parameter
`redisUrl`	Titik akhir ke instance ApsaraDB for Redis.	Di tab Instance Information instance ApsaraDB for Redis, temukan bagian Connection Information dan lihat endpoint instance ApsaraDB for Redis di baris Public Access.
`redisPort`	Nomor port instance ApsaraDB for Redis.	Di tab Instance Information instance ApsaraDB for Redis, temukan bagian Connection Information dan lihat port number instance ApsaraDB for Redis di baris Public Access.
`redisPassword`	Nama pengguna dan kata sandi akun ApsaraDB for Redis. Penting Kata sandi database berada dalam format <user>:<password>. Sebagai contoh, jika nama pengguna akun yang Anda gunakan untuk masuk ke instance ApsaraDB for Redis sumber adalah admin dan kata sandinya adalah Rp829dlwa, kata sandi database adalah admin:Rp829dlwa.	Nama pengguna dan kata sandi ditentukan saat instance ApsaraDB for Redis dibuat. Catatan Jika Anda lupa kata sandi, Anda dapat mengatur ulang kata sandi. Untuk informasi lebih lanjut, lihat Ubah atau atur ulang kata sandi.

Di bilah menu atas IntelliJ IDEA, pilih Run > Run untuk menjalankan program.

Hasil

Masuk ke database sumber dan sisipkan beberapa entri data ke tabel sumber tugas pelacakan perubahan.
Hasilnya menunjukkan bahwa program melacak perubahan dalam data dan menulis data tambahan ke database tujuan.
Masuk ke database tujuan dan kueri data.
Hasilnya menunjukkan bahwa data tambahan ditulis ke database tujuan.