Data Transmission Service:Değişiklik izleme ile önbellek güncellemelerini uygulayın

Önkoşullar

• Bir değişiklik izleme görevi yapılandırdınız ve bir tüketici grubu eklediniz. Daha fazla bilgi için bkz. ApsaraDB RDS for MySQL için değişiklik izleme görevi oluşturma ve Tüketici grubu ekleme.

• Bir Tair (Redis uyumlu) örneği oluşturdunuz ve genel erişimi etkinleştirdiniz. Daha fazla bilgi için bkz. Adım 1: Örnek Oluşturma ve Genel Uç Nokta İsteme.

  Not

  İstemci IP adresini veya CIDR bloğunu Tair örneğinin izin listesine eklemeniz gerekir. Daha fazla bilgi için bkz. İzin listesi yapılandırma.

Arka Plan

Uygulamalar, erişim hızını artırmak ve yüksek okuma eşzamanlılığını yönetmek için yaygın olarak bir önbellek katmanı ekler. Okuma isteklerini bellek içi okumalarla önbellekten karşılar; veri güncellemelerini ise ApsaraDB RDS for MySQL gibi dayanıklı bir veritabanına kalıcı olarak kaydeder. Önbellek güncelleme ilkesi, önbelleğin veritabanı ile senkronize kalmasını sağlar.

Yordam

İzlenen verileri tüketmek için IntelliJ IDEA'da SDK örnek kodunu çalıştırın.

1. Değişiklik izleme SDK demo paketini indirin ve paketi ayıklayın.

2. IntelliJ IDEA kullanarak ayıklanan SDK demo paketini bir Maven projesi olarak açın.

3. /subscribe-demo/src/main/java/com/alibaba/dts/demo/ dizininde DTSMySQL2RedisDemo.java dosyasına çift tıklayın.

4. main işlevindeki parametreleri değiştirin.

   Kodda yeşil ile vurgulanan değerleri değiştirmeniz gerekir; örneğin String brokerUrl = "your broker url"; içindeki your broker url.

   • Değişiklik izleme parametreleri

     Parametre	Açıklama	Kaynak
     brokerUrl	Veri Aboneliği örneğinin uç noktası ve bağlantı noktası numarası. Not SDK istemcisini çalıştıran ECS örneği ile Veri Aboneliği örneği aynı klasik ağda veya Virtual Private Cloud (VPC) içindeyse, ağ gecikme süresini en aza indirmek için abonelik için dahili uç noktayı kullanmanızı öneririz. Olası ağ kararsızlığı nedeniyle genel uç nokta kullanmanızı önermiyoruz.	DTS konsolunda hedef Veri Aboneliği örneğinin ID'sine tıklayın. Basic Information sayfasında, Network bölümünde uç nokta ve bağlantı noktası numarasını bulabilirsiniz.
     topic	Örnek için abonelik konusu.	DTS konsolunda hedef Veri Aboneliği örneğinin ID'sine tıklayın. Basic Information sayfasında, Basic Information bölümünde Topic bilgisini alabilirsiniz.
     sid	Tüketici grubunun ID'si.	DTS konsolunda hedef Veri Aboneliği örneğinin ID'sine tıklayın ve ardından Consume Data seçeneğine tıklayın. Tüketici grubunun Consumer Group ID ve Account bilgilerini alabilirsiniz. Not Tüketici grubu kullanıcı adı parolası, tüketici grubunu oluştururken belirtilir.
     userName	Tüketici grubu için kullanıcı adı. Uyarı Bu konudaki istemciyi kullanmıyorsanız, kullanıcı adını <Username>-<Consumer Group ID> biçiminde ayarlamanız gerekir. Örnek: dtstest-dtsaebpv. Aksi takdirde bağlantı başarısız olur.
     password	Kullanıcı adı parolası.
     initCheckpoint	SDK istemcisinin veri tüketmeye başlayacağı UNIX zaman damgası olarak belirtilen tüketim kontrol noktası. Örnek: 1620962769. Not Tüketim kontrol noktası bilgilerini aşağıdaki senaryolarda kullanabilirsiniz: Bir uygulama kesintisinden sonra veri kaybını önlemek ve tüketimi sürdürmek için bilinen son tüketim kontrol noktasını iletin. İstemciyi başlatırken, belirli bir konumdan veri tüketmek için belirli bir tüketim kontrol noktası iletebilirsiniz.	Tüketim kontrol noktası, Veri Aboneliği örneğinin veri aralığı içinde olmalıdır (şekilde gösterildiği gibi) ve bir UNIX zaman damgasına dönüştürülmelidir. Not UNIX zaman damgası dönüştürücüsü bulmak için bir arama motoru kullanabilirsiniz.
     ConsumerContext.ConsumerSubscribeMode subscribeMode	SDK istemcisinin kullanım modu. Geçerli değerler: ConsumerContext.ConsumerSubscribeMode.ASSIGN: ASSIGN modu. Bir tüketici grubundaki yalnızca bir SDK istemcisi Veri Aboneliği verilerini tüketebilir. ConsumerContext.ConsumerSubscribeMode.SUBSCRIBE: SUBSCRIBE modu. Olağanüstü durum kurtarma için aynı tüketici grubunda birden çok SDK istemcisi başlatabilirsiniz.	Yok

   • Hedef Tair parametreleri

     Parametre	Açıklama	Nasıl elde edilir
     redisUrl	Tair örneğinin uç noktası.	Tair örneğinizin Connection Information sayfasına gidin. Connection Information bölümünde Public Access için endpoint adresini bulun.
     redisPort	Tair örneğinin bağlantı noktası.	Tair örneğinizin Connection Information sayfasına gidin. Connection Information bölümünde Public Access için bağlantı noktasını bulun.
     redisPassword	Tair örneği için kullanıcı adı ve parola. Önemli Değer, <user>:<password> biçiminde bir dize olmalıdır. Örneğin, kullanıcı adınız admin ve parolanız Rp829dlwa ise bu parametreyi admin:Rp829dlwa olarak ayarlayın.	Bu değeri Tair örneğini oluştururken belirttiniz. Not Parolanızı unuttuysanız sıfırlayabilirsiniz. Daha fazla bilgi için bkz. Parola değiştirme veya sıfırlama.

5. IntelliJ IDEA'nın üst menü çubuğunda Run > Run seçeneğine tıklayın.

Sonuçlar

1. Kaynak veritabanında oturum açın ve izlenen kaynak tabloya birkaç kayıt ekleyin.

   Program, artımlı veri değişikliklerini tüketir ve ilgili verileri hedef veritabanına yazar.

2. Hedef veritabanında oturum açın ve verileri sorgulayın.

   Sorgu, verilerin başarıyla yazıldığını doğrular.