Hologres：Pengaturan keseimbangan beban berbasis JDBC

Informasi latar belakang

Dalam Hologres, sebuah instans utama dapat dihubungkan dengan beberapa instans sekunder baca-saja. Instans utama dan sekunder berbagi sumber daya penyimpanan tetapi tidak berbagi sumber daya komputasi. Hal ini memungkinkan Anda menerapkan instans dengan ketersediaan tinggi berdasarkan pemisahan baca/tulis. Untuk informasi lebih lanjut, lihat Konfigurasikan Penyebaran Multi-Instans dengan Ketersediaan Tinggi.

Anda dapat menggunakan JDBC untuk mengaitkan beberapa instans sekunder baca-saja dengan instans utama guna menerapkan pengaturan keseimbangan beban sederhana, seperti yang ditunjukkan pada gambar berikut.

Hologres menyediakan fitur-fitur berikut terkait instans sekunder baca-saja yang dikonfigurasi menggunakan JDBC:

• Permintaan kueri dialokasikan secara acak ke instans sekunder baca-saja, mencegah instans sekunder kelebihan beban.

• Permintaan kueri dialokasikan ke instans sekunder secara berurutan untuk memastikan layanan tetap tersedia dalam kasus kegagalan instans.

  • Jika JDBC gagal terhubung ke Instans Sekunder 1, JDBC secara otomatis mencoba terhubung ke Instans Sekunder 2.

  • Jika JDBC gagal terhubung ke Instans Sekunder 1 dan 2, JDBC secara otomatis mencoba terhubung ke Instans Sekunder 3.

  • Jika JDBC gagal terhubung ke semua instans sekunder, sistem menampilkan pesan kegagalan koneksi.

Mulai Hologres V2.0.10 dan versi lebih baru, lebih banyak nilai tersedia untuk parameter targetServerType. Dengan cara ini, Anda dapat menerapkan pengaturan keseimbangan beban dalam lebih banyak skenario.

Catatan penggunaan

jdbc:postgresql://<Endpoint1>:<Port1>,<Endpoint2>:<Port2>,<Endpoint3>:<Port3>.../<DBNAME>?user=<AccessKey ID>&password=<AccessKey Secret>&targetServerType=any&loadBalanceHosts=<value>[&hostRecheckSeconds=<value>]

jdbc:postgresql://{ENDPOINT1}:{PORT1},{ENDPOINT2}:{PORT2},{ENDPOINT3}:{PORT3}.../{DBNAME}?targetServerType=any&loadBalanceHosts=true&hostRecheckSeconds=30

Contoh

• Permintaan kueri dialokasikan secara acak ke tiga instans sekunder baca-saja. Jika koneksi gagal, JDBC secara otomatis mencoba terhubung ke instans lain.

  import java.sql.*;
  import java.util.HashMap;
  import java.util.Map;
  import java.util.Properties;
  
  public class hatest {
      public static void main(String[] args) {
          //Konfigurasikan titik akhir dari Hologres Read-only Secondary Instance 1.
          String endpoint1 = "hgpostcn-cn-wxxxxxxxx01-cn-shanghai.hologres.aliyuncs.com:80";
          //Konfigurasikan titik akhir dari Hologres Read-only Secondary Instance 2.
          String endpoint2 = "hgpostcn-cn-wxxxxxxxx02-cn-shanghai.hologres.aliyuncs.com:80";
          //Konfigurasikan titik akhir dari Hologres Read-only Secondary Instance 3.
          String endpoint3 = "hgpostcn-cn-wxxxxxxxx03-cn-shanghai.hologres.aliyuncs.com:80";      
          //Tentukan nama database yang ingin Anda hubungkan.
          String dbname = "postgres";
          String jdbcUrl = "jdbc:postgresql://" + endpoint1 + "," + endpoint2 + "," + endpoint3 + "/" + dbname;
          Properties properties = new Properties();
          //Tentukan ID AccessKey dari akun yang digunakan untuk terhubung ke database.
          properties.setProperty("user", "xxxx");
          //Tentukan rahasia AccessKey dari akun yang digunakan untuk terhubung ke database.
          properties.setProperty("password", "xxxx");
          //Set targetServerType ke any. Ini memungkinkan JDBC terhubung ke instans apa pun yang titik akhirnya ditentukan dalam URL.
          properties.setProperty("targetServerType", "any");
          //Set loadBalanceHosts ke true untuk mengaktifkan pengaturan keseimbangan beban.
          properties.setProperty("loadBalanceHosts", "true");
          //Set hostRecheckSeconds ke 10. Unit: detik.
          properties.setProperty("hostRecheckSeconds", "10");
          try {
              Class.forName("org.postgresql.Driver");
              Connection connection = DriverManager.getConnection(jdbcUrl, properties);
              PreparedStatement preparedStatement = connection.prepareStatement("show hg_frontend_endpoints;" );
              ResultSet resultSet = preparedStatement.executeQuery();
              while (resultSet.next()) {
                  ResultSetMetaData rsmd = resultSet.getMetaData();
                  int columnCount = rsmd.getColumnCount();
                  Map map = new HashMap();
                  for (int i = 0; i < columnCount; i++) {
                      map.put(rsmd.getColumnName(i + 1).toLowerCase(), resultSet.getObject(i + 1));
                  }
                  System.out.println(map);
              }
          } catch (Exception exception) {
              exception.printStackTrace();
          }
      }
  }

• Kueri dipolling sebanyak 100 kali dan dialokasikan ke dua instans.

  import java.sql.*;
  import java.util.HashMap;
  import java.util.Map;
  import java.util.Properties;
  
  public class hatest {
      public static void main(String[] args) {
          int x = 1;
          while( x <= 100 ){
              //Konfigurasikan titik akhir dari instans utama Hologres.
              String endpoint1 = "hgpostcn-cn-wxxxxxxxx04-cn-hangzhou.hologres.aliyuncs.com:80";
              //Konfigurasikan titik akhir dari instans sekunder baca-saja Hologres.
              String endpoint2 = "hgpostcn-cn-wxxxxxxxx05-cn-hangzhou.hologres.aliyuncs.com:80";
              //Tentukan nama database yang ingin Anda hubungkan.
              String dbname = "postgres";
              String jdbcUrl = "jdbc:postgresql://" + endpoint1 + "," + endpoint2 + "/" + dbname ;
              Properties properties = new Properties();
              //Tentukan ID AccessKey dari akun yang digunakan untuk terhubung ke database.
              properties.setProperty("user", "xxx");
              //Tentukan rahasia AccessKey dari akun yang digunakan untuk terhubung ke database.
              properties.setProperty("password", "xxx");
              //Set targetServerType ke any. Ini memungkinkan JDBC terhubung ke instans apa pun yang titik akhirnya ditentukan dalam URL.
              properties.setProperty("targetServerType", "any");
              //Set loadBalanceHosts ke true untuk mengaktifkan pengaturan keseimbangan beban.
              properties.setProperty("loadBalanceHosts", "true");
              //Set hostRecheckSeconds ke 10. Unit: detik.
              properties.setProperty("hostRecheckSeconds", "10");
              try {
                  Class.forName("org.postgresql.Driver");
                  Connection connection = DriverManager.getConnection(jdbcUrl, properties);
                  PreparedStatement preparedStatement = connection.prepareStatement("show hg_frontend_endpoints;" );
                  ResultSet resultSet = preparedStatement.executeQuery();
                  while (resultSet.next()) {
                      ResultSetMetaData rsmd = resultSet.getMetaData();
                      int columnCount = rsmd.getColumnCount();
                      Map map = new HashMap();
                      for (int i = 0; i < columnCount; i++) {
                          map.put(rsmd.getColumnName(i + 1).toLowerCase(), resultSet.getObject(i + 1));
                      }
                      System.out.println(map);
                  }
              } catch (Exception exception) {
                  exception.printStackTrace();
              }
              x++;
          }
      }
  }

  Data metrik dari kedua instans menunjukkan bahwa jumlah koneksi dari kedua instans hampir sama. Untuk informasi lebih lanjut tentang cara melihat data metrik dari instans, lihat Lihat Metrik.

  • Metrik dari instans hgpostcn-cn-wxxxxxxxx04

  • Metrik dari instans hgpostcn-cn-wxxxxxxxx05