分散システムは、データとタスクが共有される複數(shù)の獨(dú)立したコンピューターで構(gòu)成されるシステムです。これらのコンピューターはネットワーク経由で相互に通信し、一緒にタスクを完了します。このシステムでは、各コンピュータは獨(dú)立しており、異なるオペレーティング システムとプログラミング言語(yǔ)を使用できます。これらのコンピュータが連攜して動(dòng)作するには、それらの動(dòng)作を調(diào)整するためのフレームワークが必要です。この記事では、Golang の Buffalo フレームワークを使用して分散システムを?qū)g裝する方法を紹介します。

Golang は効率的なプログラミング言語(yǔ)であり、分散システムでは他の言語(yǔ)よりも Golang を使用する方が適しています。したがって、開発言語(yǔ)として Golang を選択しました。 Buffalo フレームワークは、迅速な開発と共同開発の利點(diǎn)を提供する人気のある Golang Web フレームワークです。このフレームワークでは、その自動(dòng)化サービスを使用してアプリケーションを作成および管理できます。

分散システムを作成するときは、次の要素を考慮する必要があります:

1. 相互通信: 分散システム內(nèi)のコンピュータは、連攜して動(dòng)作するために相互に通信する必要があります。これを?qū)g現(xiàn)するには、RESTful API または gRPC プロトコルを使用できます。
2. データ同期: 分散システム內(nèi)のコンピューターは獨(dú)立しているため、異なるデータを持つ可能性があります。したがって、このデータを同期する方法を検討する必要があります。
3. 負(fù)荷分散: 分散システムをより効率的にするには、コンピューティング リソースに余裕のあるコンピュータにタスクを割り當(dāng)てる必要があります。

次に、Buffalo フレームワークを使用してこれらの関數(shù)を?qū)g裝する方法を見てみましょう。

Buffalo アプリケーションを作成する

まず、サーバー上に Buffalo アプリケーションを作成する必要があります。このタスクを?qū)g行するには、Buffalo CLI を使用できます。 Buffalo CLI をインストールし、次のコマンド ラインを使用して新しい Buffalo アプリケーションを作成します。

$ go get -u -v github.com/gobuffalo/buffalo/cli/v2
$ buffalo new appname

Buffalo は基本的なアプリケーション構(gòu)造を生成します。次のコマンドを使用してサーバーを起動(dòng)できます:

$ buffalo dev

このコマンドは Web サーバーを起動(dòng)し、ブラウザで http://127.0.0.1:3000 にアクセスしてアプリケーションを表示できます。

RESTful API の作成

次に、分散システム內(nèi)のコンピューターが相互に通信するための RESTful API を作成する必要があります。 Buffalo フレームワークの自動(dòng)化サービスを使用して、このタスクを?qū)g行できます。

まず、API リクエストを処理するコントローラーを作成する必要があります。次のコマンドを使用してコントローラを作成できます。

$ buffalo generate resource user name email

このコマンドは、「user」という名前のコントローラを生成します。このコントローラには、「name」と「email」の 2 つのパラメータが含まれます。コントローラーにロジックを追加して、さまざまな種類のリクエストに応答できるようにすることができます。

分散システム內(nèi)のコンピュータが相互に通信するには、POST リクエストと GET リクエストを作成する必要があります。これらのリクエストを処理するには、コントローラーに次のコードを追加します。

func (v *UsersResource) Create(c buffalo.Context) error {
    user := &models.User{}
    if err := c.Bind(user); err != nil {
        return err
    }

    // Add validation logic here!

    tx := c.Value("tx").(*pop.Connection)
    if err := tx.Create(user); err != nil {
        return err
    }

    return c.Render(201, r.JSON(user))
}

func (v *UsersResource) List(c buffalo.Context) error {
    users := &models.Users{}
    tx := c.Value("tx").(*pop.Connection)
    if err := tx.All(users); err != nil {
        return err
    }

    return c.Render(200, r.JSON(users))
}

これらのコードは、POST リクエストと GET リクエストを処理し、JSON 形式の応答データをクライアントに返します。

gRPC プロトコルの使用

RESTful API に加えて、gRPC プロトコルを使用してコンピューター間の通信を?qū)g裝することもできます。 Buffalo フレームワークは gRPC プロトコルをサポートしており、次のコマンドを使用して Buffalo-gRPC プラグインをインストールできます。

$ buffalo plugins install buffalo-grpc

次に、アプリケーションの gRPC サービス コードを生成する必要があります。次のコマンドを使用してコードを生成できます。

$ buffalo generate grpc user

このコマンドは、「user」という名前の gRPC サービスを生成します。

サーバー コードでは、gRPC サービスで定義されたメソッドを?qū)g裝する必要があります。これらのメソッドは次のコードで実裝できます:

type UserServer struct{}

func (s *UserServer) GetUser(ctx context.Context, req *user.GetUserRequest) (*user.GetUserResponse, error) {
    // Insert user retrieval logic here
}

func (s *UserServer) CreateUser(ctx context.Context, req *user.CreateUserRequest) (*user.User, error) {
    // Insert user creation logic here
}

クライアント コードでは、次のコードを使用して gRPC サービスを呼び出すことができます:

conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())
if err != nil {
    log.Fatalf("failed to connect: %s", err)
}
defer conn.Close()

client := user.NewUserClient(conn)
res, err := client.GetUser(context.Background(), &user.GetUserRequest{Id: "123"})
if err != nil {
    log.Fatalf("failed to get user: %s", err)
}

log.Printf("user: %v", res)

分散システムでのキャッシュとしての Redis の使用

分散システムでは、データ アクセスを高速化するために、通常、キャッシュを使用します。 Redis は、分散システムをサポートし、データを迅速に保存および取得できるようにする人気のキャッシュ ツールです。次のコマンドを使用して Redis をインストールできます:

$ brew install redis

次に、アプリケーションで Redis をキャッシュとして使用できます。次のコマンドを使用して Redis プラグインをインストールできます:

$ buffalo plugins install buffalo-redis

次に、アプリケーションで次のコードを使用して Redis を構(gòu)成できます:

var (
    RedisClient *redis.Client
)

func init() {
    RedisClient = redis.NewClient(&redis.Options{
        Addr: "localhost:6379",
    })
}

func main() {
    app := buffalo.New(buffalo.Options{})
    app.Use(midware.Redis(RedisClient))
    // ...
}

次に、コントローラーで使用できます。データを Redis に保存するには、次のコードを使用します。

func (v *UsersResource) Create(c buffalo.Context) error {
    user := &models.User{}
    if err := c.Bind(user); err != nil {
        return err
    }

    // Add validation logic here!

    if err := RedisClient.Set("user_"+user.ID.String(), user, 0).Err(); err != nil {
        return err
    }

    // Add logic to store user in database

    return c.Render(201, r.JSON(user))
}

この例では、ユーザーを Redis キャッシュに保存し、ユーザーの ID をキーとして使用します。これにより、後でユーザー データをすばやく取得できるようになります。

負(fù)荷分散の実現(xiàn)

最後に、負(fù)荷分散機(jī)能を?qū)g裝する必要があります。分散システムでは、コンピューティング リソースに余裕のあるコンピュータにコンピューティング タスクを割り當(dāng)てられるようにしたいと考えています。このタスクを達(dá)成するには、リバース プロキシ サーバーを使用できます。

Nginx は、負(fù)荷分散と HTTPS 暗號(hào)化をサポートする人気のあるリバース プロキシ サーバーです。サーバーに Nginx をインストールし、次の構(gòu)成ファイルを使用して負(fù)荷分散を?qū)g現(xiàn)できます:

http {
    upstream app_servers {
        server 127.0.0.1:3001;
        server 127.0.0.1:3002;
        server 127.0.0.1:3003;
    }

    server {
        listen 80;
        server_name example.com;

        location / {
            proxy_pass http://app_servers;
        }
    }
}

この構(gòu)成ファイルはリクエストを 3 つの異なるサーバーに分散し、ラウンドロビン アルゴリズムを使用してリクエストを分散する場(chǎng)所を決定します。 。 ＃＃＃＃＃＃結(jié)論は＃＃＃

Buffalo フレームワークを使用することで、分散システムを迅速に実裝し、RESTful API や gRPC などの複數(shù)の通信プロトコルをサポートできます。 Redis を使用してデータ アクセスを高速化し、リバース プロキシ サーバーを使用して負(fù)荷分散を?qū)g現(xiàn)することもできます。これらの方法を通じて、分散システムをより効率的にし、より高速なコンピューティング速度を?qū)g現(xiàn)できます。

以上がGolang の Web フレームワーク Buffalo フレームワークを使用した分散システムの実裝の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。