Maison > développement back-end > Golang > le corps du texte

service de démarrage et d'arrêt de Golang

王林
Libérer: 2023-05-10 11:37:36
original
1018 Les gens l'ont consulté

golang est actuellement l'un des langages de programmation les plus populaires et peut être utilisé pour développer diverses applications, y compris des applications serveur. Cet article explique comment utiliser Golang pour écrire du code permettant de démarrer et d'arrêter les services.

1. Démarrez le service

  1. Définissez le service

Tout d'abord, nous devons définir une structure de service. Voici un exemple simple :

type MyService struct {
    httpServer *http.Server
}

func NewMyService(port string) *MyService {
    return &MyService{
        httpServer: &http.Server{
            Addr: fmt.Sprintf(":%s", port),
        },
    }
}

func (svc *MyService) Run() error {
    return svc.httpServer.ListenAndServe()
}
Copier après la connexion

Dans cet exemple, nous définissons une structure nommée MyService, qui contient une instance de http.Server. Nous définissons également la fonction NewMyService, qui crée une instance de la structure MyService. Cette fonction doit transmettre un numéro de port et l'utiliser pour configurer la propriété Addr de http.Server. Enfin, nous définissons également une méthode Run, qui démarre http.Server et commence à écouter les requêtes entrantes. MyService的结构体,其中包含http.Server的实例。我们还定义了NewMyService函数,它创建MyService结构体的实例。该函数需要传递一个端口号,并将其用于配置http.Server的Addr属性。最后,我们还定义了一个Run方法,它启动http.Server并开始监听传入的请求。

  1. 启动服务

要启动服务,我们只需要使用NewMyService函数创建服务实例,然后调用Run方法即可:

svc := NewMyService("8080")
err := svc.Run()
if err != nil {
    fmt.Printf("Failed to start service: %s", err)
    return
}
Copier après la connexion

这段代码会创建一个名为svc的新服务实例,并将其配置为监听端口8080。然后,我们调用Run方法以启动服务。如果启动失败,我们会在控制台打印错误信息。

二、停止服务

停止服务比启动服务稍微复杂一些,因为我们需要处理优雅关闭的过程。优雅关闭可以确保服务器在关闭之前完成任何正在处理的请求。下面是一种实现优雅关闭的方法:

  1. 修改服务定义

首先,我们需要向MyService结构体添加一个关闭通道:

type MyService struct {
    httpServer *http.Server
    stopChan   chan os.Signal
}
Copier après la connexion

这个关闭通道会用于通知服务器何时停止。我们还需要修改NewMyService函数,以便将关闭通道添加到服务实例中:

func NewMyService(port string) *MyService {
    stopChan := make(chan os.Signal, 1)
    signal.Notify(stopChan, os.Interrupt, syscall.SIGTERM)

    return &MyService{
        httpServer: &http.Server{
            Addr: fmt.Sprintf(":%s", port),
        },
        stopChan: stopChan,
    }
}
Copier après la connexion

在这里,我们定义了一个名为stopChan的管道,并使用signal.Notify函数将操作系统的终止信号(例如ctrl-c)添加到该通道中。然后,我们将该管道添加到服务实例中。

  1. 修改Run方法

接下来,我们需要修改Run方法。我们将在该方法中使用一个goroutine来侦听关闭通道,如果通道收到信号,则停止http.Server并关闭该函数:

func (svc *MyService) Run() error {
    go func() {
        <-svc.stopChan
        ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
        defer cancel()
        svc.httpServer.Shutdown(ctx)
    }()

    return svc.httpServer.ListenAndServe()
}
Copier après la connexion

在这里,我们通过使用context.WithTimeout方法定义了一个TimeoutContext,以确保http.Server有足够的时间来完成正在处理的请求。然后,我们调用http.Server的Shutdown方法以停止正在运行的服务器。最后,我们在goroutine中侦听管道,等待关闭通知,并使用该通知执行优雅关闭。

  1. 停止服务

现在,我们只需要在客户端代码中创建新服务实例,调用其Run方法并等待ctrl-c或其他终止信号即可:

svc := NewMyService("8080")
err := svc.Run()
if err != nil {
    fmt.Printf("Failed to start service: %s", err)
    return
}

// wait for shutdown signal
Copier après la connexion

在这里,我们创建了服务实例,并调用其Run

    Démarrer le service

    Pour démarrer le service, il suffit d'utiliser la fonction NewMyService pour créer une instance de service, puis d'appeler Run Méthode  :

    rrreee🎜Ce code créera une nouvelle instance de service nommée svc et la configurera pour écouter sur le port 8080. Ensuite, nous appelons la méthode Run pour démarrer le service. Si le démarrage échoue, nous imprimerons un message d'erreur sur la console. 🎜🎜2. Arrêter le service🎜🎜Arrêter le service est légèrement plus compliqué que démarrer le service, car nous devons gérer le processus d'arrêt progressif. L'arrêt progressif garantit que le serveur termine toutes les requêtes en cours avant de s'arrêter. Voici un moyen d'obtenir un arrêt progressif : 🎜🎜🎜Modifiez la définition du service🎜🎜🎜Tout d'abord, nous devons ajouter un canal d'arrêt à la structure MyService : 🎜rrreee🎜Ce canal d'arrêt sera utilisé pour informer le serveur quand arrêter. Nous devons également modifier la fonction NewMyService pour que le canal de fermeture soit ajouté à l'instance de service : 🎜rrreee🎜Ici, nous définissons un tube appelé stopChan et utilisons signal.Notify ajoute le signal de terminaison du système d'exploitation (tel que ctrl-c) au canal. Nous ajoutons ensuite le pipeline à l'instance de service. 🎜
      🎜Modifier la méthode Run🎜🎜🎜Ensuite, nous devons modifier la méthode Run. Nous utiliserons une goroutine dans cette méthode pour écouter fermer le canal et si le canal reçoit un signal, arrêter le http.Server et fermer la fonction : 🎜rrreee🎜Ici, nous fermons le canal en utilisant context.WithTimeout La méthode définit un TimeoutContext pour garantir que http.Server dispose de suffisamment de temps pour terminer la demande en cours de traitement. Nous appelons ensuite la méthode Shutdown de http.Server pour arrêter le serveur en cours d'exécution. Enfin, nous écoutons le tube dans la goroutine, attendons la notification d'arrêt et utilisons cette notification pour effectuer un arrêt progressif. 🎜<ol start="3">🎜Arrêtez le service 🎜🎜🎜Il ne nous reste plus qu'à créer une nouvelle instance de service dans le code client, appeler sa méthode <code>Run et attendre ctrl-c ou autre signal de terminaison C'est tout : 🎜rrreee🎜Ici, nous créons l'instance de service et appelons sa méthode Run. Ensuite, il nous suffit d'attendre ctrl-c ou un autre signal de fin. 🎜🎜Résumé🎜🎜Dans cet article, nous avons appris à écrire du code pour démarrer et arrêter les services à l'aide de Golang afin de fournir une expérience d'arrêt stable et gracieuse pour votre application. Que vous écriviez un service web, une API RESTful ou tout autre type de service, ces technologies auront un impact positif sur la fiabilité et la stabilité de votre application. 🎜

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!

source:php.cn
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal