Sobes.tech
Middle+

Quali pattern di microservizi conosci?

sobes.tech AI

Risposta dell'AI

  • Service Discovery: Consente ai servizi di trovare gli uni gli altri. Implementato tramite un registro centralizzato (ad esempio, ZooKeeper, Consul, etcd).
  • API Gateway: Punto di ingresso unico per i clienti, che instrada le richieste ai servizi corrispondenti. Fornisce autenticazione, autorizzazione e bilanciamento del carico.
  • Circuit Breaker (Interruttore automatico): Previene i guasti a cascata, disattivando temporaneamente le chiamate ai servizi non funzionanti.
  • Bulkhead: Isola le risorse di diversi servizi, prevenendo la loro influenza reciproca in caso di guasti.
  • Saga: Gestisce transazioni distribuite, garantendo la coerenza dei dati tra più servizi tramite una sequenza di transazioni locali e azioni di compensazione.
  • Event Sourcing (Archiviazione orientata agli eventi): Memorizza tutte le modifiche dei dati sotto forma di sequenza di eventi, fornendo una storia completa degli stati.
  • CQRS (Segregazione di responsabilità comando e query): Divide la logica di lettura e scrittura dei dati in modelli diversi, ottimizzando le prestazioni per ogni tipo di operazione.
  • Database per servizio: A ogni servizio viene assegnato un proprio database per garantire indipendenza e decentralizzazione.
  • Strangler Fig: Sostituzione progressiva di un'applicazione monolitica con microservizi, reindirizzando parti del traffico.

Esempio di implementazione di Circuit Breaker in PHP (pseudocodice):

<?php
// Classe Circuit Breaker
class CircuitBreaker
{
    private $threshold; // Soglia di fallimenti
    private $timeout; // Tempo di permanenza aperto
    private $failures = 0; // Numero di fallimenti
    private $lastFailureTime = 0; // Tempo dell'ultimo fallimento
    private $state = 'CLOSED'; // Stato: CLOSED, OPEN, HALF_OPEN

    public function __construct(int $threshold, int $timeout)
    {
        $this->threshold = $threshold;
        $this->timeout = $timeout;
    }

    public function execute(callable $operation)
    {
        switch ($this->state) {
            case 'OPEN':
                if (time() - $this->lastFailureTime > $this->timeout) {
                    $this->state = 'HALF_OPEN';
                    try {
                        $result = $operation();
                        $this->reset();
                        return $result;
                    } catch (\Exception $e) {
                        $this->recordFailure();
                        throw $e;
                    }
                } else {
                    throw new \Exception("Circuit breaker is open");
                }
                break;
            case 'HALF_OPEN':
                // Logica per HALF-OPEN già sopra
                break;
            case 'CLOSED':
            default:
                try {
                    $result = $operation();
                    $this->reset();
                    return $result;
                } catch (\Exception $e) {
                    $this->recordFailure();
                    throw $e;
                }
                break;
        }
    }

    private function recordFailure(): void
    {
        $this->failures++;
        $this->lastFailureTime = time();
        if ($this->failures >= $this->threshold) {
            $this->state = 'OPEN';
        }
    }

    private function reset(): void
    {
        $this->failures = 0;
        $this->lastFailureTime = 0;
        $this->state = 'CLOSED';
    }
}

// Uso
$breaker = new CircuitBreaker(3, 60);
try {
    $data = $breaker->execute(function() {
        if (rand(0, 1) == 0) {
             throw new \Exception("Service unavailable");
        }
        return ['status' => 'ok'];
    });
    echo "Success: " . json_encode($data) . "\n";
} catch (\Exception $e) {
    echo "Failure: " . $e->getMessage() . "\n";
}