\u57fa\u4e8e Dubbo3 \u5b9a\u4e49\u7684 Triple \u534f\u8bae\uff0c\u4f60\u53ef\u4ee5\u8f7b\u677e\u7f16\u5199\u6d4f\u89c8\u5668\u3001\u79fb\u52a8\u7aef\u3001gRPC \u517c\u5bb9\u7684 RPC \u670d\u52a1\uff0c\u5e76\u8ba9\u8fd9\u4e9b\u670d\u52a1\u540c\u65f6\u8fd0\u884c\u5728 HTTP\/1 \u548c HTTP\/2 \u4e0a\u3002Dubbo Node.js SDK \u652f\u6301\u4f7f\u7528 IDL \u6216\u7f16\u7a0b\u8bed\u8a00\u7279\u6709\u7684\u65b9\u5f0f\u5b9a\u4e49\u670d\u52a1\uff0c\u5e76\u63d0\u4f9b\u4e00\u5957\u8f7b\u91cf\u7684 API \u6765\u53d1\u5e03\u6216\u8c03\u7528\u8fd9\u4e9b\u670d\u52a1\u3002<\/p>\n
<\/p>\n
\u5173\u4e8e Dubbo3 Node.js \u9996\u4e2a\u53d1\u5e03\u7248<\/h2>\n
Dubbo-js \u9879\u76ee\u4e8e 9 \u6708\u4efd\u521a\u521a\u53d1\u5e03\u4e86\u652f\u6301 Dubbo3 \u534f\u8bae\u7684\u9996\u4e2a alpha \u7248\u672c\uff0c\u8be5\u9879\u76ee\u662f Dubbo3 \u7684 Typescript \u7248\u672c\u5b9e\u73b0\uff0c\u63d0\u4f9b\u4e86 Web\u3001Node.js \u4e24\u79cd\u53d1\u5e03\u5305\u3002\u5176\u4e2d\uff0cWeb \u6846\u67b6\u80fd\u8ba9\u5f00\u53d1\u8005\u76f4\u63a5\u5728\u6d4f\u89c8\u5668\u9875\u9762\u8bbf\u95ee\u540e\u7aef\u670d\u52a1\uff0cNode.js \u5219\u8fdb\u4e00\u6b65\u4e30\u5bcc\u4e86\u540e\u7aef\u5fae\u670d\u52a1\u6280\u672f\u6808\u7684\u9009\u62e9\u3002\u5f53\u524d Node.js \u7248\u672c\u4e3b\u8981\u662f\u5b9e\u73b0\u4e86 Triple \u534f\u8bae\u7684\u5b8c\u6574\u652f\u6301\uff0c\u63a5\u4e0b\u6765\u7684\u7248\u672c\u4e2d\uff0c\u793e\u533a\u5c06\u7ee7\u7eed\u5b8c\u5584\u5730\u5740\u53d1\u73b0\u3001\u8d1f\u8f7d\u5747\u8861\u7b49\u670d\u52a1\u6cbb\u7406\u80fd\u529b\u3002<\/p>\n
Node.js \u5fae\u670d\u52a1\u5f00\u53d1\u5b8c\u6574\u793a\u4f8b<\/h3>\n
\u672c\u793a\u4f8b\u57fa\u4e8e\u6700\u65b0\u53d1\u5e03\u7684 Node.js \u7248\u672c\uff0c\u6f14\u793a\u4e86\u57fa\u4e8e Triple \u534f\u8bae\u7684 RPC \u901a\u4fe1\u6a21\u5f0f\uff0c\u793a\u4f8b\u4f7f\u7528 Protocol Buffer \u5b9a\u4e49 RPC \u670d\u52a1\uff0c\u5e76\u6f14\u793a\u4e86\u4ee3\u7801\u751f\u6210\u3001\u670d\u52a1\u53d1\u5e03\u548c\u670d\u52a1\u8bbf\u95ee\u7b49\u8fc7\u7a0b\u3002<\/p>\n
\u524d\u7f6e\u6761\u4ef6<\/h4>\n
\u56e0\u4e3a\u4f7f\u7528 Protocol Buffer \u7684\u539f\u56e0\uff0c\u6211\u4eec\u9996\u5148\u9700\u8981\u5b89\u88c5\u76f8\u5173\u7684\u4ee3\u7801\u751f\u6210\u5de5\u5177\uff0c\u8fd9\u5305\u62ec @bufbuild\/protoc-gen-es\u3001@bufbuild\/protobuf\u3001@apachedubbo\/protoc-gen-apache-dubbo-es\u3001@apachedubbo\/dubbo\u3002<\/p>\n
npm install @bufbuild\/protoc-gen-es @bufbuild\/protobuf @apachedubbo\/protoc-gen-apache-dubbo-es @apachedubbo\/dubbo<\/code><\/pre>\n\u5b9a\u4e49\u670d\u52a1<\/h4>\n
\u73b0\u5728\uff0c\u4f7f\u7528 Protocol Buffer (IDL) \u6765\u5b9a\u4e49\u4e00\u4e2a Dubbo \u670d\u52a1\u3002<\/p>\n
\u521b\u5efa\u76ee\u5f55\uff0c\u5e76\u751f\u6210\u6587\u4ef6\uff1a<\/p>\n
mkdir -p proto && touch proto\/example.proto<\/code><\/pre>\n\u5199\u5165\u5185\u5bb9\uff1a<\/p>\n
syntax = "proto3";\n\npackage apache.dubbo.demo.example.v1;\n\nmessage SayRequest {\n string sentence = 1;\n}\n\nmessage SayResponse {\n string sentence = 1;\n}\n\nservice ExampleService {\n rpc Say(SayRequest) returns (SayResponse) {}\n}<\/code><\/pre>\n\u8fd9\u4e2a\u6587\u4ef6\u58f0\u660e\u4e86\u4e00\u4e2a\u53eb\u505a ExampleService \u7684\u670d\u52a1\uff0c\u4e3a\u8fd9\u4e2a\u670d\u52a1\u5b9a\u4e49\u4e86 Say \u65b9\u6cd5\u4ee5\u53ca\u5b83\u7684\u8bf7\u6c42\u53c2\u6570 SayRequest \u548c\u8fd4\u56de\u503c SayResponse\u3002<\/p>\n
\u751f\u6210\u4ee3\u7801<\/h4>\n
\u521b\u5efa gen \u76ee\u5f55\uff0c\u505a\u4e3a\u751f\u6210\u6587\u4ef6\u653e\u7f6e\u7684\u76ee\u6807\u76ee\u5f55\u3002<\/p>\n
mkdir -p gen<\/code><\/pre>\n\u8fd0\u884c\u4ee5\u4e0b\u547d\u4ee4\uff0c\u5728 gen \u76ee\u5f55\u4e0b\u751f\u6210\u4ee3\u7801\u6587\u4ef6\uff1a<\/p>\n
PATH=$PATH:$(pwd)\/node_modules\/.bin \/\n protoc -I proto \/\n --es_out gen \/\n --es_opt target=ts \/\n --apache-dubbo-es_out gen \/\n --apache-dubbo-es_opt target=ts \/\n example.proto<\/code><\/pre>\n\u8fd0\u884c\u547d\u4ee4\u540e\uff0c\u5e94\u8be5\u53ef\u4ee5\u5728\u76ee\u6807\u76ee\u5f55\u4e2d\u770b\u5230\u4ee5\u4e0b\u751f\u6210\u7684\u6587\u4ef6:<\/p>\n
\u251c\u2500\u2500 gen\n\u2502 \u251c\u2500\u2500 example_dubbo.ts\n\u2502 \u2514\u2500\u2500 example_pb.ts\n\u251c\u2500\u2500 proto\n\u2502 \u2514\u2500\u2500 example.proto<\/code><\/pre>\n\u5b9e\u73b0\u670d\u52a1<\/h4>\n
\u63a5\u4e0b\u6765\u6211\u4eec\u5c31\u9700\u8981\u6dfb\u52a0\u4e1a\u52a1\u903b\u8f91\u4e86\uff0c\u5b9e\u73b0 ExampleService \uff0c\u5e76\u5c06\u5176\u6ce8\u518c\u5230 DubboRouter \u4e2d\u3002<\/p>\n
\u521b\u5efa dubbo.ts \u6587\u4ef6\uff1a<\/p>\n
import { DubboRouter } from "@apachedubbo\/dubbo";\nimport { ExampleService } from ".\/gen\/example_dubbo";\n\nexport default (router: DubboRouter) =>\n \/\/ registers apache.dubbo.demo.example.v1\n router.service(ExampleService, {\n \/\/ implements rpc Say\n async say(req) {\n return {\n sentence: `You said: ${req.sentence}`,\n };\n },\n }, { serviceGroup: 'dubbo', serviceVersion: '1.0.0' });<\/code><\/pre>\n\u542f\u52a8 Server<\/h4>\n
Dubbo \u670d\u52a1\u53ef\u4ee5\u5d4c\u5165\u5230\u666e\u901a\u7684 Node.js \u670d\u52a1\u5668\u3001Next.js\u3001Express \u6216 Fastify \u4e2d\u3002\u5728\u8fd9\u91cc\u6211\u4eec\u5c06\u4f7f\u7528 Fastify\uff0c\u6240\u4ee5\u8ba9\u6211\u4eec\u5b89\u88c5 Fastify \u4ee5\u53ca\u6211\u4eec\u4e3a Fastify \u51c6\u5907\u7684\u63d2\u4ef6\u3002<\/p>\n
npm install fastify @apachedubbo\/dubbo-fastify<\/code><\/pre>\n\u521b\u5efa server.ts \u6587\u4ef6\uff0c\u65b0\u5efa\u4e00\u4e2a Server\uff0c\u628a\u4e0a\u4e00\u6b65\u4e2d\u5b9e\u73b0\u7684 ExampleService \u6ce8\u518c\u7ed9\u5b83\u3002<\/p>\n
\u63a5\u4e0b\u6765\u5c31\u53ef\u4ee5\u76f4\u63a5\u521d\u59cb\u5316\u548c\u542f\u52a8 Server \u4e86\uff0c\u5b83\u5c06\u5728\u6307\u5b9a\u7684\u7aef\u53e3\u63a5\u6536\u8bf7\u6c42\u3002<\/p>\n
import { fastify } from "fastify";\nimport { fastifyDubboPlugin } from "@apachedubbo\/dubbo-fastify";\nimport routes from ".\/dubbo";\n\nasync function main() {\n const server = fastify();\n await server.register(fastifyDubboPlugin, {\n routes,\n });\n server.get("\/", (_, reply) => {\n reply.type("text\/plain");\n reply.send("Hello World!");\n });\n await server.listen({ host: "localhost", port: 8080 });\n console.log("server is listening at", server.addresses());\n}\n\nvoid main();<\/code><\/pre>\n\u6700\u540e\uff0c\u8fd0\u884c\u4ee3\u7801\u542f\u52a8\u670d\u52a1\u3002<\/p>\n
npx tsx server.ts<\/code><\/pre>\n\u8bbf\u95ee\u670d\u52a1<\/h4>\n
\u6700\u7b80\u5355\u7684\u65b9\u5f0f\u662f\u4f7f\u7528 HTTP\/1.1 POST \u8bf7\u6c42\u8bbf\u95ee\u670d\u52a1\uff0c\u53c2\u6570\u5219\u4f5c\u4ee5\u6807\u51c6 JSON \u683c\u5f0f\u4f5c\u4e3a HTTP \u8d1f\u8f7d\u4f20\u9012\u3002\u5982\u4e0b\u662f\u4f7f\u7528 cURL \u547d\u4ee4\u7684\u8bbf\u95ee\u793a\u4f8b:<\/p>\n
curl \/\n --header 'Content-Type: application\/json' \/\n --header 'TRI-Service-Version: 1.0.0' \/\n --header 'TRI-Service-group: dubbo' \/\n --data '{"sentence": "Hello World"}' \/\n http:\/\/localhost:8080\/apache.dubbo.demo.example.v1.ExampleService\/Say<\/code><\/pre>\n\u4e5f\u53ef\u4ee5\u4f7f\u7528\u6807\u51c6\u7684 Dubbo client \u8bf7\u6c42\u670d\u52a1\uff0c\u6211\u4eec\u9996\u5148\u9700\u8981\u4ece\u751f\u6210\u4ee3\u7801\u5373 dubbo-node \u5305\u4e2d\u83b7\u53d6\u670d\u52a1\u4ee3\u7406\uff0c\u4e3a\u5b83\u6307\u5b9a server \u5730\u5740\u5e76\u521d\u59cb\u5316\uff0c\u4e4b\u540e\u5c31\u53ef\u4ee5\u53d1\u8d77\u8d77 RPC \u8c03\u7528\u4e86\u3002<\/p>\n
\u521b\u5efa client.ts \u6587\u4ef6\u3002<\/p>\n
import { createPromiseClient } from "@apachedubbo\/dubbo";\nimport { ExampleService } from ".\/gen\/example_dubbo";\nimport { createDubboTransport } from "@apachedubbo\/dubbo-node";\n\nconst transport = createDubboTransport({\n baseUrl: "http:\/\/localhost:8080",\n httpVersion: "1.1",\n});\n\nasync function main() {\n const client = createPromiseClient(ExampleService, transport, { serviceVersion: '1.0.0', serviceGroup: 'dubbo' });\n const res = await client.say({ sentence: "Hello World" });\n console.log(res);\n}\nvoid main();<\/code><\/pre>\n\u8fd0\u884c\u5ba2\u6237\u7aef\uff1a<\/p>\n
npx tsx client.ts<\/code><\/pre>\n\u603b\u7ed3<\/h2>\n
\u5f53\u524d Node.js \u7248\u672c\u4e3b\u8981\u662f\u5b9e\u73b0\u4e86 Triple \u534f\u8bae\u7684\u5b8c\u6574\u652f\u6301\uff0c\u63a5\u4e0b\u6765\u7684\u7248\u672c\u4e2d\uff0c\u793e\u533a\u5c06\u7ee7\u7eed\u5b8c\u5584\u5730\u5740\u53d1\u73b0\u3001\u8d1f\u8f7d\u5747\u8861\u7b49\u670d\u52a1\u6cbb\u7406\u80fd\u529b<\/p>\n
\u76f8\u5173\u94fe\u63a5\uff1a<\/strong><\/p>\n[1] apache\/dubbo<\/p>\n
https:\/\/github.com\/apache\/dubbo<\/a><\/p>\n[2] apache\/dubbo-go<\/p>\n
https:\/\/github.com\/apache\/dubbo-go<\/a><\/p>\n[3] apache\/dubbo-js<\/p>\n
https:\/\/github.com\/apache\/dubbo-js<\/a><\/p>\n[4] apache\/dubbo-rust<\/p>\n
https:\/\/github.com\/apache\/dubbo-rust<\/a><\/p>\n\u4f5c\u8005\uff1a\u8521\u5efa\u603f<\/p>\n
\u70b9\u51fb\u7acb\u5373\u514d\u8d39\u8bd5\u7528\u4e91\u4ea7\u54c1 \u5f00\u542f\u4e91\u4e0a\u5b9e\u8df5\u4e4b\u65c5\uff01<\/strong><\/a><\/p><\/blockquote>\n