- This lib doesn't use Deno's 1.9 HTTP/2 native bindings, but relies on JS implementation roughly ported from node-http2
- I'm not an expert in gRPC or HTTP/2, I just moved HTTP/2 frames around until it worked
- It was never meant for production use, only for fun and some integration tests and scripts
- I have no plans on implementing full gRPC spec
- load proto files
-
serverunary calls -
clientunary calls - multiplex calls
-
serverserver streams -
clientserver streams - auto reconnects (without retries)
- deadlines/cancellation with AbortController/AbortSignal
- call metadata
- logging interface
- no TLS
- no client streams
- no bidirectional streams
- no client side load balancing
syntax = "proto3";
package helloworld;
service Greeter {
rpc SayHello (HelloRequest) returns (HelloReply) {}
rpc ShoutHello (HelloRequest) returns (stream HelloReply) {}
}
message HelloRequest {
string name = 1;
}
message HelloReply {
string message = 1;
}Service typings are not essential, but it's nice to have them
$ deno run --allow-read https://deno.land/x/[email protected]/gen/dts.ts ./greeter.proto > ./greeter.d.tsexport interface Greeter {
SayHello(request: HelloRequest): Promise<HelloReply>;
ShoutHello(request: HelloRequest): AsyncGenerator<HelloReply>;
}
export interface HelloRequest {
name?: string;
}
export interface HelloReply {
message?: string;
}import { GrpcServer } from "https://deno.land/x/[email protected]/server.ts";
import { Greeter } from "./greeter.d.ts";
const port = 50051;
const server = new GrpcServer();
const protoPath = new URL("./greeter.proto", import.meta.url);
const protoFile = await Deno.readTextFile(protoPath);
server.addService<Greeter>(protoFile, {
async SayHello({ name }) {
const message = `hello ${name || "stranger"}`;
return { message };
},
async *ShoutHello({ name }) {
for (const n of [0, 1, 2]) {
const message = `hello ${name || "stranger"} #${n}`;
yield { message };
}
}
});
console.log(`gonna listen on ${port} port`);
for await (const conn of Deno.listen({ port })) {
server.handle(conn);
}import { getClient } from "https://deno.land/x/[email protected]/client.ts";
import { Greeter } from "./greeter.d.ts";
const protoPath = new URL("./greeter.proto", import.meta.url);
const protoFile = await Deno.readTextFile(protoPath);
const client = getClient<Greeter>({
port: 50051,
root: protoFile,
serviceName: "Greeter",
});
/* unary calls */
console.log(await client.SayHello({ name: "unary #1" }));
console.log(await client.SayHello({ name: "unary #2" }));
/* server stream */
for await (const reply of client.ShoutHello({ name: "streamed" })) {
console.log(reply);
}
client.close();
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent