Java 프레임워크에서 미들웨어를 사용하여 로드 밸런싱 및 장애 조치 관리-java지도 시간-php.cn

Java 프레임워크에서 미들웨어를 사용하여 로드 밸런싱 및 장애 조치 관리

WBOY

풀어 주다： 2024-06-03 15:41:02

원래의

1050명이 탐색했습니다.

최신 분산 시스템의 가용성과 성능을 보장하려면 로드 밸런싱과 장애 조치가 중요합니다. Java 프레임워크는 성숙한 미들웨어 솔루션을 통해 이러한 기능을 쉽게 구현할 수 있습니다. 로드 밸런서를 사용하면 수신 트래픽을 백엔드 서버 클러스터에 균등하게 분산하여 확장성과 가용성을 높일 수 있습니다. 장애 조치는 구성 요소에 오류가 발생하면 트래픽을 정상 구성 요소로 리디렉션하여 애플리케이션의 안정적인 작동을 보장할 수 있습니다. 이 문서에서는 Google Cloud에서 대상 풀, 상태 확인, 부하 분산기를 만드는 실제 사례를 포함하여 자바 프레임워크에서 부하 분산 및 장애 조치를 위해 미들웨어를 사용하는 구체적인 사례를 살펴봅니다.

Java 프레임워크에서 미들웨어를 사용하여 로드 밸런싱 및 장애 조치 관리

Java 프레임워크의 로드 밸런싱 및 장애 조치: 미들웨어 사용

최신 분산 시스템에서 로드 밸런싱 및 장애 조치는 매우 중요합니다. 이를 통해 애플리케이션이 가용성과 성능을 유지하면서 피크 트래픽이나 구성 요소 오류를 견딜 수 있도록 보장합니다. Java 프레임워크는 다양한 성숙한 미들웨어 솔루션을 통해 이러한 기능을 쉽게 구현할 수 있습니다.

로드 밸런서

로드 밸런서는 더 나은 확장성과 가용성을 위해 수신 트래픽을 백엔드 서버 클러스터 전체에 균등하게 분산합니다. Java에서 일반적으로 사용되는 로드 밸런서는 다음과 같습니다.

import com.google.cloud.compute.v1.GlobalForwardingRule;
import com.google.cloud.compute.v1.ForwardingRuleService;
import com.google.cloud.compute.v1.RegionForwardingRule;
import com.google.cloud.compute.v1.ForwardingRule;
import com.google.cloud.compute.v1.TargetPool;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;

public class CreateLoadBalancer {

  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample
    String project = "your-project-id";
    String zone = "zone-name"; // optional, only required for region-wide forwarding rules
    String region = "region-name"; // optional, only required for global forwarding rules
    String forwardingRuleName = "your-forwarding-rule-name";
    String targetPoolName = "your-target-pool-name";
    String healthCheckName = "your-health-check-name";
    String backendServiceName = "your-backend-service-name";
    String port = "8080"; // your port

    // Initialize client that will be used to send requests. This client only needs to be created
    // once, and can be reused for multiple requests. After completing all of your requests, call
    // the `client.close()` method on the client to safely
    // clean up any remaining background resources.
    try (ComputeEngine client = ComputeEngine.create()) {
      // Create a new forwarding rule
      ForwardingRule forwardingRule;
      if (region == null) {
        // Create regional forwarding rule
        forwardingRule =
            ForwardingRule.newBuilder()
                .setName(forwardingRuleName)
                .setTarget(String.format("/region/%s/targetPools/%s", region, targetPoolName))
                .addPortRange(port)
                .build();
        RegionForwardingRule regionForwardingRule =
            RegionForwardingRule.newBuilder().setForwardingRule(forwardingRule).setRegion(zone).build();
        forwardingRule = client.insertRegionForwardingRule(regionForwardingRule, zone);
      } else {
        // Create global forwarding rule
        forwardingRule =
            ForwardingRule.newBuilder()
                .setName(forwardingRuleName)
                .setTarget(String.format("/global/targetPools/%s", targetPoolName))
                .addPortRange(port)
                .build();
        GlobalForwardingRule globalForwardingRule =
            GlobalForwardingRule.newBuilder()
                .setForwardingRule(forwardingRule)
                .setProject(project)
                .build();
        forwardingRule = client.insertGlobalForwardingRule(globalForwardingRule);
      }
      System.out.printf("Forwarding rule %s created.\n", forwardingRule.getName());
    }
  }
}

로그인 후 복사

Failover

장애 조치는 서버나 데이터베이스와 같은 구성 요소에 오류가 발생할 때 정상적인 구성 요소로 트래픽을 리디렉션하는 프로세스입니다. Java에서 일반적으로 사용되는 장애 조치 솔루션은 다음과 같습니다.

import com.google.cloud.compute.v1.HealthCheck;
import com.google.cloud.compute.v1.HealthCheckService;
import com.google.cloud.compute.v1.RegionHealthCheck;
import com.google.cloud.compute.v1.ResourceGroupReference;
import com.google.cloud.compute.v1.TargetPool;
import com.google.cloud.compute.v1.TargetPoolService;
import java.io.IOException;

public class CreateHealthCheck {
  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample
    String project = "your-project-id";
    String zone = "zone-name";
    String region = "region-name";
    String targetPoolName = "your-target-pool-name";
    String healthCheckName = "your-health-check-name";

    // Initialize client that will be used to send requests. This client only needs to be created
    // once, and can be reused for multiple requests. After completing all of your requests, call
    // the `client.close()` method on the client to safely
    // clean up any remaining background resources.
    try (ComputeEngine client = ComputeEngine.create()) {
      // Create a new health check
      HealthCheck hc =
          HealthCheck.newBuilder()
              .setName(healthCheckName)
              .setType("TCP")
              .setPort(8080) // optional, ignored by TCP-based heath checks
              .addTcpHealthCheck(
                  com.google.cloud.compute.v1.TcpHealthCheck.newBuilder()
                      .setRequest("/index.html")
                      .setResponse("200"))
              .build();

      // Add the health check to target pool
      TargetPool targetPool =
          TargetPool.newBuilder()
              .setName(targetPoolName)
              .addHealthChecks(String.format("/zone/%s/healthChecks/%s", zone, healthCheckName))
              .build();

      if (region == null) {
        targetPool = client.updateRegionTargetPool(targetPool, zone);
      } else {
        targetPool = client.updateGlobalTargetPool(targetPool);
      }

      System.out.printf("Added health check %s to target pool %s.\n", healthCheckName, targetPoolName);
    }
  }
}

로그인 후 복사

실용 사례: Google Cloud Load Balancing 사용

다음은 Google Cloud Load Balancing을 사용하여 로드 밸런싱 및 장애 조치를 달성하는 실제 사례입니다.