HTTP协议转gRPC协议

插件信息

名称	字段	属性
http协议转gRPC协议	http_to_grpc	协议转换

功能描述

将客户端 HTTP请求 转换成 gRPC请求 转发给上游服务，并将上游服务的 gRPC响应 转换成 HTTP响应 转发给客户端。该插件仅当路由驱动为http时生效。

Open Api

配置参数说明

参数名	值类型	是否必填	值可能性	默认值	说明
types	array_string	否	["text/html","application/json"]		需要压缩的响应content-type类型列表，不填则 匹配任何 MIME 类型， 不填则为所有
min_length	int	否	1	1	待压缩内容的最小长度
vary	bool	否	false	false	是否加上Vary: Accept-Encoding响应头部

Open Api

插件配置参数

参数名	值类型	是否必填	值可能性	默认值	说明
service	string	否	Service.Hello		服务名称，gRPC调用服务名
method	string	否	Hello		方法名称，gRPC调用方法名
authority	string	否			虚拟主机域名(Authority)
format	string	是	json		请求数据格式
reflect	bool	是		false	反射，若gRPC服务器开启了反射，配置时可设置为true
protobuf_id	string	否			protobuf编码器ID，若reflect为false时，该值必填
header	map[string]string	否	{"name":"apinto"}		额外头部，转发请求时，会将其拼接到转发的请求头部中一并转发

• 当服务名称不填时，则默认使用 HTTP请求路径的第一个/和第二个/之间的值作为服务名
• 当方法名称不填时，则默认使用 HTTP请求路径的第二个/和第三个/之间的值作为服务名
• 即，若HTTP请求路径上/Service.Hello/Hello，则此时服务名称为Service.Hello，方法名称为Hello

配置示例

{
    "authority":"",
    "format":"json",
    "headers":{

    },
    "method":"",
    "protobuf_id":"demo@transcode",
    "reflect":false,
    "service":""
}

全局配置

在使用http_to_grpc插件之前，需要在全局插件配置中将name为http_to_grpc的插件状态设置为enable，具体配置点此跳转

curl -X POST  'http://127.0.0.1:9400/api/setting/plugin' \
-H 'Content-Type:application/json' \
-d '{
    "plugins":[{
        "id":"eolinker.com:apinto:http_to_grpc",
        "name":"http_to_grpc",
        "status":"enable"
    }]
}'

配置gRPC上游服务

curl -X POST  'http://127.0.0.1:9400/api/service' -H 'Content-Type:application/json' -d '{
    "balance":"round-robin",
    "create":"2023-02-17 12:33:09",
    "description":"",
    "discovery":"",
    "driver":"http",
    "id":"grpc_demo@service",
    "name":"grpc_demo",
    "nodes":[
        "127.0.0.1:9001"
    ],
    "pass_host":"node",
    "profession":"service",
    "retry":0,
    "scheme":"HTTP",
    "timeout":2000,
    "update":"2023-02-27 19:59:45"
}' 

配置带有http转gRPC协议插件的路由

curl -X POST  'http://127.0.0.1:9400/api/router' -H 'Content-Type:application/json' -d '{
    "listen":8099,
    "method":[
        "GET",
        "POST"
    ],
    "host":[

    ],
    "location":"/Service.Hello/Hello",
    "rules":[

    ],
    "service":"grpc_demo@service",
    "template":"",
    "websocket":false,
    "disable":false,
    "plugins":{
        "http_to_grpc":{
            "disable":false,
            "config":{
                "authority":"",
                "format":"json",
                "headers":{

                },
                "method":"",
                "protobuf_id":"demo@transcode",
                "reflect":false,
                "service":""
            }
        }
    },
    "retry":0,
    "time_out":0,
    "description":""
}' 

使用网关访问gRPC服务端

官方提供gRPC服务端示例，可点击获取gRPC示例代码获取。

1. 启动gRPC服务器

./grpcServer

2、请求Service.Hello服务的Hello方法

示例中，我们定义了Hello方法的功能：

• 将HelloRequest中的name字段通过HelloResponse的msg字段封装成hello,%s的结果返回
• 将请求的Header作为gRPC响应的Trailer头部返回

调用结果如下：