Golang에서 요청 전달을 구현하고 지연 기능을 추가하는 방법-Golang-php.cn

Golang에서 요청 전달을 구현하고 지연 기능을 추가하는 방법

PHPz

풀어 주다： 2023-04-05 10:42:06

원래의

595명이 탐색했습니다.

웹 애플리케이션을 개발할 때 로드 밸런싱 구현, 요청 캐싱 등과 같은 처리를 위해 요청을 다른 서버로 전달해야 하는 경우가 많습니다. Golang은 효율적인 언어이며 표준 라이브러리의 net/http 패키지는 요청을 전달하는 다양한 방법을 제공합니다. 여기서는 Golang에서 요청 전달을 구현하고 지연 기능을 추가하는 방법에 대해 논의해 보겠습니다.

먼저 사용자 요청을 수신하기 위한 HTTP 서버를 생성해야 합니다. 데모의 편의를 위해 두 개의 HTTP 서버를 로컬로 시작하여 요청 전달을 시뮬레이션하겠습니다. 서버의 포트 중 하나는 8081이고 다른 하나는 8082입니다.

package main

import (
    "fmt"
    "log"
    "net/http"
)

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        log.Printf("request from: %s\n", r.RemoteAddr)
        resp, err := http.Get("http://127.0.0.1:8081")
        if err != nil {
            http.Error(w, err.Error(), http.StatusInternalServerError)
            return
        }
        defer resp.Body.Close()

        _, err = w.Write([]byte(fmt.Sprintf("[%s]: %s", r.RemoteAddr, resp.Status)))
        if err != nil {
            log.Printf("failed to write response: %s", err.Error())
        }
    })

    addr := ":8080"
    log.Printf("listening on %s...\n", addr)
    log.Fatal(http.ListenAndServe(addr, nil))
}

로그인 후 복사

다음으로 요청 전달을 구현하고 지연 기능을 추가하기 위해 코드를 수정해야 합니다. Golang은 비동기 작업을 잘 지원하므로 고루틴과 채널을 통해 지연을 구현할 수 있습니다.

package main

import (
    "fmt"
    "log"
    "net/http"
    "time"
)

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        log.Printf("request from: %s\n", r.RemoteAddr)

        // 使用channel来实现延时
        done := make(chan bool)
        go func() {
            time.Sleep(1 * time.Second)
            done <- true
        }()

        // 请求转发
        resp, err := http.Get("http://127.0.0.1:8081")
        if err != nil {
            http.Error(w, err.Error(), http.StatusInternalServerError)
            return
        }
        defer resp.Body.Close()

        _, err = w.Write([]byte(fmt.Sprintf("[%s]: %s", r.RemoteAddr, resp.Status)))
        if err != nil {
            log.Printf("failed to write response: %s", err.Error())
        }

        // 等待延时完成
        <-done
    })

    addr := ":8080"
    log.Printf("listening on %s...\n", addr)
    log.Fatal(http.ListenAndServe(addr, nil))
}

로그인 후 복사

위 코드에서는 채널을 생성하고 goroutine을 사용하여 1초 지연을 구현한 다음 http.Get()을 사용하여 요청을 전달하고 마지막으로 채널이 신호를 보낼 때까지 기다렸습니다. 지연이 완료되어야 사용자에게 응답이 반환됩니다. 이러한 방식으로 요청을 전달하는 동안 지연을 추가하는 기능이 실현됩니다.

고루틴과 채널을 사용하여 지연을 구현하는 것 외에도 아래와 같이 time 패키지에 제공되는 time.Sleep() 메서드를 사용할 수도 있습니다.