Golang と gRPC を使用してスケーラブルな分散データ転送を構築するためのヒント

go get -u google.golang.org/grpc

go get -u github.com/golang/protobuf/protoc-gen-go

syntax = "proto3";

package data;

service DataTransfer {
  rpc SendData (DataRequest) returns (DataResponse) {}
}

message DataRequest {
  string message = 1;
}

message DataResponse {
  int32 status = 1;
  string response_message = 2;
}

protoc --go_out=. data.proto

package main

import (
    "context"
    "log"
    "net"

    "google.golang.org/grpc"

    pb "your_package_name/data"
)

type server struct{}

func (s *server) SendData(ctx context.Context, req *pb.DataRequest) (*pb.DataResponse, error) {
    log.Printf("Received message: %s", req.Message)

    response := &pb.DataResponse{
        Status:          200,
        ResponseMessage: "Data received successfully",
    }

    return response, nil
}

func main() {
    lis, err := net.Listen("tcp", ":50051")
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
    }

    s := grpc.NewServer()
    pb.RegisterDataTransferServer(s, &server{})

    log.Println("Server started on port :50051")
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

package main

import (
    "context"
    "log"

    "google.golang.org/grpc"

    pb "your_package_name/data"
)

func main() {
    conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())
    if err != nil {
        log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()

    c := pb.NewDataTransferClient(conn)

    message := "Hello gRPC"

    response, err := c.SendData(context.Background(), &pb.DataRequest{Message: message})
    if err != nil {
        log.Fatalf("could not send data: %v", err)
    }

    log.Printf("Response status: %d", response.Status)
    log.Printf("Response message: %s", response.ResponseMessage)
}

go run server.go

go run client.go