go-zero をベースとしたマイクロサービスメッセージ通信ソリューション-Golang-php.cn

go-zero をベースとしたマイクロサービスメッセージ通信ソリューション

王林

リリース： 2023-06-22 17:19:37

オリジナル

1858 人が閲覧しました

マイクロサービスアーキテクチャの人気に伴い、マイクロサービス間の通信がますます重要になっています。これまで一般的に使用されていた REST API 通信方式には、マイクロサービスが相互に呼び出す場合に次のような欠点がありました。

頻繁なネットワークリクエストは遅延とパフォーマンスのボトルネックをもたらします;
高頻度のリクエストの場合また、短期間に大量のリクエストが発生すると、サービスがクラッシュする可能性があります。
大量のデータ送信が行われるシナリオでは、HTTP プロトコルに基づく送信方法も非効率になりがちです。

したがって、メッセージキュー (Message Queue) に基づいてマイクロサービス間の非同期通信を実装することが良い選択になりました。メッセージキューはメッセージサーバーにメッセージを送信し、受信者はメッセージを非同期に受信して処理できるため、時間のかかるサービス間の通信が節約され、システムパフォーマンスが向上し、通信の信頼性が確保されます。

しかし、アーキテクチャ実装の観点から見ると、強力で拡張性の高いメッセージ通信ソリューションを迅速に実装するにはどうすればよいでしょうか?今日は、go-zero をベースにしたマイクロサービスメッセージ通信ソリューションについて説明します。

環境構成

マイクロサービス通信を実装するには、サーバー上のメッセージキューを処理するツールが必要です。現在人気のあるものには、RabbitMQ、Kafka、RocketMQ などが含まれます。この記事では、RabbitMQ メッセージキューの使用方法を紹介します。したがって、最初に RabbitMQ をインストールして設定する必要があります。

RabbitMQ のインストール

関連するインストールパッケージとインストール方法は、[RabbitMQ 公式 Web サイト](https://www.rabbitmq.com/download.html) で参照できます。ここでは詳細な説明は行いません。

インストールが完了したら、RabbitMQ Web 管理コンソールで必要な仮想ホストとユーザーを作成します。ここでは、vhost を myhost、ユーザー名とパスワードを admin/admin として設定します。

go-zero をインストールする

go-zero は、スケーラブルで保守可能なマイクロサービスを構築するためのツールキットです。必要なすべてのツールをモノリシックアプリケーションに統合し、マイクロサービス、RPC、API ゲートウェイなどの最も一般的に使用されるツールを提供します。 go-zero 開発環境をローカルにインストールする必要があります。

go-zero インフラストラクチャ

go-zero はマイクロサービスアーキテクチャに基づいており、マイクロサービス、RPC、API ゲートウェイなどの共通の開発ツールを提供します。 go-zero を使用して RabbitMQ メッセージキューをサポートするマイクロサービスアーキテクチャを実装するのは非常に簡単です。

1. サービスの作成

goctl ツール (go-zero のコマンドラインツール) を使用して、サービスをすばやく作成します。まず、go-zero コマンドラインでサービスが作成されたディレクトリを入力し、次のコマンドを実行します。

goctl api new message

ログイン後にコピー

操作の結果は次のとおりです。

- api
    - etc
        - message-api.yaml
    - internal
        - config
            - config.go
        - handler
            - message_handler.go
        - service
            - message_service.go
    - message.api
- Dockerfile
- go.mod
- go.sum
- main.go

ログイン後にコピー

Through goctl api new## コマンドによって作成されたサービスには、必要な基本ディレクトリとデフォルト実装が含まれています。このうち、- api はサービス名を表し、- etc/message-api.yaml はサービスの設定ファイルを表します。

2. 設定ファイル

etc/message-api.yaml を開き、RabbitMQ 情報を設定します:

Name: message-api
Host: 0.0.0.0
Port: 8080
JwtSecret: # 在API网关中使用

MessageQueue:
  Host: 127.0.0.1
  Port: 5672 # RabbitMQ端口
  User: admin # RabbitMQ用户名
  Password: admin # RabbitMQ密码
  VirtualHost: myhost # RabbitMQ vhost

ログイン後にコピー

その中に

MessageQueue セクションでは、RabbitMQ を使用する際に必要な情報を指定します。

3. ハンドラーとサービスの実装

RabbitMQ メッセージキュー内のメッセージを処理するには、ハンドラーとサービスの実装を追加する必要があります。

handler ディレクトリに message_handler.go ファイルを追加し、次のコードを追加します。

package handler

import (
    "context"

    "github.com/tal-tech/go-zero/core/logx"
    "github.com/tal-tech/go-zero/rest/httpx"
    "github.com/tal-tech/go-zero/zmq"
)

type MessageHandler struct {
    messageService *zmq.Service
}

func NewMessageHandler(ctx context.Context) *MessageHandler {
    return &MessageHandler{
        messageService: zmq.NewService("my-exchange", "my-key", false), // 确定队列信息
    }
}

func (h *MessageHandler) SendMessage(ctx context.Context, req *MessageRequest) (*MessageResponse, error) {
    logx.Infof("handler receive message %v", req.Message)

    err := h.messageService.SendMessage(zmq.NewMessage(req.Message)) // 发送消息到队列

    if err != nil {
        logx.Error(err)
        return nil, httpx.NewDefaultError(httpx.InternalServerErrorStatus)
    }

    return &MessageResponse{}, nil
}

ログイン後にコピー

このうち、go-zero が提供する zmq ツールを使用して、 RabbitMQ メッセージキューインタラクションを実装します (詳細については、[go-zero 公式ドキュメント](https://go-zero.dev/cn/tools/zmq) を参照してください)。

service ディレクトリに message_service.go ファイルを追加し、次のコードを追加します。

package service

import (
    "context"

    "message/internal/biz"
)

type MessageApi struct {
    bc *biz.BizClient
}

func NewMessageApi(bc *biz.BizClient) *MessageApi {
    return &MessageApi{
        bc: bc,
    }
}

func (s *MessageApi) SendMessage(ctx context.Context, req *MessageRequest) (*MessageResponse, error) {
    _, err := s.bc.SendMessage(ctx, req.Message)

    if err != nil {
        return nil, err
    }

    return &MessageResponse{}, nil
}

ログイン後にコピー

その中に、

biz 部分アプリケーションロジックのコードを処理するために、特定のビジネスニーズに応じて特定のコード実装を作成できます。

4. コード生成

ハンドラーとサービスを作成した後、go-zero コマンドラインツールを使用して RPC コードを自動的に生成する必要があります。コマンドラインで、

message.api ファイルと同じディレクトリを入力し、次のコードを実行します。

goctl rpc proto -src message.api -dir .

ログイン後にコピー

このコマンドは、

message.api# を自動的に生成します。 . ##関連する gRPC プロトコルファイルを作成し、現在のディレクトリに配置します。 5. 登録サービス

次のコードを

internal/config/config.go

に追加します: <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:go;toolbar:false;'>// register MessageApi group := server.Group("/") messageSvc := service.NewMessageApi(biz.NewBizClient()) server.POST(group+"/send-message", httpx.NewHandler(messageSvc.SendMessage)) go func() { err = zmq.NewSubscriber("my-exchange", "my-key", false).Subscribe(func(msg zmq.Message) { logx.Infof("[RabbitMQ Subscriber] receive message %s", string(msg.Body)) }) // 订阅队列 if err != nil { panic(err) } }()</pre><div class="contentsignin">ログイン後にコピー</div></div>その中に # があります。 application ##MessageApi

サービスは、

zmq.NewSubscriber 呼び出しで登録およびサブスクライブされます。メッセージをサブスクライブした後、logx.Infof を通じて RabbitMQ キュー内のメッセージを直接処理します。 最後に、main.go

の

Run メソッドに次のコードを追加します。

s := &http.Server{
    Handler: server,
    Addr:    ":"+cfg.Port,
}

ログイン後にコピー

上記のコードは、サービスが HTTP で実行可能になるように構成します。サーバーに接続し、指定されたポートにバインドします。最後に、サービスが正常かどうかをテストできます。

概要

この記事では、go-zero に基づくマイクロサービスメッセージ通信ソリューションを紹介し、サンプルコードを通じて RabbitMQ をサポートするマイクロサービスアーキテクチャを実装しました。 RabbitMQ には、メッセージング通信テクノロジで広く使用されている、複数のプログラミング言語をサポートしている、オープンソースであるという利点があり、ほとんどのエンタープライズレベルのアプリケーションシナリオに適しています。実用化にあたっては、ビジネスシーンや需要特性に応じて柔軟に活用する必要があります。

以上がgo-zero をベースとしたマイクロサービスメッセージ通信ソリューションの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。