Feign Client — Kolaylığın Gizlediği Şeyler

Başka bir servisi çağırmak normalde otuz satır tekrar eden kod ister. Feign ile yalnızca bir arayüz yazarsın, çağrıyı yapan kodu Spring üretir. RestTemplate ile yazacağın otuz satırlık tekrar kaybolur.

Feign ne verir, ne vermez?

1
@FeignClient(name = "pricing")
2
interface PricingClient {
3
    @GetMapping("/prices/{id}")
4
    Price get(@PathVariable String id);
5
}

Gövde yazmazsın; Spring bu arayüzün uygulamasını üretir ve bean olarak verir. Kazanç tekrarın silinmesi: URL kurma, serileştirme, yanıt okuma tek yerde.

Vermediği şeyler de aynı ölçüde net: timeout, retry politikası, hata çevirimi, devre kesici. Bunların hiçbiri Feign’i eklemekle gelmez — hepsi ayrı ve açık kararlardır.

Yerel çağrı gibi görünür, değildir

pricing.get(id) satırına bak. Bir List.get(id) çağrısından hiçbir farkı yok.

Oysa arkasında servis keşfi, bağlantı kurma, ağ üzerinden istek, serileştirme ve karşı tarafın yükü var. İmza bunların hiçbirini söylemiyor — ve söylemediği için kod incelemesinde kimse sormuyor.

Satır satır: aynı arayüz, üç sürpriz

Son adım en kritik olanı: retry katmanlar boyunca toplanmaz, çarpılır. Zorlanan bir servise en çok yüklenen taraf, onu kurtarmaya çalışan çağıran olur.

Kendin gör

Fiyat servisinin davranışını, metodu, timeout’ları, retry’ı ve dismiss404’ü değiştir. Üstte ayarların kod hâli, altta her denemenin thread’i ne kadar tuttuğu var.

1. Varsayılanlarla oynat. Fiyat servisi yavaş, retry yok. Tek satırlık pricing.get(id) bir thread’i tam 60 saniye tutuyor ve sonunda istisna atıyor.
2. Retryer.Default’u aç. Beş deneme ve aralarındaki beklemeler: aynı çağrı artık beş dakikadan uzun sürüyor. Spring Cloud OpenFeign’ın retry’ı varsayılan olarak kapatmasının sebebi bu.
3. Read timeout’u 2 saniyeye indir, retry’ı kapat. Çağrı iki saniyede başarısız oluyor. Hızlı başarısızlık?Terimin tanımını açfail fastBaşarısız olacağı belli olan bir işlemi beklemeden reddetmek. Breaker açıkken çağrının ağa hiç çıkmaması budur — çağıranın thread'i timeout boyunca tutulmaz.Sözlükte gör →, yavaş başarısızlıktan iyidir.
4. POST seç ve retry’ı yeniden aç. Yavaş sunucu vazgeçilen her isteği yine de işliyor: tek bir rezervasyon isteği beş kayıt bırakıyor.
5. Servisi 404’e çevir. Retry açık olsa da tek deneme yapılıyor, çünkü 404 bir ağ hatası değil. dismiss404 ile istisna yerine Optional.empty() dönüyor.

Tuzaklar

Sessiz fallback. Devre kesici fallback’i boş liste döndürüyorsa kullanıcı hatasız ama yanlış bir sayfa görür ve kimse alarm almaz. Fallback bir gizleme aracı değil, bilinçli bir azaltılmış hizmet kararıdır — ve her zaman metriğe yazılmalıdır.

Retry’ı idempotent olmayan çağrıya koymak. POST /orders timeout aldığında siparişin oluşup oluşmadığını bilemezsin. Idempotency?Terimin tanımını açidempotencyAynı işlemin bir kez de on kez de çalışsa aynı sonucu vermesi. Dağıtık sistemde timeout aldığında işlemin yapılıp yapılmadığını bilemediğin için zorunludur.Sözlükte gör → anahtarı yoksa retry, ikinci bir sipariş demektir.

Sağlayıcının yayınladığı ortak client kütüphanesi kolay görünür: fiyat ekibi PricingClient’ı paketleyip yayınlar. Bedeli, tüketicilerin sağlayıcının sürüm takvimine bağlanması ve arayüzün sağlayıcının modeline göre şekillenmesidir. Arayüzü tüketici tanımlarsa bağımlılık oku doğru yöne bakar.

Timeout bütçesini hesaba katmamak. Timeout bütçesi?Terimin tanımını açtimeout bütçesiBir zincirdeki timeout değerlerinin içten dışa artacak şekilde bölünmesi. Dıştaki içtekinden küçükse çağıran vazgeçer ama iş devam eder.Sözlükte gör → aşağı indikçe küçülmeli ve retry’lı toplam süre dıştaki bütçeyi aşmamalı. Aşarsa çağıran vazgeçer, senin çağrın devam eder.

Aşağıdaki örnek bir bankanın transfer servisinden; hesap servisine Feign ile soruyor. Feign’in vermediği dört şey açıkça ekleniyor: istemci başına zaman aşımı, bilinçli retry kararı, hata çevirimi ve Feign’i domain’den saklayan bir adaptör. Test gerçek HTTP’yi WireMock ile taklit ediyor.

1
// The transfer service asks the account service: does this IBAN exist, is it open, whose is it?
2
@FeignClient(name = "accounts", url = "${accounts.url}", configuration = AccountFeignConfig.class)
3
interface AccountClient {
4

5
    @GetMapping("/accounts/{iban}")
6
    AccountDto get(@PathVariable String iban);     // looks local; it is a network call
7
}

1
accounts:
2
  url: http://account-service
3

4
spring:
5
  cloud:
6
    openfeign:
7
      client:
8
        config:
9
          accounts:
10
            connect-timeout: 500        # ms
11
            read-timeout: 1500          # ms, below the caller's own budget
12
            logger-level: basic
13
            dismiss404: true            # 404 -> empty body instead of an exception

1
class AccountFeignConfig {
2

3
    // Not annotated @Configuration: it applies to this client only, not to every Feign client.
4

5
    @Bean
6
    Retryer retryer() {
7
        return Retryer.NEVER_RETRY;     // retries live in one place (resilience4j), never in two
8
    }
9

10
    @Bean
11
    ErrorDecoder accountErrorDecoder() {
12
        return (methodKey, response) -> switch (response.status()) {
13
            case 400 -> new InvalidIbanException(methodKey);
14
            case 429, 503 -> new AccountsUnavailableException("accounts busy: " + response.status());
15
            default -> new ErrorDecoder.Default().decode(methodKey, response);
16
        };
17
    }
18
}

1
@Component
2
class AccountAdapter implements AccountLookup {      // AccountLookup is the domain's own port
3

4
    private final AccountClient client;
5

6
    AccountAdapter(AccountClient client) {
7
        this.client = client;
8
    }
9

10
    @Override
11
    public Optional<Beneficiary> beneficiaryOf(Iban iban) {
12
        try {
13
            AccountDto dto = client.get(iban.value());        // null body when 404 (dismiss404)
14
            return Optional.ofNullable(dto).map(AccountDto::toBeneficiary);
15
        } catch (RetryableException ex) {                      // connect/read timeout
16
            throw new AccountsUnavailableException("accounts timed out", ex);
17
        }
18
    }
19
}

1
@SpringBootApplication
2
@EnableFeignClients
3
public class TransferApplication {
4

5
    public static void main(String[] args) {
6
        SpringApplication.run(TransferApplication.class, args);
7
    }
8
}

1
@SpringBootTest(properties = "accounts.url=http://localhost:${wiremock.server.port}")
2
@AutoConfigureWireMock(port = 0)
3
class AccountAdapterTest {
4

5
    private static final String IBAN = "TR330006100519786457841326";
6

7
    @Autowired AccountLookup accounts;
8

9
    @Test
10
    void unknownIbanIsEmpty() {
11
        stubFor(get("/accounts/" + IBAN).willReturn(notFound()));
12
        assertThat(accounts.beneficiaryOf(new Iban(IBAN))).isEmpty();
13
    }
14

15
    @Test
16
    void slowServerFailsFastWithADomainError() {
17
        stubFor(get("/accounts/" + IBAN)
18
                .willReturn(okJson("{\"name\":\"Ayşe Yılmaz\",\"status\":\"OPEN\"}").withFixedDelay(3_000)));
19
        assertThatThrownBy(() -> accounts.beneficiaryOf(new Iban(IBAN)))
20
                .isInstanceOf(AccountsUnavailableException.class);   // after 1.5 s, not 3 s
21
    }
22
}

Kendini sına