golang は API ゲートウェイを実装します-Golang-php.cn

マイクロサービスアーキテクチャの人気に伴い、異なるサービス間の通信が非常に重要な問題になっています。マイクロサービスアーキテクチャの安定した動作を保証するには、マイクロサービスアーキテクチャ間の通信を制御および管理するための適切な方法が必要です。 API ゲートウェイは、マイクロサービス間の通信を制御および管理するために使用される重要なコンポーネントです。

API ゲートウェイは、すべての API リクエストを対応するマイクロサービスインスタンスにルーティングすることで、サービス機能の公開と通信制御を実装するマイクロサービスアーキテクチャのパターンです。 API ゲートウェイは、セキュリティ、プロトコル変換、負荷分散、アクセス制御、その他の機能をリクエストと応答に追加することで、マイクロサービスアーキテクチャのセキュリティと信頼性を強化することもできます。実際のアプリケーションでは、API ゲートウェイは通常クラウド上にデプロイされ、分散システムを構築するための重要なツールです。

Golang は、高性能、高同時実行性、高効率、そしてメンテナンスの容易さという特徴を持つ優れたプログラミング言語です。マイクロサービスアーキテクチャでは、golang のプログラミングモデルはサービス間の通信と一致しているため、golang を使用して独自の API ゲートウェイを実装する企業が増えています。この記事では、golangを使って簡単なAPIゲートウェイを実装する方法を紹介します。

API ゲートウェイのアーキテクチャを理解する

API ゲートウェイを実装する前に、API ゲートウェイの基本アーキテクチャを理解する必要があります。 API ゲートウェイの基本的なアーキテクチャは次のとおりです。

golang は API ゲートウェイを実装します

API ゲートウェイには次のコンポーネントが含まれています。

ルーター: 受信リクエストのルーティングを担当します。ルート異なるマイクロサービスインスタンスに。
ロードバランサー: さまざまなマイクロサービスインスタンスにリクエストを分散する役割を果たします。
セキュリティマネージャー (セキュリティマネージャー): API ゲートウェイのセキュリティを管理して、ネットワークリソースが不正なユニットによってアクセスされないようにします。
Validator (検証者): API 呼び出し元の身元を確認する責任を負います。
キャッシュマネージャー (キャッシュマネージャー): API 応答のキャッシュを管理し、マイクロサービスへの負荷を軽減します。
管理者パネル (管理パネル): API ゲートウェイとマイクロサービスの視覚的なコントロールパネルを管理者に提供します。

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 リクエストに対応する 2 つのルーターを作成しました。各ルーターで、パラメーターを使用して GET リクエストを定義します。これらのリクエストが呼び出されると、最初にルーター内でルーティングされ、次に対応するマイクロサービスインスタンスにリダイレクトされます。リダイレクトする前に、ReverseProxy を使用してリクエスト内の URL をマイクロサービスインスタンスの URL にリダイレクトする必要があることに注意してください。

ロードバランシング機能の追加

API ゲートウェイのもう 1 つの非常に重要なコンポーネントはロードバランサーです。ロードバランサーはリクエストを複数のマイクロサービスインスタンスに分散できるため、システム全体の信頼性とパフォーマンスが向上します。以下は、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 を使用して、コンストラクター内のすべてのマイクロサービスインスタンスのステータスを NextEndpoint 関数を通じて定期的に取得します。 LoadBalance では、負荷を順番に分散します。 LoadBalance 構造とその関連機能を、API ゲートウェイの異なるルート間で共有される独立したモジュールとして定義していることに注意してください。 API のルーティングでは、LoadBalance 構造で返された URL にリクエストをリダイレクトします。

概要

この記事を通じて、API ゲートウェイにおける golang の基本的なアプリケーションをすでに理解しているはずです。私たちはインフラストラクチャから始めて、ルーティング制御、負荷分散、セキュリティ管理、および API ゲートウェイのその他の機能を示すいくつかの単純な golang コードをデモンストレーションしました。このコンテンツが、マイクロサービスアーキテクチャにおける golang のアプリケーションをより深く理解し、プロジェクトに役立つことを願っています。

以上がgolang は API ゲートウェイを実装しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。