GRPC를 사용하여 Golang에서 동시 데이터 전송을 구현하는 모범 사례
소개:
클라우드 컴퓨팅과 빅데이터 기술의 발전으로 데이터 전송에 대한 수요가 점점 더 긴급해지고 있습니다. Google의 오픈소스 고성능 원격 프로시저 호출 프레임워크인 gRPC는 효율성, 유연성 및 언어 간 기능으로 인해 많은 개발자의 첫 번째 선택이 되었습니다. 이 기사에서는 프로젝트 구조 구축, 연결 풀 사용 및 오류 처리 등을 포함하여 Golang에서 동시 데이터 전송을 달성하기 위해 gRPC를 사용하는 모범 사례를 소개합니다.
1. 프로젝트 구조 구축
gRPC를 사용하기 전에 프로그램의 구성과 관리를 보다 명확하게 하기 위해 적합한 프로젝트 구조를 구축해야 합니다.
myproject
├── api
│ └── myservice.proto
│
├── client
│ ├── client.go
│ └── main.go
│
└── server
├── server.go
├── handler.go
└── main.go그 중 api 디렉터리는 gRPC 서비스의 인터페이스 정의를 저장하는 데 사용되며, 클라이언트 디렉터리는 클라이언트 관련 코드와 주요 기능을 저장하는 데 사용되며, 서버 디렉터리는 서버 관련 코드 및 주요 기능.
syntax = "proto3";
package myproject;
service MyService {
rpc GetData (GetDataRequest) returns (GetDataResponse) {}
}
message GetDataRequest {
string id = 1;
}
message GetDataResponse {
string data = 1;
}여기에는 GetDataRequest 매개변수를 수신하고 GetDataResponse 매개변수를 반환하는 GetData라는 RPC 메서드를 포함하여 MyService라는 서비스가 정의되어 있습니다.
protoc --proto_path=./api --go_out=plugins=grpc:./api ./api/myservice.proto
이렇게 하면 gRPC 서비스가 포함된 api 디렉터리에 myservice.pb.go라는 파일이 생성됩니다. 메시지 정의 및 기타 관련 코드.
2. 클라이언트 만들기
다음으로 서버에 동시 요청을 보내고 반환된 데이터를 받기 위한 클라이언트 코드 작성을 시작하겠습니다.
package main
import (
"context"
"log"
"sync"
"time"
"google.golang.org/grpc"
pb "myproject/api" // 导入生成的代码
)grpc.Dial 함수를 사용하여 연결을 만들 수 있습니다. 샘플 코드는 다음과 같습니다. grpc.Dial函数来创建连接。示例代码如下：func main() {
// 创建连接并指定服务端地址和端口
conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())
if err != nil {
log.Fatalf("failed to connect: %v", err)
}
defer conn.Close()
// 创建客户端
client := pb.NewMyServiceClient(conn)
// 发送并发请求
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
// 创建上下文和请求
ctx, cancel := context.WithTimeout(context.Background(), time.Second)
defer cancel()
req := &pb.GetDataRequest{
Id: strconv.Itoa(id),
}
// 调用服务端方法
resp, err := client.GetData(ctx, req)
if err != nil {
log.Printf("failed to get data: %v", err)
return
}
// 输出结果
log.Printf("data: %s", resp.Data)
}(i)
}
// 等待所有请求完成
wg.Wait()
}在上述代码中，我们首先使用grpc.Dial函数创建与服务端的连接。这里采用了不安全的连接模式（Insecure），用于简化示例。实际应用中，建议采用安全的连接模式（Secure）。
然后，我们创建了一个MyServiceClient实例，用于调用服务端的方法。
接下来，我们使用sync.WaitGroup来协调并发请求。在循环中，我们创建了一个匿名函数，用于发起并发请求。在每个并发执行的请求中，我们创建了一个上下文和请求对象，然后调用服务端的方法GetData。
最后，我们使用wg.Wait来等待所有的并发请求完成。
三、创建服务端
接下来我们将开始编写服务端的代码，用于接收客户端的请求并返回处理后的数据。
package main
import (
"log"
"net"
"google.golang.org/grpc"
pb "myproject/api" // 导入生成的代码
)package main
import (
"context"
)
// 定义服务
type MyServiceServer struct{}
// 实现方法
func (s *MyServiceServer) GetData(ctx context.Context, req *pb.GetDataRequest) (*pb.GetDataResponse, error) {
// 处理请求
data := "Hello, " + req.Id
// 构造响应
resp := &pb.GetDataResponse{
Data: data,
}
return resp, nil
}这里我们实现了MyServiceServer结构体，并实现了GetData方法。在该方法中，我们首先处理请求，然后构造响应并返回。
grpc.NewServer函数来创建服务。示例代码如下：func main() {
// 监听TCP端口
lis, err := net.Listen("tcp", ":50051")
if err != nil {
log.Fatalf("failed to listen: %v", err)
}
// 创建gRPC服务
s := grpc.NewServer()
// 注册服务
pb.RegisterMyServiceServer(s, &MyServiceServer{})
// 启动服务
if err := s.Serve(lis); err != nil {
log.Fatalf("failed to serve: %v", err)
}
}在上述代码中，我们首先使用net.Listen函数创建一个TCP监听器，指定监听端口为50051。
然后，我们使用grpc.NewServer函数创建一个gRPC服务，并使用pb.RegisterMyServiceServer方法将我们实现的服务注册到该服务中。
最后，我们使用s.Serve(lis)
package main
// main函数入口
func main() {
// 注册服务
pb.RegisterMyServiceServer(s, &MyServiceServer{})
// 启动服务
if err := s.Serve(lis); err != nil {
log.Fatalf("failed to serve: %v", err)
}
}위 코드에서는 먼저 grpc.Dial 함수를 사용하여 서버와 연결을 생성합니다. 여기서는 예를 단순화하기 위해 안전하지 않은 연결 모드(Insecure)가 사용되었습니다. 실제 응용에서는 보안 연결 모드(Secure)를 사용하는 것이 좋습니다.
GetData를 호출합니다. 마지막으로 wg.Wait를 사용하여 모든 동시 요청이 완료될 때까지 기다립니다. 3. 서버 생성 다음으로 클라이언트의 요청을 수신하고 처리된 데이터를 반환하는 서버 코드 작성을 시작하겠습니다.
종속성 가져오기server/main.go에서 먼저 gRPC, 로그, net 등을 포함한 관련 종속성을 가져와야 합니다.
package main
// main函数入口
func main() {
ctx, cancel := context.WithTimeout(context.Background(), time.Second)
defer cancel()
req := &pb.GetDataRequest{
Id: "1",
}
resp, err := client.GetData(ctx, req)
if err != nil {
log.Fatalf("failed to get data: %v", err)
}
log.Printf("data: %s", resp.Data)
}go run server/main.go go run client/main.go
grpc.NewServer 함수를 사용하여 서비스를 생성할 수 있습니다. 샘플 코드는 다음과 같습니다. 🎜🎜2021/01/01 15:00:00 data: Hello, 1
net.Listen 함수를 사용하여 TCP 리스너를 생성하고 리스닝 포트를 50051로 지정합니다. 🎜🎜그런 다음 grpc.NewServer 함수를 사용하여 gRPC 서비스를 생성하고, pb.RegisterMyServiceServer 메서드를 사용하여 우리가 구현한 서비스를 서비스에 등록합니다. 🎜🎜마지막으로 s.Serve(lis) 메서드를 사용하여 서비스를 시작하고 지정된 포트를 수신합니다. 🎜🎜4. 코드 예제 데모🎜 아래에서는 전체 예제를 사용하여 gRPC를 사용하여 Golang에서 동시 데이터 전송을 구현하는 방법을 보여줍니다. 🎜🎜먼저 server/main.go에 다음 코드를 추가해야 합니다. 🎜rrreee🎜그런 다음 client/main.go에 다음 코드를 추가합니다. 🎜rrreee🎜마지막으로 프로젝트 루트 디렉터리에서 다음 명령을 실행할 수 있습니다. 서버와 클라이언트를 시작하려면: 🎜rrreee🎜실행 결과는 다음과 같습니다. 🎜rrreee🎜서버가 클라이언트의 요청을 성공적으로 수신하고 처리된 데이터를 반환한 것을 볼 수 있습니다. 🎜🎜요약: 🎜이 문서에서는 gRPC를 사용하여 Golang에서 동시 데이터 전송을 구현하는 방법에 대한 모범 사례를 소개합니다. 적절한 프로젝트 구조를 구축하고, 연결을 생성하고, 서비스 인터페이스를 구현하고, 서비스를 시작함으로써 동시 데이터 전송에 gRPC를 쉽게 사용할 수 있습니다. 이 기사가 gRPC를 사용 중이거나 사용할 개발자에게 도움이 되기를 바랍니다. 🎜위 내용은 Golang에서 동시 데이터 전송을 구현하기 위해 gRPC를 사용하는 모범 사례의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
