Koje kanale sinhronizacije biste koristili za…

Različiti kanali za sinhronizaciju se koriste za interakciju između više servisa, a izbor zavisi od zahteva za pouzdanošću, performansom, skalabilnošću i tipom interakcije (sinhrono ili asinhrono).

Glavni kanali sinhronizacije:

RESTful API: Sinhrona interakcija putem HTTP protokola. Jednostavnost implementacije, široko rasprostranjena. Pogodno za zahteve "upit-odgovor".

// Primer zahteva ka REST API koristeći HttpClient
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: Visokoperformansna, sinhrona interakcija korišćenjem Protocol Buffers. Efikasno za prenos strukturiranih podataka.

// Primer poziva gRPC servisa (klijentski deo)
// Potreban je kod generisan od strane protobuf-a
// managedChannel.build()
// stub = YourServiceGrpc.newBlockingStub(channel);
// Response response = stub.yourMethod(request);

Messaging (Message Queues): Asinhrona interakcija putem posrednika poruka (npr. Kafka, RabbitMQ, ActiveMQ). Garantuje dostavu poruka, omogućava implementaciju obrazaca Pub/Sub i Point-to-Point. Pogodno za visok teret i odvajanje servisa.

// Primer slanja poruke u tipičnu JMS red
// Potreban je JMS implementacija (npr. ActiveMQ klijent)
/*
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("Zdravo, svet!");
sender.send(message);

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

Event Buses: Asinhrona interakcija zasnovana na slanju i obradi događaja. Servisi se pretplaćuju na tipove događaja koji ih interesuju. Podstiče slabu povezanost. Implementira se preko posrednika poruka ili specijalizovanih okvira.
Shared Database: Direktna interakcija putem zajedničke baze podataka. Često se smatra anti-pattern-om u mikroservisnoj arhitekturi zbog visoke povezanosti i problema sa skalabilnošću i nezavisnošću implementacije. Može se koristiti u monolitima ili za keširanje podataka.

Izbor specifičnog kanala zavisi od:

Tipa interakcije: Sinhrono (potreban je trenutni odgovor) ili asinhrono (odgovor nije odmah potreban ili može biti kasnije).
Zahteva za pouzdanošću: Garancije dostave (najmanje jednom, najviše jednom, tačno jednom).
Performansi i skalabilnosti.
Složenosti podataka: Strukturirani ili nestrukturirani.
Odvajanja servisa: Koliko su servisi nezavisni.

Koje kanale sinhronizacije biste koristili za organizaciju interakcije između više usluga?