golang은 API 게이트웨이를 구현합니다.

마이크로서비스 아키텍처의 인기로 인해 서로 다른 서비스 간의 통신이 매우 중요한 문제가 되었습니다. 마이크로서비스 아키텍처의 안정적인 운영을 보장하기 위해서는 이들 간의 통신을 제어하고 관리하는 좋은 방법이 필요합니다. API 게이트웨이는 마이크로서비스 간의 통신을 제어하고 관리하는 데 사용되는 중요한 구성 요소입니다.

API 게이트웨이는 모든 API 요청을 해당 마이크로서비스 인스턴스로 라우팅하여 서비스 기능 노출 및 통신 제어를 달성하는 마이크로서비스 아키텍처의 패턴입니다. API 게이트웨이는 요청과 응답에 보안, 프로토콜 변환, 로드 밸런싱, 액세스 제어 및 기타 기능을 추가하여 마이크로서비스 아키텍처의 보안과 안정성을 향상시킬 수도 있습니다. 실제 애플리케이션에서 API 게이트웨이는 일반적으로 클라우드에 배포되며 분산 시스템을 구축하는 데 중요한 도구입니다.

golang은 고성능, 높은 동시성, 고효율 및 손쉬운 유지 관리라는 특징을 지닌 뛰어난 프로그래밍 언어입니다. 마이크로서비스 아키텍처에서 golang의 프로그래밍 모델은 서비스 간 통신과 일치하므로 점점 더 많은 회사가 golang을 사용하여 자체 API 게이트웨이를 구현하기 시작하고 있습니다. 이 기사에서는 golang을 사용하여 간단한 API 게이트웨이를 구현하는 방법을 소개합니다.

1. API 게이트웨이 아키텍처 이해

API 게이트웨이를 구현하기 전에 API 게이트웨이의 기본 아키텍처를 이해해야 합니다. API 게이트웨이의 기본 아키텍처는 다음과 같습니다.

API 게이트웨이에는 다음 구성 요소가 포함됩니다.

• Router(라우터): 들어오는 요청을 다른 마이크로서비스 인스턴스로 라우팅하는 역할을 합니다.
• 로드 밸런서: 다양한 마이크로서비스 인스턴스에 대한 요청 분산을 담당합니다.
• 보안 관리자(보안 관리자): 승인되지 않은 장치가 네트워크 리소스에 접근하지 못하도록 API 게이트웨이의 보안을 관리하는 역할을 담당합니다.
• Validator: API 호출자의 신원을 확인하는 역할을 담당합니다.
• 캐시 관리자(캐싱 관리자): API 응답의 캐시를 관리하고 마이크로서비스에 대한 부담을 줄이는 역할을 담당합니다.
• 관리자 패널(관리자 패널): 관리자에게 API 게이트웨이 및 마이크로서비스에 대한 시각적 제어판을 제공합니다.

2. API 게이트웨이 구현 코드

이제 golang을 사용하여 API 게이트웨이 코드를 구현하는 방법을 살펴보겠습니다. gin 프레임워크를 사용하여 API 게이트웨이의 기본 기능을 구현하겠습니다. 먼저 gin 프레임워크를 설치해야 합니다.

go get -u github.com/gin-gonic/gin

다음으로 gin 프레임워크를 통해 API 게이트웨이의 기본 라우팅 제어를 구현하기 위해 작성할 수 있는 첫 번째 샘플 코드는 다음과 같습니다.

package main

import (
    "net/http"

    "github.com/gin-gonic/gin"
)

func main() {
    router := gin.Default()

    router.GET("/", func(c *gin.Context) {
        c.JSON(http.StatusOK, gin.H{
            "message": "Hello, world!",
        })
    })

    router.Run(":8080") 
}

코드를 실행하고 http://에 액세스할 수 있습니다. localhost: 8080/ 코드가 제대로 작동하는지 확인합니다. 이제 API 게이트웨이의 라우팅 제어를 구현하기 위해 더 복잡한 코드를 작성해 보겠습니다. 이 예에서는 들어오는 요청을 다른 마이크로서비스 인스턴스로 라우팅하는 방법을 보여줍니다.

package main

import (
    "net/http"
    "net/http/httputil"
    "net/url"

    "github.com/gin-gonic/gin"
)

func main() {
    router := gin.Default()

    api1 := router.Group("/api1")
    api1.GET("/user/:id", func(c *gin.Context) {
        director := func(req *http.Request) {
            url, _ := url.Parse("http://user-service:8080")
            req.URL.Scheme = url.Scheme
            req.URL.Host = url.Host
            req.URL.Path = "/user/" + c.Param("id")
        }

        proxy := &httputil.ReverseProxy{Director: director}
        proxy.ServeHTTP(c.Writer, c.Request)
    })

    api2 := router.Group("/api2")
    api2.GET("/order/:id", func(c *gin.Context) {
        director := func(req *http.Request) {
            url, _ := url.Parse("http://order-service:8080")
            req.URL.Scheme = url.Scheme
            req.URL.Host = url.Host
            req.URL.Path = "/order/" + c.Param("id")
        }

        proxy := &httputil.ReverseProxy{Director: director}
        proxy.ServeHTTP(c.Writer, c.Request)
    })

    router.Run(":8080") 
}

이 예에서는 각각 서로 다른 API 요청에 해당하는 두 개의 라우터를 만들었습니다. 각 라우터에서 매개변수를 사용하여 GET 요청을 정의합니다. 이러한 요청이 호출되면 먼저 라우터에서 라우팅된 다음 해당 마이크로서비스 인스턴스로 리디렉션됩니다. 리디렉션을 수행하기 전에 ReverseProxy를 사용하여 요청의 URL을 마이크로서비스 인스턴스의 URL로 리디렉션해야 합니다.

3. 로드 밸런싱 기능 추가

API 게이트웨이의 또 다른 매우 중요한 구성 요소는 로드 밸런서입니다. 로드 밸런서는 요청을 여러 마이크로서비스 인스턴스에 분산하여 전체 시스템의 안정성과 성능을 향상시킬 수 있습니다. 다음은 golang을 사용하여 간단한 로드 밸런서를 구현하는 방법에 대한 코드 예제입니다.

먼저 Consul 및 Consul API를 설치해야 합니다.

go get github.com/hashicorp/consul/api

이제 Consul 및 Consul API를 사용하여 모든 마이크로서비스 인스턴스의 상태를 주기적으로 확인하고 로드 밸런서 로드 조건에 따라 동적으로 선택하는 Consul 클라이언트를 생성할 수 있습니다. 다음은 Consul 및 Consul API를 사용하여 클라이언트를 생성하기 위한 코드 예제입니다.

package main

import (
    "fmt"
    "log"
    "net/http"
    "net/http/httputil"
    "net/url"
    "sync"

    "github.com/gin-gonic/gin"
    "github.com/hashicorp/consul/api"
)

type ServiceEndpoints struct {
    Urls []string
}

type LoadBalance struct {
    Services map[string]ServiceEndpoints
    Current  map[string]int
    Mutex    sync.Mutex
}

func NewLoadBalance(consulAddress string) (*LoadBalance, error) {
    lb := &LoadBalance{
        Services: make(map[string]ServiceEndpoints),
        Current:  make(map[string]int),
    }

    conf := api.DefaultConfig()
    conf.Address = consulAddress
    client, err := api.NewClient(conf)
    if err != nil {
        return nil, err
    }

    services, _, err := client.Health().Service("user-service", "", true, nil)
    if err != nil {
        return nil, err
    }

    for _, svc := range services {
        serviceUrl := fmt.Sprintf("%v:%v", svc.Service.Address, svc.Service.Port)
        lb.Services["user-service"] = ServiceEndpoints{
            Urls: append(lb.Services["user-service"].Urls, serviceUrl),
        }
    }

    return lb, nil
}

func (lb *LoadBalance) NextEndpoint(serviceName string) string {
    lb.Mutex.Lock()
    defer lb.Mutex.Unlock()

    endpoints := lb.Services[serviceName]
    currentIndex := lb.Current[serviceName]
    nextIndex := (currentIndex + 1) % len(endpoints.Urls)
    lb.Current[serviceName] = nextIndex
    return endpoints.Urls[nextIndex]
}

func main() {
    router := gin.Default()

    lb, err := NewLoadBalance("localhost:8500")
    if err != nil {
        log.Fatal(err)
    }

    api1 := router.Group("/api1")
    api1.GET("/user/:id", func(c *gin.Context) {
        director := func(req *http.Request) {
            urlStr := lb.NextEndpoint("user-service")
            url, _ := url.Parse(urlStr)
            req.URL.Scheme = url.Scheme
            req.URL.Host = url.Host
            req.URL.Path = "/user/" + c.Param("id")
        }

        proxy := &httputil.ReverseProxy{Director: director}
        proxy.ServeHTTP(c.Writer, c.Request)
    })

    router.Run(":8080") 
}

이 예제에서는 먼저 Consul API를 사용하여 LoadBalance의 NextEndpoint 함수를 통해 생성자 및 인스턴스 사이의 모든 마이크로서비스 인스턴스 상태를 주기적으로 가져옵니다. 부하를 분산시키기 위해. LoadBalance 구조와 관련 기능을 API 게이트웨이의 다양한 경로에서 공유할 수 있는 독립 모듈로 정의합니다. API 라우팅에서는 요청을 LoadBalance 구조에 반환된 URL로 리디렉션합니다.

요약

이 글을 통해 API 게이트웨이에서 golang의 기본 적용을 이미 이해하셨을 것입니다. 우리는 인프라부터 시작하여 API 게이트웨이의 라우팅 제어, 로드 밸런싱, 보안 관리 및 기타 기능을 보여주는 몇 가지 간단한 golang 코드를 시연했습니다. 이 콘텐츠가 마이크로서비스 아키텍처에서 golang의 적용을 더 잘 이해하고 프로젝트에 도움이 되기를 바랍니다.

위 내용은 golang은 API 게이트웨이를 구현합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!