service de démarrage et d'arrêt de Golang-Golang-php.cn

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

王林

Libérer： 2023-05-10 11:37:36

original

1054 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

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并开始监听传入的请求。

启动服务

要启动服务，我们只需要使用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方法以启动服务。如果启动失败，我们会在控制台打印错误信息。

二、停止服务

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

修改服务定义

首先，我们需要向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）添加到该通道中。然后，我们将该管道添加到服务实例中。

修改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中侦听管道，等待关闭通知，并使用该通知执行优雅关闭。

停止服务

现在，我们只需要在客户端代码中创建新服务实例，调用其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

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 :

svc

Run

MyService

NewMyService

stopChan

Run

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

Run

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!