Comment puis-je arrêter progressivement un serveur Go et gérer l'erreur « Utilisation d'une connexion réseau fermée » ?

Gérer l'arrêt du serveur dans Go

Dans Go, gérer l'arrêt d'un serveur en écoute est essentiel pour gérer correctement les connexions client et éviter les erreurs inattendues . Cet article aborde les défis liés à l'arrêt d'un serveur d'écoute et présente une approche robuste pour y parvenir.

Identification du défi

Lorsqu'un serveur écoute les connexions entrantes, l'option Accepter La méthode se bloque jusqu'à ce qu'une connexion soit établie ou qu'une erreur se produise. Bien qu'utile pour accepter en permanence des connexions, ce comportement de blocage présente un défi lorsqu'il faut arrêter le serveur en douceur. La fermeture du socket d'écoute pour signaler la fin de l'opération peut entraîner une erreur impossible à distinguer des autres erreurs d'acceptation.

Le problème "FIXME"

Dans le code fourni, la méthode serve tente de détecter l'erreur « utilisation d'une connexion réseau fermée » lorsque le socket d'écoute est fermé, mais cette erreur n'est pas exportée depuis le package net. Cette limitation rend difficile la gestion gracieuse de l'arrêt du serveur sans recourir à de vilaines techniques de gestion des erreurs.

Une meilleure approche

Pour résoudre ce problème, une approche plus efficace implique en utilisant un canal dédié (terminé) pour signaler l'intention du serveur de s'arrêter. Lorsque la méthode stop est appelée, une valeur est envoyée au canal terminé.

Dans la méthode serve, la boucle Accept est modifiée pour vérifier la présence du signal dans le canal terminé avant de consigner l'erreur Accept. Si un signal est présent, l'erreur d'acceptation est supprimée.

Exemple de code

Les extraits de code modifiés ci-dessous démontrent comment cette approche est implémentée :

// Serve method
func (es *EchoServer) serve() {
  for {
    conn, err := es.listen.Accept()
    if err != nil {
      select {
      case <-es.done:
        // If we called stop() then there will be a value in es.done, so
        // we'll get here and we can exit without showing the error.
      default:
        log.Printf("Accept failed: %v", err)
      }
      return
    }
    go es.respond(conn.(*net.TCPConn))
  }
}

// Stop method
func (es *EchoServer) stop() {
  es.done <- true   // We can advance past this because we gave it buffer of 1
  es.listen.Close() // Now it the Accept will have an error above
}

En utilisant le canal done, le serveur peut gérer gracieusement l'arrêt en envoyant un signal à la méthode serve, ce qui supprime l'erreur « utilisation d'une connexion réseau fermée » et garantit un arrêt propre.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!