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";
}