近年、インターネットの急速な発展に伴い、分散システムがますます注目を集めています。 RPC (リモート プロシージャ コール) テクノロジは、分散システムの主要なテクノロジであり、異なるシステムが相互に通信し、連携できるようにします。さまざまな言語の中でも、ほとんどの言語には独自の RPC フレームワークがあります。この記事では、システムが快適に連携できるように、Golang を使用して RPC を実装する方法を紹介します。
1. RPC の基本概念
1.1.
RPC とはリモート プロシージャ コール (Remote Procedure Call) であり、クライアントがローカルでリモート サービスを呼び出すことを意味します。 , ネイティブコードを呼び出すのと同じように、ネイティブコードを呼び出すのと同じようにパラメータを渡したり戻り値を取得したりできます。実際には、ネットワーク通信プロセスをローカル呼び出しと同様のパターンに抽象化します。
1.2. 理由
分散システムでは、各ノードが分散され、それぞれが異なるタスクやビジネス サービスを引き受けます。これらのノードが連携して動作するには、ネットワーク経由で通信する必要があります。 RPC を使用すると、これらのノードがネットワーク経由でデータを交換し、ビジネス ロジックの実行を実装できるようになります。
1.3. 機能
RPC の中心原理は、ネットワーク通信プロセスをローカル呼び出しプロセスに抽象化することであり、クライアントはパラメータをローカルでリモート サービスに渡し、サーバーはパラメータを処理します。そして処理結果をクライアントに返却します。これにより、分散システム内のさまざまなノードが相互に連携して、分散システムのさまざまなタスクを完了できるようになります。 RPC の特徴は次のとおりです。
2. Golang で RPC を実装するための基本手順
2.1. インターフェイスの定義
Golang では、まず公開するインターフェイスを定義する必要があります。インターフェースは、リモート呼び出しの関数プロトタイプに相当します。
type Server struct {}
type Args struct {
A, B int
}
func (s *Server) Multiply(args *Args, reply *int) error {
*reply = args.A * args.B
return nil
}コードでは、Server 構造体と Args 構造体が定義されています。Server 構造体は Multiply 関数を定義しています。Multiply 関数は、2 つの整数の積を計算するために使用されます。 Multiply 関数のパラメータと戻り値は RPC 仕様を満たす必要があることに注意してください。
2.2. RPC サービスの登録
インターフェースを定義した後、クライアントが RPC サービスを呼び出せるように、インターフェースを RPC サービスに登録する必要があります。サービスを RPC サーバーに登録するには、Golang の rpc.Serve() 関数を使用する必要があります。
func main() {
server := new(Server)
rpc.Register(server)
rpc.HandleHTTP()
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("listen error:", err)
}
http.Serve(listener, nil)
}上記のコードでは、最初に Server 構造を作成し、次に rpc.Register 関数を通じて Server 構造に定義されたインターフェイスを RPC サーバーに登録し、次に rpc.HandleHTTP() を使用して RPC にアクセスします。サーバーは http パッケージ内のデフォルト マルチプレクサにバインドされ、最後に RPC サーバーは http.Serve を通じて TCP リスニング アドレスにバインドされます。
2.3. クライアント コードを記述する
RPC サービスの登録が完了したら、RPC サービスを呼び出すためのクライアント コードを記述する必要があります。 Golang の rpc パッケージは、RPC クライアント接続の確立に使用できる rpc.DialHTTP 関数を提供します。以下は、単純な RPC クライアントの実装です。
func main() {
client, err := rpc.DialHTTP("tcp", "localhost:8080")
if err != nil {
log.Fatal("dialing:", err)
}
args := &Args{7, 8}
var reply int
err = client.Call("Server.Multiply", args, &reply)
if err != nil {
log.Fatal("Server error:", err)
}
fmt.Printf("Multiply: %d*%d=%d", args.A, args.B, reply)
}クライアントは、rpc.DialHTTP 関数を通じて RPC サーバーとの接続を確立し、client.Call メソッドを呼び出して RPC サーバー関数を実行します。 Call の最初のパラメータは呼び出される関数の名前、2 番目のパラメータは関数のパラメータ、3 番目のパラメータは関数の戻り値です。
3. Golang RPC サンプル コード
以下は、Golang に基づいた RPC 実装の完全な例です:
package main
import (
"fmt"
"log"
"net"
"net/http"
"net/rpc"
)
type Server struct{}
type Args struct {
A, B int
}
func (s *Server) Multiply(args *Args, reply *int) error {
*reply = args.A * args.B
return nil
}
func main() {
server := new(Server)
rpc.Register(server)
rpc.HandleHTTP()
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("listen error:", err)
}
go http.Serve(listener, nil)
client, err := rpc.DialHTTP("tcp", "localhost:8080")
if err != nil {
log.Fatal("dialing:", err)
}
args := &Args{7, 8}
var reply int
err = client.Call("Server.Multiply", args, &reply)
if err != nil {
log.Fatal("Server error:", err)
}
fmt.Printf("Multiply: %d*%d=%d", args.A, args.B, reply)
}上記のコードを通して、Golang でのことがわかります。 , RPC の実装は非常に簡単です。インターフェイスを定義し、RPC サービスを登録し、クライアント コードを記述するだけで済みます。もちろん、RPC クライアントとサーバーの両方を異種混合にすることができ、これは分散システムを拡張するときに非常に役立ちます。
4. 概要
この記事では、RPC とは何か、RPC が必要な理由、および Golang を使用して RPC を実装する方法を紹介します。この記事を読むと、RPC が分散システムの基礎技術として広く使われていることがわかります。 Golang は効率的なプログラミング言語として、開発者が分散システムをより適切に実装するのに役立つ優れた RPC フレームワークを備えています。分散システムを開発する必要がある場合は、Golang を使用して RPC を実装してみるのもよいでしょう。
以上がgolangでrpcを実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
