安科网

grpc之protobuf常用语法速学

gumingyaotangwei

gumingyaotangwei

2019-12-22

关注 关注

1，语法速学(1):返回商品”数组”、repeated修饰符

Repeated:是一个修饰符,返回字段可以重复任意多次（包括0次） 可以认为就是一个数组(切片)

服务端：

创建protobuf文件

syntax="proto3";
package services;
import "google/api/annotations.proto";

message  ProdRequest {
    int32 prod_id =1;   //传入的商品ID
}
message ProdResponse{
    int32 prod_stock=1;//商品库存
}

message QuerySize{
    int32 size = 1;//页尺寸
}

//返回 一堆商品库存，使用了repeated修饰符
message ProdResponseList{
    repeated ProdResponse prodres=1;
}

service ProdService {
    rpc GetProdStock (ProdRequest) returns (ProdResponse){
        option (google.api.http) = {
            get: "/v1/prod/{prod_id}"
        };

    }
    rpc GetProdStocks(QuerySize) returns (ProdResponseList){

    }
}

生成Prod.pb.go文件

cd pbfiles && protoc --go_out=plugins=grpc:../services  Prod.proto

创建ProdSerbice.go文件

package services

import (
    "context"
)

type ProdService struct {

}

func(this *ProdService) GetProdStock(ctx context.Context, request *ProdRequest) (*ProdResponse, error) {

      return &ProdResponse{ProdStock:20},nil
}

func (this *ProdService) GetProdStocks(ctx context.Context,size *QuerySize) (*ProdResponseList, error){
    var Prodres []*ProdResponse
    Prodres = make([]*ProdResponse,0,3)
    Prodres = append(Prodres,&ProdResponse{ProdStock:28,})
    Prodres = append(Prodres,&ProdResponse{ProdStock:29,})
    Prodres = append(Prodres,&ProdResponse{ProdStock:30,})
    return &ProdResponseList{
        Prodres:Prodres,
    },nil
}

server.go

package main

import (
    "google.golang.org/grpc"
    "grpcpro/services"
    "net"
)

func main()  {
    rpcServer:=grpc.NewServer()
    services.RegisterProdServiceServer(rpcServer,new(services.ProdService))

    lis,_:=net.Listen("tcp",":8081")

    rpcServer.Serve(lis)


}

启动服务

go run server.go

客户端：

拷贝服务端的生成的文件Prod.pb.go到客户端目录下

mian.go

package main

import (
    "context"
    "fmt"
    "google.golang.org/grpc"
    "gprccli/services"
    "log"
)

func main(){

    conn,err:=grpc.Dial(":8081",grpc.WithInsecure())
    if err!=nil{
        log.Fatal(err)
    }
    defer conn.Close()

    prodClient:=services.NewProdServiceClient(conn)
    ctx:=context.Background()

    //prodRes,err:=prodClient.GetProdStock(context.Background(),
    //    &services.ProdRequest{ProdId:12})
    //if err!=nil{
    //    log.Fatal(err)
    //}
    //fmt.Println(prodRes.ProdStock)

    response,err := prodClient.GetProdStocks(ctx,&services.QuerySize{Size:10})

    if err!=nil{
        log.Fatal(err)
    }
    fmt.Println(response.Prodres[2].ProdStock)
}

启动客户端client 调用服务端gprc服务

go run main.go

2，语法速学(2): 使用枚举、获取分区商品库存

1、传入一个商品ID 获取一个商品库存。

2、根据size获取一堆商品的库存列表

3，创建枚举类型，支持分区枚举参数

enum ProdAreas{
    A=0;
    B=1;
    C=2;
}

ProdService.go

package services

import (
    "context"
)

type ProdService struct {}

func(this *ProdService) GetProdStock(ctx context.Context, request *ProdRequest) (*ProdResponse, error) {

      var stock int32=0
      if request.ProdArea==ProdAreas_A{
          stock=30
      }else if request.ProdArea==ProdAreas_B{
          stock=31
      }else{
          stock=50
      }
      return &ProdResponse{ProdStock:stock},nil
}
func(this *ProdService) GetProdStocks(ctx context.Context,size *QuerySize) (*ProdResponseList, error)  {
            Prodres:= []*ProdResponse{
                    &ProdResponse{ProdStock:28},
                    &ProdResponse{ProdStock:29},
                    &ProdResponse{ProdStock:30},
                    &ProdResponse{ProdStock:31},
            }
            return &ProdResponseList{
                Prodres:Prodres,
            },nil
}

语法速学(3): 导入外部Proto、获取商品信息

服务端：

Models.proto

syntax="proto3";
package services;
message ProdModel{ //商品模型
    int32 prod_id=1;
    string prod_name=2;
    float prod_price=3;
}

Prod.proto

syntax="proto3";
package services;


import "google/api/annotations.proto";
import "Models.proto";

enum ProdAreas{
    A=0;
    B=1;
    C=2;
}

message  ProdRequest {
    int32 prod_id =1;   //传入的商品ID
}
message ProdResponse{
    int32 prod_stock=1;//商品库存
}

message QuerySize{
    int32 size = 1;//页尺寸
}

//返回 一堆商品库存，使用了repeated修饰符
message ProdResponseList{
    repeated ProdResponse prodres=1;
}

service ProdService {
    rpc GetProdStock (ProdRequest) returns (ProdResponse){
        option (google.api.http) = {
            get: "/v1/prod/{prod_id}"
        };

    }
    rpc GetProdStocks(QuerySize) returns (ProdResponseList){

    }

    rpc GetProdInfo(ProdRequest) returns(ProdModel){}
}

生成pb.go文件

protoc --go_out=plugins=grpc:../services  Prod.proto

protoc --go_out=plugins=grpc:../services  Models.proto

ProdService.go

package services

import (
    "context"
)

type ProdService struct {

}

func(this *ProdService) GetProdStock(ctx context.Context, request *ProdRequest) (*ProdResponse, error) {

      return &ProdResponse{ProdStock:20},nil
}

func (this *ProdService) GetProdStocks(ctx context.Context,size *QuerySize) (*ProdResponseList, error){
    var Prodres []*ProdResponse
    Prodres = make([]*ProdResponse,0,3)
    Prodres = append(Prodres,&ProdResponse{ProdStock:28,})
    Prodres = append(Prodres,&ProdResponse{ProdStock:29,})
    Prodres = append(Prodres,&ProdResponse{ProdStock:30,})
    return &ProdResponseList{
        Prodres:Prodres,
    },nil
}

func (this *ProdService) GetProdInfo(ctx context.Context, in *ProdRequest) (*ProdModel, error){

    ret:=ProdModel{
        ProdId:101,
        ProdName:"测试商品",
        ProdPrice:20.5,
    }
    return &ret,nil
}

客户端：

拷贝服务端 Models.pb.go和Prod.pb.go到客户端下

package main

import (
    "context"
    "fmt"
    "google.golang.org/grpc"
    "gprccli/services"
    "log"
)

func main(){

    conn,err:=grpc.Dial(":8081",grpc.WithInsecure())
    if err!=nil{
        log.Fatal(err)
    }
    defer conn.Close()

    prodClient:=services.NewProdServiceClient(conn)
    ctx:=context.Background()

    //prodRes,err:=prodClient.GetProdStock(context.Background(),
    //    &services.ProdRequest{ProdId:12})
    //if err!=nil{
    //    log.Fatal(err)
    //}
    //fmt.Println(prodRes.ProdStock)

    //response,err := prodClient.GetProdStocks(ctx,&services.QuerySize{Size:10})
    //
    //if err!=nil{
    //    log.Fatal(err)
    //}
    //fmt.Println(response.Prodres[2].ProdStock)

    prod,err :=prodClient.GetProdInfo(ctx,&services.ProdRequest{ProdId:12})
    if err!=nil{
        log.Fatal(err)
    }
    fmt.Println(prod)
}

grpc protobuf services

gumingyaotangwei

gumingyaotangwei

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

微服务开发手册之GRPC

> GRPC是一个高性能、通用的开源RPC框架，基于HTTP/2协议标准和Protobuf序列化协议开发，支持众多的开发语言。gRPC使用protocol buffers作为接口描述语言以及底层的信息交换格式，一般情况下推荐使用 proto3因为其能

小小书童 2020-05-20

gRPC 介绍和简单实现

　　gRPC是Google公司基于Protobuf开发的跨语言的开源RPC框架。gRPC基于HTTP/2协议设计，可以基于一个HTTP/2链接提供多个服务，对于移动设备更加友好。本节将讲述gRPC的简单用法。　　最底层为TCP或Unix Socket协议，

极品小肥羊 2020-04-23

grpc| python 实战 grpc【h】

description: 只要代码可以跑起来, 很多难题都会迎刃而解. so, keep coding and stay hungry.之前用 swoole 写 server 时就接触过 protobuf, 本来以为基于 protobuf 的 grpc,

小小书童 2019-12-28

gRPC详解

所谓RPC框架实际是提供了一套机制，使得应用程序之间可以进行通信，而且也遵从server/client模型。如下图所示就是一个典型的RPC结构图。gRPC和restful API都提供了一套通信机制，用于server/client模型通信，而且它们都使用h

comhaqs 2019-12-28

grpc服务端转换protobuf到http请求参数query

grpc服务接收到request的请求后，需要把参数转换成http，去请求其他接口。方案1是比较简单的，用空格分割，得到参数和值，再根据":"分割得到参数、值，再加入到url.values{}

Erick 2019-12-18

GRPC基础入门

　　项目中要使用rpc协议框架来实现两个系统之间的接口调用。A系统调用B系统的相应接口，因为考虑到http请求会包含更多冗余信息，造成请求过大，因此选用了rpc众多框架中的grpc。　　grpc是google开源的rpc框架，目前版本1.0.0，看jar包

极品小肥羊 2018-03-17

.Net Core中使用Grpc的方法

　　gRPC 基于如下思想：定义一个服务， 指定其可以被远程调用的方法及其参数和返回类型。gRPC 默认使用protocol buffers作为接口定义语言，来描述服务接口和有效载荷消息结构。如果有需要的话，可以使用其他替代方案。服务端流式 RPC，即客户

darren0zdc 2020-10-16

java 通过 Grpc 与c 通信

由于项目是java 和 c 开发的并且各自独立部署，所以涉及业务需要进行java 与c 通信；根据自测grpc 客户端发现，grpc 支持自动重连、自动判断服务是否上线；

ltstud 2020-07-24

思考gRPC ：为什么是HTTP/2

§。§

岁月如歌 2020-07-21

grpc 安装

安装请参考官方资料-快速开始，安装gRPC需要安装Go、protocol buffer、protoc-gen-go、gRPC等。windows下直接下载编译好的包，然后将bin目录加到环境变量。这是因为grpc的版本和protoc-gen-go版本不一致造

Erick 2020-07-18

golang使用grpc

我的网络通信概念还停留在比较基础的地方, 直觉来说就是发送一个get/post请求, 设定一定的参数格式, 这样对方再解析你的数据, 基于此完成通讯.而rpc则不使用这种显式的通讯方式, 通过proto与生成grpc文件, 里面提供方法, 供client与

wujingsheng0 2020-06-16

Asp.net core 通过grpc调用python

简单来说就是远程过程调用。举个例子，比如在C#代码中直接调用python 中写的方法，或者一个C#进程调用另一个C#进程中的方法，或者其他语言之间的互相调用。具体书写方法可百度。syntax = "proto3"; //表示用的是pro

xmwang0 2020-06-14

【gRPC】 在.Net core中使用gRPC

gRPC是一个高性能的通信协议，它基于HTTP/2和protocol buffers。它是微服务之间进行同步通信的主要选择。与之相对的，就是其他协议，如AMQP的异步通信队列或者发布/订阅模式。RPC框架实际是提供了一套机制，使得应用程序之间可以进行通信，

极品小肥羊 2020-05-31

gRPC怎样节省您的开发时间

此时，您应该已经听说过" gRPC"。在本文中，我将着重介绍采用gRPC作为微服务之间的通信介质的好处。首先，我将尝试简要介绍一下架构演变的历史。其次，我将重点介绍使用REST和可能出现的问题。最后，我将以我的开发工作流程为例。一切都在

小小书童 2020-04-10

Service Mesh - gRPC 本地联调远程服务

Service Mesh 架构下，服务间调用会通过服务名互相调用，比如在 Kubernetes 、Docker Swarm 集群中，服务 IP 均由集群动态分配，外部网络无法直接访问到集群内部的服务。比较优雅一点的做法是本地启动相应服务，gRPC 调用都连

君小黑 2020-03-04

GRPC协议的相关原理

GRPC的Client与Server，均通过Netty Channel作为数据通信，序列化、反序列化则使用Protobuf，每个请求都将被封装成HTTP2的Stream，在整个生命周期中，客户端Channel应该保持长连接，而不是每次调用重新创建Chann

naiwenw 2020-02-18

使用gRPC-Web从浏览器调用.NET gRPC服务

我很高兴宣布通过.NET对gRPC-Web进行实验性支持。gRPC-Web允许从基于浏览器的应用程序调用gRPC。gRPC-Web通过与HTTP / 1.1和HTTP / 2兼容来解决此问题。gRPC-Web不是一项新技术。有一个稳定的gRPC-Web J

小小书童 2020-02-22

一个新实验：使用gRPC-Web从浏览器调用.NET gRPC服务

今天给大家翻译一篇由ASP.NET首席开发工程师James Newton-King前几天发表的一篇博客，文中带来了一个实验性的产品gRPC-Web。大家可以点击文末的讨论帖进行相关反馈。我会在文章末尾给出原文链接。我很高兴宣布通过.NET对gRPC-Web

dabaoge 2020-02-16

ASP.NET Core 3.0 gRPC拦截器的使用

前面两篇文章给大家介绍了使用gRPC的入门以及双向流的使用，今天介绍的是gRPC中的拦截器。拦截器就像MVC的过滤器或者是ASP.NET Core middleware 一样，具有面向切面的思想，可以在调用服务的时候进行一些统一处理， 很适合在这里处理验证

小小书童 2019-12-23

ASP.NET Core 3.0使用gRPC的具体方法

gRPC ±Googleè·¨èè¨é§èè¨è¨è°¨RPC gRPC·¨¨é°èèéè¨HTTP/2éè¨ Protocol Buffers è。Grpc.AspNetCore ¨¨ASP.NET CoreègRPC° gRPCASP.NET Core

dabaoge 2020-01-25
gumingyaotangwei

gumingyaotangwei

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号