特使GRPC反向桥-接收代码为0的RST_STREAM
特使GRPC反向桥-接收代码为0的RST_STREAM
提问于 2022-03-26 12:26:18
我试图通过GRPC客户端，通过特使GRPC反向桥访问HTTP1.1 rest。但是当我测试它时，我得到了下面的错误。任何帮助或示例代码片段都将不胜感激。谢谢!
Error: 13 INTERNAL: Received RST_STREAM with code 0
at Object.callErrorFromStatus (/Users/meiyappan/grpc-node/grpc/examples/node/node_modules/@grpc/grpc-js/build/src/call.js:31:26)
at Object.onReceiveStatus (/Users/meiyappan/grpc-node/grpc/examples/node/node_modules/@grpc/grpc-js/build/src/client.js:176:52)我的特使代理配置XML
admin:
address:
socket_address:
address: 0.0.0.0
port_value: 9901
static_resources:
listeners:
- name: listener_0
address:
socket_address:
address: 0.0.0.0
port_value: 50051
filter_chains:
- filters:
- name: envoy.filters.network.http_connection_manager
typed_config:
"@type": type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager
access_log:
- name: envoy.access_loggers.stdout
typed_config:
"@type": type.googleapis.com/envoy.extensions.access_loggers.stream.v3.StdoutAccessLog
stat_prefix: ingress_http
route_config:
name: local_route
virtual_hosts:
- name: local_service
domains: ["*"]
routes:
- match:
prefix: "/"
route:
cluster: grpc
timeout: 50.00s
# per_filter_config disables the filter for this route
typed_per_filter_config:
envoy.filters.http.grpc_http1_reverse_bridge:
"@type": type.googleapis.com/envoy.extensions.filters.http.grpc_http1_reverse_bridge.v3.FilterConfigPerRoute
disabled: true
http_filters:
- name: envoy.filters.http.grpc_http1_reverse_bridge
typed_config:
"@type": type.googleapis.com/envoy.extensions.filters.http.grpc_http1_reverse_bridge.v3.FilterConfig
content_type: application/grpc
withhold_grpc_frames: true
- name: envoy.filters.http.router
clusters:
- name: grpc
type: STRICT_DNS
lb_policy: ROUND_ROBIN
load_assignment:
cluster_name: grpc
endpoints:
- lb_endpoints:
- endpoint:
address:
socket_address:
address: localhost
port_value: 80这是Proto文件
// The greeting service definition.
service Greeter {
// Sends a greeting
rpc SayHello (HelloRequest) returns (HelloReply) {}
}
// The request message containing the user's name.
message HelloRequest {
string name = 1;
}
// The response message containing the greetings
message HelloReply {
string message = 1;
}我的，使用
app.post('/helloworld.greeter/SayHello', async (req, res) => {
console.log(req)
const root = await protobuf.load(PROTO_PATH);
const HelloReply = root.lookupType('helloworld.HelloReply');
const buf = HelloReply.encode({ message: 'Hello Bill'}).finish();
res.send(buf)
res.end();
})节点js中的GRPC客户端代码
function main() {
var target = 'localhost:50051';
var client = new hello_proto.Greeter(target,
grpc.credentials.createInsecure());
var user = 'world';
var metadata = new grpc.Metadata();
metadata.add('Content-Type', 'application/grpc')
client.sayHello({name: user},metadata, function(err, response) {
console.log(err)
console.log('Greeting:', response);
});
}回答 1
Stack Overflow用户
回答已采纳
发布于 2022-03-27 13:49:27
我已经成功地复制了你的问题。有两件事不对：
在您的特使配置中，删除typed_per_filter_config，因为这里您说不使用grpc_http1_reverse_bridge for /，但是应该使用它。
在服务器实现中，添加：
res.header("Content-Type", "application/grpc");就在res.send(buf)之前。
然后，在你的客户中，如果你写：
console.log('Greeting:', response.getMessage());你应该看看：Greeting: Hello Bill。
检索请求属性
此外，如果您想检索请求体，则应该在服务器中使用原始快件中间件：
app.use(express.raw({type: "application/grpc"}));然后：
const root = await protobuf.load(PROTO_PATH);
app.post('/helloworld.greeter/SayHello', (req, res) => {
var message = "Hello";
// if there is a body, transform it to HelloRequest and retrieve name
if (req.body !== undefined && req.body instanceof Buffer && req.body.length != 0) {
const HelloRequest = root.lookupType('helloworld.HelloRequest');
const helloReq = HelloRequest.decode(req.body);
message += " " + helloReq.name;
}
res.header("Content-Type", "application/grpc");
const HelloReply = root.lookupType('helloworld.HelloReply');
res.send(HelloReply.encode({ message: message }).finish());
});客户端，您可以这样传递名称：
var request = new HelloRequest();
request.setName("World");通过执行客户机，您现在应该获得：Greeting: Hello World。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/71628043
复制相关文章
相似问题
腾讯云开发者
