gRPC: そもそもRPC って何？

今回gRPC を学ぶ上でRPCの説明をできるようにするためにRPCとはについてご説明します。

概要

リモートプロシージャコール（RPC）は、分散コンピューティングのサブルーチンです。

RPCのリモート実装はローカル呼び出しに似ていますが、通常は同じではありません。

RPCでは通常、オブジェクト名、関数名、またはパラメーターがリモートサーバーに渡され、 サーバーは処理された結果をクライアント側に返します（要求/応答）。

RPCは、TCP、UDP、またはHTTPプロトコルを介して通信できます。

Go での実装

今回はGoで server / client を実装して体験します。
Goでは、公式ドキュメントにあるように
明示的なCodecの指定をしない限り、gobを使用してマーシャリングされます。

サーバーの実装

package main

import (
	"fmt"
	"log"
	"net"
	"net/rpc"
)

type Listener int
type Reply struct {
	Data string
}

func (l *Listener) GetLine(line []byte, reply *Reply) error {
	rv := string(line)
	fmt.Printf("Receive: %v\n", rv)
	*reply = Reply{rv}
	return nil
}

func main() {
	addy, err := net.ResolveTCPAddr("tcp", "0.0.0.0:12345")
	if err != nil {
		log.Fatal(err)
	}
	inbound, err := net.ListenTCP("tcp", addy)
	if err != nil {
		log.Fatal(err)
	}
	listener := new(Listener)
	rpc.Register(listener)
	rpc.Accept(inbound)
}

クライアントの実装

package main

import (
	"bufio"
	"log"
	"net/rpc"
	"os"
)

type Reply struct {
	Data string
}

func main() {
	client, err := rpc.Dial("tcp", "localhost:12345")
	if err != nil {
		log.Fatal(err)
	}
	in := bufio.NewReader(os.Stdin)
	for {
		line, _, err := in.ReadLine()
		if err != nil {
			log.Fatal(err)
		}
		var reply Reply
		err = client.Call("Listener.GetLine", line, &reply)
		if err != nil {
			log.Fatal(err)
		}
		log.Printf("Reply: %v, Data: %v", reply, reply.Data)
	}
}

in.ReadLine の無限ループで受け取っているので、
client起動したら、文字を入力してEnter をしてください。

実行結果

clientからCallすると、サーバーで定義したGetLine 関数がcall されることがわかります。

REPO

今回の実装サンプルは以下に残しておきます。
https://github.com/locona/what-is-rpc-go