Golang 마이크로서비스 프레임워크를 사용하여 분산 시스템 만들기

Golang 마이크로서비스 프레임워크를 사용하여 분산 시스템 생성: Golang 설치, 마이크로서비스 프레임워크(예: Gin)를 선택하여 Gin 마이크로서비스 생성, 엔드포인트를 추가하여 마이크로서비스 배포, 애플리케이션 구축 및 실행하여 주문 및 재고 마이크로서비스 생성, 엔드포인트 사용 주문 및 재고 처리 Kafka와 같은 메시징 시스템을 사용하여 마이크로서비스 연결 sarama 라이브러리를 사용하여 주문 정보 생성 및 소비

Golang 마이크로서비스 프레임워크를 사용하여 분산 시스템 만들기

이 기사에서는 단계별로 안내하겠습니다. Golang 마이크로서비스 프레임워크 공식 시스템을 사용하여 배포판을 만듭니다. 또한 마이크로서비스 패턴을 사용하여 실제 애플리케이션을 만드는 방법을 보여주는 실제 사례도 제공합니다.

전제 조건

• 시스템에 Golang 설치 및 구성
• 기본 Golang 지식

마이크로서비스 소개

마이크로서비스 아키텍처는 애플리케이션을 독립 모듈로 분할하는 소프트웨어 설계 접근 방식입니다. 각 마이크로서비스는 특정 기능을 처리하며 독립적으로 배포, 확장 및 유지 관리될 수 있습니다.

Golang 마이크로서비스 프레임워크

Golang에 사용할 수 있는 마이크로서비스 프레임워크가 많이 있으며 가장 인기 있는 프레임워크는 다음과 같습니다.

• Gin: 간단하고 효율적인 웹 프레임워크
• Echo: 고성능이고 사용하기 쉬운 -사용된 웹 프레임워크
• Fiber: 빠르고 가벼운 웹 프레임워크

이 가이드에서는 Gin 프레임워크를 사용하여 마이크로서비스 생성 프로세스를 보여줍니다.

Gin 마이크로서비스 만들기

먼저 새 Go 모듈 만들기:

go mod init microservice

다음으로 Gin 프레임워크 설치:

go get github.com/gin-gonic/gin

새 Gin 라우터 만들기:

package main

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

func main() {
    r := gin.Default()
}

엔드포인트 추가

마이크로서비스 엔드포인트에 추가하려면 Gin.RouterGroup 사용 개체: Gin.RouterGroup 对象：

func main() {
    r := gin.Default()
    r.GET("/hello", func(c *gin.Context) {
        c.JSON(200, gin.H{"message": "Hello, World!"})
    })
}

部署微服务

要部署微服务，请构建并运行应用程序：

go build .
./microservice

实战案例：订单管理系统

让我们创建一个订单管理系统，其中包含一个处理用户订单的微服务。

创建订单微服务

使用相同的步骤创建一个新的 Gin 微服务，并添加以下端点：

func main() {
    r := gin.Default()
    r.GET("/orders", func(c *gin.Context) {
        // 获取所有订单
    })
    r.POST("/orders", func(c *gin.Context) {
        // 创建新订单
    })
}

创建库存微服务

库存微服务将跟踪产品可用性。使用相同的步骤创建一个新的 Gin 微服务，并添加以下端点：

func main() {
    r := gin.Default()
    r.GET("/stock/:product_id", func(c *gin.Context) {
        // 获取产品的库存数量
    })
}

连接微服务

为了让微服务相互通信，我们需要使用一个消息传递系统。在本例中，我们将使用 Kafka。

• 安装 Kafka：brew install kafka
• 创建一个 Kafka 主题：kafka-topics --create --topic orders
• 在订单微服务中，使用 sarama 库生产订单：

import (
    "context"
    "time"

    "github.com/Shopify/sarama"
)

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        // 处理错误
    }
    msg := &sarama.ProducerMessage{
        Topic: "orders",
        Value: sarama.StringEncoder("new order"),
    }
    _, _, err = producer.SendMessage(msg)
    if err != nil {
        // 处理错误
    }
}

• 在库存微服务中，使用 sarama

  import (
      "context"
      "log"
      "time"
  
      "github.com/Shopify/sarama"
  )
  
  func main() {
      consumer, err := sarama.NewConsumer([]string{"localhost:9092"}, nil)
      if err != nil {
          // 处理错误
      }
      defer consumer.Close()
      ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
      consumer.ConsumePartition("orders", 0, sarama.OffsetNewest)
      for {
          select {
          case msg := <-consumer.Messages():
              log.Printf("Received message: %s\n", string(msg.Value))
          case err := <-consumer.Errors():
              log.Printf("Received consumer error: %s\n", err.Error())
          case <-ctx.Done():
              cancel()
              return
          }
      }
  }

  마이크로서비스 배포

  마이크로서비스를 배포하려면 애플리케이션 빌드 및 실행:

  rrreee

  실용 사례: 주문 관리 시스템

  🎜다음을 포함하는 주문 관리 시스템을 만들어 보겠습니다. 사용자 주문을 처리하는 마이크로서비스입니다. 🎜🎜🎜주문 마이크로서비스 생성🎜🎜🎜동일한 단계를 사용하여 새로운 Gin 마이크로서비스를 생성하고 다음 엔드포인트를 추가합니다. 🎜rrreee🎜🎜인벤토리 마이크로서비스 생성 🎜🎜🎜인벤토리 마이크로서비스는 제품 가용성을 추적합니다. 동일한 단계를 사용하여 새로운 Gin 마이크로서비스를 생성하고 다음 엔드포인트를 추가합니다. 🎜rrreee🎜🎜마이크로서비스 연결🎜🎜🎜마이크로서비스가 서로 통신하려면 메시징 시스템을 사용해야 합니다. 이 예에서는 Kafka를 사용하겠습니다. 🎜🎜🎜Kafka 설치: brew install kafka🎜🎜Kafka 주제 만들기: kafka-topics --create --topic 주문🎜🎜주문 마이크로서비스에서 sarama 라이브러리 생산 순서: 🎜🎜rrreee🎜🎜인벤토리 마이크로서비스에서 sarama 라이브러리 소비 순서 사용: 🎜🎜rrreee🎜Summary🎜🎜Golang 마이크로서비스 프레임워크를 사용하면 분산 생성이 가능합니다. 시스템을 쉽게 사용할 수 있습니다. 이 문서의 단계를 따르면 메시징을 사용하여 마이크로서비스를 조정하는 주문 관리 시스템을 구축할 수 있습니다. 🎜

  위 내용은 Golang 마이크로서비스 프레임워크를 사용하여 분산 시스템 만들기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!