> 백엔드 개발 > Golang > Golang의 웹 프레임워크인 Iris 프레임워크를 사용하여 분산 구성 관리 구현

Golang의 웹 프레임워크인 Iris 프레임워크를 사용하여 분산 구성 관리 구현

WBOY
풀어 주다: 2023-06-24 08:56:48
원래의
865명이 탐색했습니다.

인터넷의 급속한 발전과 대중화로 인해 점점 더 많은 기업과 개인이 다양한 웹 애플리케이션을 개발하고 유지하기 시작했습니다. 이러한 애플리케이션은 일반적으로 프로덕션 환경, 테스트 환경, 개발 환경 등과 같은 다양한 환경에서 배포되고 실행되어야 합니다. 이러한 다양한 환경에서는 애플리케이션 구성이 다양할 수 있으며 이러한 구성은 비즈니스 요구 사항과 사용자 요구 사항에 맞게 지속적으로 조정 및 업데이트되어야 할 수 있습니다. 따라서 구성 관리는 매우 중요한 문제가 되었습니다.

구성 관리는 일종의 데이터 관리로 간주할 수 있으며, 주로 구성 데이터를 저장, 획득 및 수정하는 방법을 포함합니다. 안정적이고 효율적인 구성 관리 시스템을 구현하기 위해 etcd 또는 consul과 같은 분산 구성 관리 도구를 사용할 수 있습니다. 이러한 도구는 고가용성, 데이터 일관성 및 내결함성뿐만 아니라 복잡한 kv 스토리지 시스템과 같은 기능을 제공하여 구성 관리에 대한 강력한 지원을 제공할 수 있습니다.

이 글에서는 Golang의 웹 프레임워크인 Iris 프레임워크를 사용하여 분산 구성 관리를 구현하는 방법을 주로 소개합니다. Iris는 MVC 모드, 라우팅 관리, 종속성 주입 및 기타 여러 기능을 지원하는 사용하기 쉬운 고성능 웹 프레임워크입니다. 또한 구성 관리, 세션 관리 및 로깅 작업을 용이하게 할 수 있는 구성, 세션 및 로거 등과 같은 일부 패키지가 포함되어 있습니다. 여기서는 Iris를 사용하여 분산 KV 스토어에서 구성 데이터를 획득 및 수정하고 이를 다른 서버로 업데이트할 수 있는 간단한 구성 관리 시스템을 구현하겠습니다.

먼저 Iris 및 etcd-cli 도구를 설치해야 합니다. Iris는 Go 언어의 표준 라이브러리를 사용하므로 먼저 Go 언어 환경을 설치해야 합니다. 다음으로 Go 명령줄 도구를 사용하여 Iris를 설치할 수 있습니다.

go get -u github.com/kataras/iris
로그인 후 복사

마찬가지로 명령줄에서 etcd 클러스터를 관리할 수 있도록 etcd-cli 도구도 설치해야 합니다. 바이너리를 다운로드하여 etcd의 공식 솔루션에서 직접 사용할 수 있습니다.

wget https://github.com/etcd-io/etcd/releases/download/v3.5.0/etcd-v3.5.0-linux-amd64.tar.gz
tar xzf etcd-v3.5.0-linux-amd64.tar.gz
cd etcd-v3.5.0-linux-amd64
로그인 후 복사

다음으로 etcd 클러스터를 실행하고 키-값 쌍을 여기에 추가할 수 있습니다. etcd 서비스는 다음 명령을 사용하여 시작할 수 있습니다:

./etcd --name node1 --initial-advertise-peer-urls http://127.0.0.1:2380 
  --listen-peer-urls http://127.0.0.1:2380 
  --listen-client-urls http://127.0.0.1:2379,http://127.0.0.1:4001 
  --advertise-client-urls http://127.0.0.1:2379,http://127.0.0.1:4001 
  --initial-cluster-token etcd-cluster-1 
  --initial-cluster node1=http://127.0.0.1:2380,node2=http://127.0.0.1:2381,node3=http://127.0.0.1:2382 
  --initial-cluster-state new
로그인 후 복사

여기서는 노드 중 하나(node1)가 리더인 3개의 노드가 있는 etcd 클러스터를 시작했습니다. 노드는 포트 2380을 통해 서로 통신하며, etcd 클라이언트는 포트 2379 또는 포트 4001을 통해 노드에 연결할 수 있습니다. 이러한 매개변수에 대한 자세한 설명은 etcd 공식 문서에서 확인할 수 있습니다.

다음으로 etcd-cli 도구를 사용하여 일부 키-값 쌍을 분산 스토리지에 추가할 수 있습니다. 예를 들어, 일부 구성 데이터가 포함된 "app_config"라는 디렉터리를 추가할 수 있습니다.

./etcdctl --endpoints http://127.0.0.1:2379 put /app_config/database_url "mysql://root:123456@localhost:3306/test_db"
로그인 후 복사

이렇게 하면 etcd 클러스터에 데이터 조각이 추가됩니다. 여기서 "/app_config/database_url"은 키이고 "mysql: / /root:123456@localhost:3306/test_db" 값입니다. 이 데이터는 모든 노드에서 액세스 및 수정이 가능하므로 분산 구성 관리가 가능합니다.

이제 Iris 프레임워크를 사용하여 구성 관리 시스템을 구축할 수 있습니다. 먼저 프로그램에서 Iris 프레임워크와 etcd 라이브러리를 참조하고 Iris 애플리케이션을 생성해야 합니다.

package main

import (
    "context"
    "github.com/coreos/etcd/client"
    "github.com/kataras/iris/v12"
    "github.com/kataras/iris/v12/middleware/logger"
    "github.com/kataras/iris/v12/middleware/recover"
)

var app *iris.Application
var etcdEndpoints []string

func main() {
    app = iris.New()
    app.Use(recover.New())
    app.Use(logger.New())
    app.Get("/config", getConfigHandler)
    app.Put("/config", updateConfigHandler)
    app.Run(iris.Addr(":8080"), iris.WithoutServerError(iris.ErrServerClosed))
}
로그인 후 복사

여기서 Iris 애플리케이션의 라우팅 규칙을 설정합니다. 여기서 "/config"는 구성 데이터를 얻고 업데이트하기 위한 API입니다. 상호 작용. 또한 오류 복구용과 로깅용으로 각각 하나씩 두 개의 미들웨어를 사용했습니다. 이러한 미들웨어는 애플리케이션의 성능과 안정성을 최적화하는 데 도움이 될 수 있습니다.

다음으로 etcd 클러스터에 연결하고 구성 관리를 수행할 수 있도록 etcd 클라이언트를 생성해야 합니다. 다음 코드를 사용하여 etcd 클라이언트를 생성할 수 있습니다.

    etcdEndpoints = []string{"http://127.0.0.1:2379"}

    cfg := client.Config{
        Endpoints: etcdEndpoints,
    }
    etcdClient, err := client.New(cfg)
    if err != nil {
        panic(err)
    }
로그인 후 복사

여기에서는 etcd 클러스터의 주소를 지정하고 client.Config를 사용하여 etcd 클라이언트를 초기화합니다. TLS 인증서, 사용자 이름, 비밀번호 등과 같은 다른 구성 옵션을 설정할 수도 있습니다.

이제 getConfigHandler 및 updateConfigHandler의 로직을 구현하여 구성 데이터를 쉽게 얻고 업데이트할 수 있습니다. getConfigHandler의 구현은 다음과 같습니다.

func getConfigHandler(ctx iris.Context) {
    key := ctx.URLParam("key")
    if key == "" {
        ctx.StatusCode(iris.StatusBadRequest)
        ctx.JSON(map[string]string{
            "error": "missing key parameter",
        })
        return
    }

    api := client.NewKeysAPI(etcdClient)
    resp, err := api.Get(context.Background(), key, nil)
    if err != nil {
        ctx.StatusCode(iris.StatusInternalServerError)
        ctx.JSON(map[string]string{
            "error": err.Error(),
        })
        return
    }

    ctx.StatusCode(iris.StatusOK)
    ctx.JSON(resp.Node.Value)
}
로그인 후 복사

여기에서는 먼저 URL 매개변수에서 얻을 구성 키를 얻은 다음 etcd의 KeysAPI를 사용하여 구성 데이터를 얻습니다. 해당 키를 찾을 수 없으면 오류 정보가 포함된 상태 코드 400의 응답이 반환됩니다. 데이터가 성공적으로 획득되면 키에 해당하는 값이 포함된 상태 코드 200의 응답이 반환됩니다.

updateConfigHandler의 구현은 다음과 같습니다.

func updateConfigHandler(ctx iris.Context) {
    key := ctx.URLParam("key")
    value := ctx.URLParam("value")
    if key == "" || value == "" {
        ctx.StatusCode(iris.StatusBadRequest)
        ctx.JSON(map[string]string{
            "error": "missing key or value parameter",
        })
        return
    }

    api := client.NewKeysAPI(etcdClient)
    _, err := api.Set(context.Background(), key, value, nil)
    if err != nil {
        ctx.StatusCode(iris.StatusInternalServerError)
        ctx.JSON(map[string]string{
            "error": err.Error(),
        })
        return
    }

    ctx.StatusCode(iris.StatusOK)
    ctx.JSON(map[string]string{
        "status": "success",
    })
}
로그인 후 복사

여기서 URL 매개변수에서 업데이트할 구성의 키와 값을 가져옵니다. 그런 다음 etcd의 KeysAPI를 사용하여 값을 지정된 키로 설정합니다. 업데이트가 성공하면 상태 코드 200이 포함된 응답과 "상태" 키가 포함된 JSON 데이터가 반환됩니다.

마지막으로 애플리케이션을 실행하고 컬과 같은 도구를 사용하여 API 인터페이스의 응답을 테스트해야 합니다. 다음 명령을 사용하여 애플리케이션을 시작할 수 있습니다.

go run main.go
로그인 후 복사

컬을 사용하여 API 인터페이스를 테스트할 수 있습니다. 예를 들어, 다음 명령을 사용하여 구성 데이터를 가져올 수 있습니다.

curl http://localhost:8080/config?key=/app_config/database_url
로그인 후 복사

그러면 다음과 같은 JSON 응답이 반환됩니다.

"mysql://root:123456@localhost:3306/test_db"
로그인 후 복사

다음 명령을 사용하여 구성 데이터를 업데이트할 수도 있습니다.

curl -X PUT -d "value=postgresql://user:password@localhost/dbname" http://localhost:8080/config?key=/app_config/database_url
로그인 후 복사

그러면 다음 명령이 반환됩니다. "/app_config/database_url" key 해당 값이 "postgresql://user:password@localhost/dbname"으로 변경됩니다. 업데이트가 성공하면 다음 JSON 응답이 반환됩니다.

{"status":"success"}
로그인 후 복사

到这里,我们已经实现了一个简单的分布式配置管理系统,该系统可以方便地获取和修改分布式KV存储中的配置数据。我们使用了Iris框架的路由、中间件和JSON响应等功能,以及etcd的KeysAPI来管理分布式存储。通过这样的方式,我们可以优化我们的应用程序的可靠性和性能,并提供更好的核心功能。

当然,实际情况下,我们需要考虑更多的方面,例如数据的安全性、版本控制、配置发布和回滚等问题。但是,通过使用Iris框架和etcd工具的技术,我们可以更加容易地构建和维护分布式配置管理系统,从而更好地满足业务和用户需求。

위 내용은 Golang의 웹 프레임워크인 Iris 프레임워크를 사용하여 분산 구성 관리 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

원천:php.cn
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿