Bir neçə xidmət arasında qarşılıqlı əlaqəni təşkil…

Bir neçə xidmət arasında qarşılıqlı əlaqə üçün müxtəlif sinxronizasiya kanalları istifadə olunur, onların seçimi etibarlılıq, performans, miqyaslama və qarşılıqlı əlaqə növünə (sinxron və ya asinxron) əsaslanır.

Əsas sinxronizasiya kanalları:

RESTful API: HTTP protokolu ilə sinxron qarşılıqlı əlaqə. Sadə tətbiq, geniş yayılmışdır. "Sorğu-cavab" üçün uyğundur.

// HttpClient istifadə edərək REST API-ya sorğu nümunəsi
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class RestClientExample {

    public static void main(String[] args) throws Exception {
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("http://example.com/api/resource"))
                .build();

        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
        System.out.println(response.body());
    }
}

gRPC: Protocol Buffers istifadə edilən yüksək performanslı, sinxron qarşılıqlı əlaqə. Strukturlaşdırılmış məlumatların ötürülməsi üçün effektiv.

// gRPC xidməti çağırış nümunəsi (klient tərəfi)
// Əsl kodda protobuf tərəfindən yaradılmış kod tələb olunur.
// managedChannel.build()
// stub = YourServiceGrpc.newBlockingStub(channel);
// Response response = stub.yourMethod(request);

Messaging (Message Queues): Broker vasitəsilə asinxron qarşılıqlı əlaqə (məsələn, Kafka, RabbitMQ, ActiveMQ). Mesajların çatdırılmasını təmin edir, Pub/Sub və Point-to-Point nümunələrini həyata keçirməyə imkan verir. Yüksək yüklər və xidmətlərin ayrılması üçün uyğundur.

// Tipik JMS növbəsinə mesaj göndərmə nümunəsi
// JMS tətbiqi tələb olunur (məsələn, ActiveMQ müştərisi)
/*
Context initialContext = new InitialContext();
QueueConnectionFactory cf = (QueueConnectionFactory) initialContext.lookup("ConnectionFactory");
QueueConnection conn = cf.createQueueConnection();
QueueSession session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) initialContext.lookup("MyQueue");
QueueSender sender = session.createSender(queue);

TextMessage message = session.createTextMessage("Salam, Dünya!");
sender.send(message);

sender.close();
session.close();
conn.close();
*/

Event Buses: Sənədlərin göndərilməsi və işlənməsi əsasında asinxron qarşılıqlı əlaqə. Xidmətlər maraqlandıqları hadisə növlərinə abunə olurlar. Zəif bağlılığı təşviq edir. Brokerlər və ya xüsusi çərçivələr üzərində həyata keçirilir.
Shared Database: Birgə verilənlər bazası vasitəsilə birbaşa qarşılıqlı əlaqə. Mikrosistem memarlığında yüksək bağlılıq və miqyaslama və müstəqillik problemləri səbəbindən çox vaxt anti-patters kimi qəbul edilir. Monolitlərdə və ya məlumatların keşikdə saxlanması üçün istifadə edilə bilər.

Xüsusi kanal seçimi aşağıdakı amillərdən asılıdır:

Əlaqə növü: Dərhal cavab tələb edən (sinxron) və ya dərhal cavab tələb etməyən və ya sonra alınacaq (asinxron).
Etibarlılıq tələbləri: Çatdırılma zəmanətləri (ən az bir dəfə, ən çox bir dəfə, tam dəqiq bir dəfə).
Performans və miqyaslama.
Məlumatların mürəkkəbliyi: Strukturlaşdırılmış və ya strukturlaşdırılmamış.
Xidmətlərin ayrılması: Xidmətlərin nə dərəcədə müstəqil olması.

Bir neçə xidmət arasında qarşılıqlı əlaqəni təşkil etmək üçün hansı sinxronizasiya kanallarını istifadə edərdiniz?