grpc学习golang版（ 服务器流式传输 ）

package main
 
import (
    "context"
    "fmt"
    "log"
    "net"
 
    "google.golang.org/grpc"
    "google.golang.org/grpc/codes"
    "google.golang.org/grpc/status"
 
    pb "your_gprc_package_name" // 替换为你的gRPC包名称
)
 
// 定义你的结构体，用于服务
type server struct{}
 
// 实现你的gRPC服务方法
func (s *server) ListFeatures(query *pb.Point, stream pb.RouteGuide_ListFeaturesServer) error {
    // 模拟功能列表
    features := []*pb.Feature{
        {Name: "特性1", Location: &pb.Point{Latitude: 1, Longitude: 1}},
        {Name: "特性2", Location: &pb.Point{Latitude: 2, Longitude: 2}},
        // 更多特性...
    }
 
    // 通过循环发送特性给客户端
    for _, feature := range features {
        if err := stream.Send(feature); err != nil {
            return status.Errorf(codes.Unavailable, "无法发送特性: %v", err)
        }
    }
 
    return nil
}
 
func main() {
    // 设置监听端口
    lis, err := net.Listen("tcp", ":50051")
    if err != nil {
        log.Fatalf("无法监听端口: %v", err)
    }
 
    // 创建gRPC服务器实例
    s := grpc.NewServer()
 
    // 注册服务
    pb.RegisterRouteGuideServer(s, &server{})
 
    // 服务监听
    if err := s.Serve(lis); err != nil {
        log.Fatalf("服务监听失败: %v", err)
    }
}

这个代码实例展示了如何在Go语言中使用gRPC框架创建一个简单的gRPC服务器，该服务器提供了一个服务端流式方法ListFeatures。它定义了一个服务结构体server，实现了RouteGuide服务，并在指定端口监听客户端的请求。在ListFeatures函数中，它模拟了一些特性并通过流发送给客户端。