{"id":10020374,"date":"2024-11-04T15:33:57","date_gmt":"2024-11-04T07:33:57","guid":{"rendered":"https:\/\/itmax.cn\/?p=10020374"},"modified":"2024-11-04T15:33:57","modified_gmt":"2024-11-04T07:33:57","slug":"dubbo3-0-%e6%9c%8d%e5%8a%a1%e5%af%bc%e5%85%a5%e5%af%bc%e5%87%ba%e5%8e%9f%e7%90%86","status":"publish","type":"post","link":"https:\/\/itmax.cn\/?p=10020374","title":{"rendered":"dubbo3.0 \u670d\u52a1\u5bfc\u5165\u5bfc\u51fa\u539f\u7406"},"content":{"rendered":"<p>\u4f5c\u8005\uff1a\u4eac\u4e1c\u7269\u6d41 \u5f20\u58eb\u6b23<\/p>\n<p>\u4e0d\u7ba1\u662f\u670d\u52a1\u5bfc\u51fa\u8fd8\u662f\u670d\u52a1\u5f15\u5165\uff0c\u90fd\u53d1\u751f\u5728\u5e94\u7528\u542f\u52a8\u8fc7\u7a0b\u4e2d\uff0c\u6bd4\u5982\uff1a\u5728\u542f\u52a8\u7c7b\u4e0a\u52a0\u4e0a @EnableDubbo \u65f6\uff0c\u8be5\u6ce8\u89e3\u4e0a\u6709\u4e00\u4e2a @DubboComponentScan \u6ce8\u89e3\uff0c@DubboComponentScan \u6ce8\u89e3 Import \u4e86\u4e00\u4e2a DubboComponentScanRegistrar\uff0cDubboComponentScanRegistrar \u4e2d\u4f1a\u8c03\u7528 DubboSpringInitializer.initialize()\uff0c\u8be5\u65b9\u6cd5\u4e2d\u4f1a\u6ce8\u518c\u4e00\u4e2a DubboDeployApplicationListener\uff0c\u800c DubboDeployApplicationListener \u4f1a\u76d1\u542c Spring \u5bb9\u5668\u542f\u52a8\u5b8c\u6210\u4e8b\u4ef6 ContextRefreshedEvent\uff0c\u4e00\u65e6\u63a5\u6536\u5230\u8fd9\u4e2a\u4e8b\u4ef6\u540e\uff0c\u5c31\u4f1a\u5f00\u59cb Dubbo \u7684\u542f\u52a8\u6d41\u7a0b\uff0c\u5c31\u4f1a\u6267\u884c DefaultModuleDeployer \u7684 start() \u8fdb\u884c\u670d\u52a1\u5bfc\u51fa\u4e0e\u670d\u52a1\u5f15\u5165\u3002<\/p>\n<p><strong>\u5728\u542f\u52a8\u8fc7\u7a0b\u4e2d\uff0c\u5728\u505a\u5b8c\u670d\u52a1\u5bfc\u51fa\u4e0e\u670d\u52a1\u5f15\u5165\u540e\uff0c\u8fd8\u4f1a\u505a\u51e0\u4ef6\u975e\u5e38\u91cd\u8981\u7684\u4e8b\u60c5\uff1a<\/strong><\/p>\n<p>1.\u5bfc\u51fa\u4e00\u4e2a\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1\uff08\u5c31\u662f\u4e00\u4e2a MetadataService \u670d\u52a1\uff0c\u8fd9\u4e2a\u670d\u52a1\u4e5f\u4f1a\u6ce8\u518c\u5230\u6ce8\u518c\u4e2d\u5fc3\uff09\uff0c\u6216\u8005\u5c06\u5e94\u7528\u5143\u6570\u636e\u6ce8\u518c\u5230\u5143\u6570\u636e\u4e2d\u5fc3\uff1b<\/p>\n<p>2.\u751f\u6210\u5f53\u524d\u5e94\u7528\u7684\u5b9e\u4f8b\u4fe1\u606f\u5bf9\u8c61 ServiceInstance\uff0c\u6bd4\u5982\uff1a\u5e94\u7528\u540d\u3001\u5b9e\u4f8b ip\u3001\u5b9e\u4f8b port\uff0c\u5e76\u5c06\u5b9e\u4f8b\u4fe1\u606f\u6ce8\u518c\u5230\u6ce8\u518c\u4e2d\u5fc3\uff0c\u4e5f\u5c31\u662f\u5e94\u7528\u7ea7\u6ce8\u518c\uff1b<\/p>\n<h2>\u670d\u52a1\u5bfc\u51fa<\/h2>\n<p>\u5f53\u5728\u67d0\u4e2a\u63a5\u53e3\u7684\u5b9e\u73b0\u7c7b\u4e0a\u52a0\u4e0a @DubboService \u540e\uff0c\u5c31\u8868\u793a\u5b9a\u4e49\u4e86\u4e00\u4e2a Dubbo \u670d\u52a1\uff0c\u5e94\u7528\u542f\u52a8\u65f6 Dubbo \u53ea\u8981\u626b\u63cf\u5230\u4e86 @DubboService\uff0c\u5c31\u4f1a\u89e3\u6790\u5bf9\u5e94\u7684\u7c7b\uff0c\u5f97\u5230\u670d\u52a1\u76f8\u5173\u7684\u914d\u7f6e\u4fe1\u606f\uff0c\u6bd4\u5982\uff1a<\/p>\n<p>1.\u670d\u52a1\u7684\u7c7b\u578b\uff0c\u4e5f\u5c31\u662f\u63a5\u53e3\uff0c\u63a5\u53e3\u540d\u5c31\u662f\u670d\u52a1\u540d\uff1b<\/p>\n<p>2.\u670d\u52a1\u7684\u5177\u4f53\u5b9e\u73b0\u7c7b\uff0c\u4e5f\u5c31\u662f\u5f53\u524d\u7c7b\uff1b<\/p>\n<p>3.\u670d\u52a1\u7684 version\u3001timeout \u7b49\u4fe1\u606f\uff0c\u5c31\u662f @DubboService \u4e2d\u6240\u5b9a\u4e49\u7684\u5404\u79cd\u914d\u7f6e\uff1b<\/p>\n<p>\u89e3\u6790\u5b8c\u670d\u52a1\u7684\u914d\u7f6e\u4fe1\u606f\u540e\uff0c\u5c31\u4f1a\u628a\u8fd9\u4e9b\u914d\u7f6e\u4fe1\u606f\u5c01\u88c5\u6210\u4e3a\u4e00\u4e2a ServiceConfig \u5bf9\u8c61\uff0c\u5e76\u8c03\u7528\u5176 export() \u8fdb\u884c\u670d\u52a1\u5bfc\u51fa\uff0c\u6b64\u65f6\u4e00\u4e2a ServiceConfig \u5bf9\u8c61\u5c31\u8868\u793a\u4e00\u4e2aDubbo \u670d\u52a1\u3002<\/p>\n<p>\u800c\u6240\u8c13\u7684\u670d\u52a1\u5bfc\u51fa\uff0c\u4e3b\u8981\u5c31\u662f\u5b8c\u6210\u4e09\u4ef6\u4e8b\u60c5\uff1a<\/p>\n<p>1.\u786e\u5b9a\u670d\u52a1\u7684\u6700\u7ec8\u53c2\u6570\u914d\u7f6e\uff1b<\/p>\n<p>2.\u6309\u4e0d\u540c\u534f\u8bae\u542f\u52a8\u5bf9\u5e94\u7684 Server\uff08\u670d\u52a1\u66b4\u9732\uff09\uff1b<\/p>\n<p>3.\u5c06\u670d\u52a1\u6ce8\u518c\u5230\u6ce8\u518c\u4e2d\u5fc3\uff08\u670d\u52a1\u6ce8\u518c\uff09\uff1b<\/p>\n<h3>\u786e\u5b9a\u670d\u52a1\u53c2\u6570<\/h3>\n<p>\u4e00\u4e2a Dubbo \u670d\u52a1\uff0c\u9664\u5f00\u670d\u52a1\u7684\u540d\u5b57\uff0c\u4e5f\u5c31\u662f\u63a5\u53e3\u540d\uff0c\u8fd8\u4f1a\u6709\u5f88\u591a\u5176\u4ed6\u7684\u5c5e\u6027\uff0c\u6bd4\u5982\uff1a\u8d85\u65f6\u65f6\u95f4\u3001\u7248\u672c\u53f7\u3001\u670d\u52a1\u6240\u5c5e\u5e94\u7528\u540d\u3001\u6240\u652f\u6301\u7684\u534f\u8bae\u53ca\u7ed1\u5b9a\u7684\u7aef\u53e3\u7b49\u4f17\u591a\u4fe1\u606f\u3002<\/p>\n<p>\u4f46\u662f\uff0c\u901a\u5e38\u8fd9\u4e9b\u4fe1\u606f\u5e76\u4e0d\u4f1a\u5168\u90e8\u5728 @DubboService \u4e2d\u8fdb\u884c\u5b9a\u4e49\uff0c\u6bd4\u5982\uff1a\u4e00\u4e2a Dubbo \u670d\u52a1\u80af\u5b9a\u662f\u5c5e\u4e8e\u67d0\u4e2a\u5e94\u7528\u7684\uff0c\u800c\u4e00\u4e2a\u5e94\u7528\u4e0b\u53ef\u4ee5\u6709\u591a\u4e2a Dubbo \u670d\u52a1\uff0c\u6240\u4ee5\u53ef\u4ee5\u5728\u5e94\u7528\u7ea7\u522b\u5b9a\u4e49\u4e00\u4e9b\u901a\u7528\u7684\u914d\u7f6e\uff0c\u6bd4\u5982\u534f\u8bae\u3002<\/p>\n<p>\u5728 application.yml \u4e2d\u5b9a\u4e49\uff1a<\/p>\n<pre><code>dubbo:\n application:\n  name: dubbo-springboot-demo-provider\n protocol:\n  name: tri\n  port: 20880\n<\/code><\/pre>\n<p>\u8868\u793a\u5f53\u524d\u5e94\u7528\u4e0b\u6240\u6709\u7684 Dubbo \u670d\u52a1\u90fd\u652f\u6301\u901a\u8fc7 tri \u534f\u8bae\u8fdb\u884c\u8bbf\u95ee\uff0c\u5e76\u4e14\u8bbf\u95ee\u7aef\u53e3\u4e3a 20880\uff0c\u6240\u4ee5\u5728\u8fdb\u884c\u67d0\u4e2a\u670d\u52a1\u7684\u670d\u52a1\u5bfc\u51fa\u65f6\uff0c\u5c31\u9700\u8981\u5c06\u5e94\u7528\u4e2d\u7684\u8fd9\u4e9b\u914d\u7f6e\u4fe1\u606f\u5408\u5e76\u5230\u5f53\u524d\u670d\u52a1\u7684\u914d\u7f6e\u4fe1\u606f\u4e2d\u3002<\/p>\n<p>\u53e6\u5916\uff0c\u9664\u5f00\u53ef\u4ee5\u901a\u8fc7 @DubboService \u6765\u914d\u7f6e\u670d\u52a1\uff0c\u4e5f\u53ef\u4ee5\u5728\u914d\u7f6e\u4e2d\u5fc3\u5bf9\u670d\u52a1\u8fdb\u884c\u914d\u7f6e\uff0c\u6bd4\u5982\uff1a\u5728\u914d\u7f6e\u4e2d\u5fc3\u4e2d\u914d\u7f6e\uff1a<\/p>\n<p><code>dubbo.service.org.apache.dubbo.samples.api.DemoService.timeout=5000<\/code><\/p>\n<p>\u8868\u793a\u5f53\u524d\u670d\u52a1\u7684\u8d85\u65f6\u65f6\u95f4\u4e3a 5s\u3002<\/p>\n<p>\u6240\u4ee5\uff0c\u5728\u670d\u52a1\u5bfc\u51fa\u65f6\uff0c\u4e5f\u9700\u8981\u4ece\u914d\u7f6e\u4e2d\u5fc3\u83b7\u53d6\u5f53\u524d\u670d\u52a1\u7684\u914d\u7f6e\uff0c\u5982\u679c\u5728 @DubboService \u4e2d\u4e5f\u5b9a\u4e49\u4e86 timeout\uff0c\u90a3\u4e48\u5c31\u7528\u914d\u7f6e\u4e2d\u5fc3\u7684\u8986\u76d6\u6389\uff0c\u914d\u7f6e\u4e2d\u5fc3\u7684\u914d\u7f6e\u4f18\u5148\u7ea7\u66f4\u9ad8\u3002<\/p>\n<p>\u6700\u7ec8\u786e\u5b9a\u51fa\u670d\u52a1\u7684\u5404\u79cd\u53c2\u6570\uff0c\u8fd9\u5757\u5185\u5bb9\u548c Dubbo2.7 \u4e00\u81f4\u3002<\/p>\n<h2>\u670d\u52a1\u6ce8\u518c<\/h2>\n<p>\u5f53\u786e\u5b9a\u597d\u4e86\u6700\u7ec8\u7684\u670d\u52a1\u914d\u7f6e\u540e\uff0cDubbo \u5c31\u4f1a\u6839\u636e\u8fd9\u4e9b\u914d\u7f6e\u4fe1\u606f\u751f\u6210\u5bf9\u5e94\u7684\u670d\u52a1 URL\uff0c\u6bd4\u5982\uff1a<\/p>\n<p><code>tri:\/\/192.168.65.221:20880\/org.apache.dubbo.springboot.demo.DemoService?application=dubbo-springboot-demo-provider&amp;timeout=3000<\/code><\/p>\n<p>\u8fd9\u4e2a URL \u5c31\u8868\u793a\u4e86\u4e00\u4e2a Dubbo \u670d\u52a1\uff0c\u670d\u52a1\u6d88\u8d39\u8005\u53ea\u8981\u80fd\u83b7\u5f97\u5230\u8fd9\u4e2a\u670d\u52a1 URL\uff0c\u5c31\u77e5\u9053\u4e86\u5173\u4e8e\u8fd9\u4e2a Dubbo \u670d\u52a1\u7684\u5168\u90e8\u4fe1\u606f\uff0c\u5305\u62ec\u670d\u52a1\u540d\u3001\u652f\u6301\u7684\u534f\u8bae\u3001ip\u3001port\u3001\u5404\u79cd\u914d\u7f6e\u3002<\/p>\n<p>\u786e\u5b9a\u4e86\u670d\u52a1 URL \u4e4b\u540e\uff0c\u670d\u52a1\u6ce8\u518c\u8981\u505a\u7684\u4e8b\u60c5\u5c31\u662f\u628a\u8fd9\u4e2a\u670d\u52a1 URL \u5b58\u5230\u6ce8\u518c\u4e2d\u5fc3\uff08\u6bd4\u5982\uff1aZookeeper\uff09\u4e2d\u53bb\uff0c\u8bf4\u7684\u518d\u7b80\u5355\u4e00\u70b9\uff0c\u5c31\u662f\u628a\u8fd9\u4e2a\u5b57\u7b26\u4e32\u5b58\u5230 Zookeeper\u4e2d\u53bb\uff0c\u8fd9\u4e2a\u6b65\u9aa4\u5176\u5b9e\u662f\u975e\u5e38\u7b80\u5355\u7684\uff0c\u5b9e\u73b0\u8fd9\u4e2a\u529f\u80fd\u7684\u6e90\u7801\u5728 RegistryProtocol \u4e2d\u7684 export() \u65b9\u6cd5\u4e2d\uff0c\u6700\u7ec8\u670d\u52a1 URL \u5b58\u5728\u4e86 Zookeeper \u7684 \/dubbo\/ \u63a5\u53e3\u540d \/providers \u76ee\u5f55\u4e0b\u3002<\/p>\n<p>\u4f46\u662f\u670d\u52a1\u6ce8\u518c\u5e76\u4e0d\u4ec5\u4ec5\u5c31\u8fd9\u4e48\u7b80\u5355\uff0c\u65e2\u7136\u4e0a\u9762\u7684\u8fd9\u4e2a URL \u8868\u793a\u4e00\u4e2a\u670d\u52a1\uff0c\u5e76\u4e14\u8fd8\u5305\u62ec\u4e86\u670d\u52a1\u7684\u4e00\u4e9b\u914d\u7f6e\u4fe1\u606f\uff0c\u90a3\u8fd9\u4e9b\u914d\u7f6e\u4fe1\u606f\u5982\u679c\u6539\u53d8\u4e86\u5462\uff1f\u6bd4\u5982\uff1a\u5229\u7528 Dubbo\u7ba1\u7406\u53f0\u4e2d\u7684\u52a8\u6001\u914d\u7f6e\u529f\u80fd\uff08\u6ce8\u610f\uff0c\u5e76\u4e0d\u662f\u914d\u7f6e\u4e2d\u5fc3\uff09\u6765\u4fee\u6539\u670d\u52a1\u914d\u7f6e\uff0c\u52a8\u6001\u914d\u7f6e\u53ef\u4ee5\u5e94\u7528\u8fd0\u884c\u8fc7\u7a0b\u4e2d\u52a8\u6001\u7684\u4fee\u6539\u670d\u52a1\u7684\u914d\u7f6e\uff0c\u5e76\u5b9e\u65f6\u751f\u6548\u3002<\/p>\n<p>\u5982\u679c\u5229\u7528\u52a8\u6001\u914d\u7f6e\u529f\u80fd\u4fee\u6539\u4e86\u670d\u52a1\u7684\u53c2\u6570\uff0c\u90a3\u6b64\u65f6\u5c31\u8981\u91cd\u65b0\u751f\u6210\u670d\u52a1 URL \u5e76\u91cd\u65b0\u6ce8\u518c\u5230\u6ce8\u518c\u4e2d\u5fc3\uff0c\u8fd9\u6837\u670d\u52a1\u6d88\u8d39\u8005\u5c31\u80fd\u53ca\u65f6\u7684\u83b7\u53d6\u5230\u670d\u52a1\u914d\u7f6e\u4fe1\u606f\u3002<\/p>\n<p>\u800c\u5bf9\u4e8e\u670d\u52a1\u63d0\u4f9b\u8005\u800c\u8a00\uff0c\u5728\u670d\u52a1\u6ce8\u518c\u8fc7\u7a0b\u4e2d\uff0c\u8fd8\u9700\u8981\u80fd\u76d1\u542c\u5230\u52a8\u6001\u914d\u7f6e\u7684\u53d8\u5316\uff0c\u4e00\u65e6\u53d1\u751f\u4e86\u53d8\u5316\uff0c\u5c31\u6839\u636e\u6700\u65b0\u7684\u914d\u7f6e\u91cd\u65b0\u751f\u6210\u670d\u52a1 URL\uff0c\u5e76\u91cd\u65b0\u6ce8\u518c\u5230\u4e2d\u5fc3\u3002<\/p>\n<h2>\u5e94\u7528\u7ea7\u6ce8\u518c<\/h2>\n<p>\u5728 Dubbo3.0 \u4e4b\u524d\uff0cDubbo \u662f\u63a5\u53e3\u7ea7\u6ce8\u518c\uff0c\u670d\u52a1\u6ce8\u518c\u5c31\u662f\u628a\u63a5\u53e3\u540d\u4ee5\u53ca\u670d\u52a1\u914d\u7f6e\u4fe1\u606f\u6ce8\u518c\u5230\u6ce8\u518c\u4e2d\u5fc3\u4e2d\uff0c\u6ce8\u518c\u4e2d\u5fc3\u5b58\u50a8\u7684\u6570\u636e\u683c\u5f0f\u5927\u6982\u4e3a\uff1a<\/p>\n<pre><code>\u63a5\u53e3\u540d1\uff1atri:\/\/192.168.1.221:20880\/\u63a5\u53e3\u540d1?application=\u5e94\u7528\u540d\n\u63a5\u53e3\u540d2\uff1atri:\/\/192.168.1.221:20880\/\u63a5\u53e3\u540d2?application=\u5e94\u7528\u540d\n\u63a5\u53e3\u540d3\uff1atri:\/\/192.168.1.221:20880\/\u63a5\u53e3\u540d3?application=\u5e94\u7528\u540d\n<\/code><\/pre>\n<p>key \u662f\u63a5\u53e3\u540d\uff0cvalue \u5c31\u662f\u670d\u52a1 URL\uff0c\u4e0a\u9762\u7684\u5185\u5bb9\u5c31\u8868\u793a\u73b0\u5728\u6709\u4e00\u4e2a\u5e94\u7528\uff0c\u8be5\u5e94\u7528\u4e0b\u6709 3 \u4e2a\u63a5\u53e3\uff0c\u5e94\u7528\u5b9e\u4f8b\u90e8\u7f72\u5728 192.168.1.221\uff0c\u6b64\u65f6\uff0c\u5982\u679c\u7ed9\u8be5\u5e94\u7528\u589e\u52a0\u4e00\u4e2a\u5b9e\u4f8b\uff0c\u5b9e\u4f8b ip \u4e3a192.168.1.222\uff0c\u90a3\u4e48\u65b0\u7684\u5b9e\u4f8b\u4e5f\u9700\u8981\u8fdb\u884c\u670d\u52a1\u6ce8\u518c\uff0c\u4f1a\u5411\u6ce8\u518c\u4e2d\u5fc3\u65b0\u589e 3 \u6761\u6570\u636e\uff1a<\/p>\n<pre><code>\u63a5\u53e3\u540d1\uff1atri:\/\/192.168.1.221:20880\/\u63a5\u53e3\u540d1?application=\u5e94\u7528\u540d\n\u63a5\u53e3\u540d2\uff1atri:\/\/192.168.1.221:20880\/\u63a5\u53e3\u540d2?application=\u5e94\u7528\u540d\n\u63a5\u53e3\u540d3\uff1atri:\/\/192.168.1.221:20880\/\u63a5\u53e3\u540d3?application=\u5e94\u7528\u540d\n\n\u63a5\u53e3\u540d1\uff1atri:\/\/192.168.1.222:20880\/\u63a5\u53e3\u540d1?application=\u5e94\u7528\u540d\n\u63a5\u53e3\u540d2\uff1atri:\/\/192.168.1.222:20880\/\u63a5\u53e3\u540d2?application=\u5e94\u7528\u540d\n\u63a5\u53e3\u540d3\uff1atri:\/\/192.168.1.222:20880\/\u63a5\u53e3\u540d3?application=\u5e94\u7528\u540d\n<\/code><\/pre>\n<p>\u53ef\u4ee5\u53d1\u73b0\uff0c\u5982\u679c\u4e00\u4e2a\u5e94\u7528\u4e2d\u6709 3 \u4e2a Dubbo \u670d\u52a1\uff0c\u90a3\u4e48\u6bcf\u589e\u52a0\u4e00\u4e2a\u5b9e\u4f8b\uff0c\u5c31\u4f1a\u5411\u6ce8\u518c\u4e2d\u5fc3\u589e\u52a0 3 \u6761\u8bb0\u5f55\uff0c\u90a3\u5982\u679c\u4e00\u4e2a\u5e94\u7528\u4e2d\u6709 10 \u4e2a Dubbo \u670d\u52a1\uff0c\u90a3\u4e48\u6bcf\u589e\u52a0\u4e00\u4e2a\u5b9e\u4f8b\uff0c\u5c31\u4f1a\u5411\u6ce8\u518c\u4e2d\u5fc3\u589e\u52a0 10 \u6761\u8bb0\u5f55\uff0c\u6ce8\u518c\u4e2d\u5fc3\u7684\u538b\u529b\u4f1a\u968f\u7740\u5e94\u7528\u5b9e\u4f8b\u7684\u589e\u52a0\u800c\u5267\u70c8\u589e\u52a0\u3002<\/p>\n<p>\u53cd\u8fc7\u6765\uff0c\u5982\u679c\u4e00\u4e2a\u5e94\u7528\u6709 3 \u4e2a Dubbo \u670d\u52a1\uff0c5 \u4e2a\u5b9e\u4f8b\uff0c\u90a3\u4e48\u6ce8\u518c\u4e2d\u5fc3\u5c31\u6709 15 \u6761\u8bb0\u5f55\uff0c\u6b64\u65f6\u589e\u52a0\u4e00\u4e2a Dubbo \u670d\u52a1\uff0c\u90a3\u4e48\u6ce8\u518c\u4e2d\u5fc3\u5c31\u4f1a\u65b0\u589e 5 \u6761\u8bb0\u5f55\uff0c\u6ce8\u518c\u4e2d\u5fc3\u7684\u538b\u529b\u4e5f\u4f1a\u5267\u70c8\u589e\u52a0\u3002<\/p>\n<p>\u6ce8\u518c\u4e2d\u5fc3\u7684\u6570\u636e\u8d8a\u591a\uff0c\u6570\u636e\u5c31\u53d8\u5316\u7684\u8d8a\u9891\u7e41\uff0c\u6bd4\u5982\uff1a\u4fee\u6539\u670d\u52a1\u7684 timeout\uff0c\u90a3\u4e48\u5bf9\u4e8e\u6ce8\u518c\u4e2d\u5fc3\u548c\u5e94\u7528\u90fd\u9700\u8981\u6d88\u8017\u8d44\u6e90\u7528\u6765\u5904\u7406\u6570\u636e\u53d8\u5316\u3002<\/p>\n<p>\u6240\u4ee5\u4e3a\u4e86\u964d\u4f4e\u6ce8\u518c\u4e2d\u5fc3\u7684\u538b\u529b\uff0cDubbo3.0 \u652f\u6301\u4e86\u5e94\u7528\u7ea7\u6ce8\u518c\uff0c\u540c\u65f6\u4e5f\u517c\u5bb9\u63a5\u53e3\u7ea7\u6ce8\u518c\uff0c\u7528\u6237\u53ef\u4ee5\u9010\u6b65\u8fc1\u79fb\u6210\u5e94\u7528\u7ea7\u6ce8\u518c\uff0c\u800c\u4e00\u65e6\u91c7\u7528\u5e94\u7528\u7ea7\u6ce8\u518c\uff0c\u6700\u7ec8\u6ce8\u518c\u4e2d\u5fc3\u7684\u6570\u636e\u5b58\u50a8\u5c31\u53d8\u6210\u4e3a\uff1a<\/p>\n<pre><code>\u5e94\u7528\u540d\uff1a192.168.1.221:20880\n\u5e94\u7528\u540d\uff1a192.168.1.222:20880\n<\/code><\/pre>\n<p>\u8868\u793a\u5728\u6ce8\u518c\u4e2d\u5fc3\u4e2d\uff0c\u53ea\u8bb0\u5f55\u5e94\u7528\u6240\u5bf9\u5e94\u7684\u5b9e\u4f8b\u4fe1\u606f\uff08IP + \u7ed1\u5b9a\u7684\u7aef\u53e3\uff09\uff0c\u8fd9\u6837\u53ea\u6709\u4e00\u4e2a\u5e94\u7528\u7684\u5b9e\u4f8b\u589e\u52a0\u4e86\uff0c\u90a3\u4e48\u6ce8\u518c\u4e2d\u5fc3\u7684\u6570\u636e\u624d\u4f1a\u589e\u52a0\uff0c\u800c\u4e0d\u5173\u5fc3\u4e00\u4e2a\u5e94\u7528\u4e2d\u5230\u5e95\u6709\u591a\u5c11\u4e2a Dubbo \u670d\u52a1\u3002<\/p>\n<p>\u8fd9\u6837\u5e26\u6765\u7684\u597d\u5904\u5c31\u662f\uff0c\u6ce8\u518c\u4e2d\u5fc3\u5b58\u50a8\u7684\u6570\u636e\u53d8\u5c11\u4e86\uff0c\u6ce8\u518c\u4e2d\u5fc3\u4e2d\u6570\u636e\u7684\u53d8\u5316\u9891\u7387\u53d8\u5c0f\u4e86\uff0c\u5e76\u4e14\u4f7f\u7528\u5e94\u7528\u7ea7\u6ce8\u518c\uff0c\u4f7f\u5f97 Dubbo3 \u80fd\u5b9e\u73b0\u4e0e\u5f02\u6784\u5fae\u670d\u52a1\u4f53\u7cfb\u5982\uff1aSpring Cloud\u3001Kubernetes Service \u7b49\u5728\u5730\u5740\u53d1\u73b0\u5c42\u9762\u66f4\u5bb9\u6613\u4e92\u901a\uff0c \u4e3a\u8fde\u901a Dubbo \u4e0e\u5176\u4ed6\u5fae\u670d\u52a1\u4f53\u7cfb\u63d0\u4f9b\u53ef\u884c\u65b9\u6848\u3002<\/p>\n<p>\u5e94\u7528\u7ea7\u6ce8\u518c\u5e26\u6765\u4e86\u597d\u5904\uff0c\u4f46\u662f\u5bf9\u4e8e Dubbo \u6765\u8bf4\u53c8\u51fa\u73b0\u4e86\u4e00\u4e9b\u65b0\u7684\u95ee\u9898\uff0c\u6bd4\u5982\uff1a\u539f\u672c\uff0c\u670d\u52a1\u6d88\u8d39\u8005\u53ef\u4ee5\u76f4\u63a5\u4ece\u6ce8\u518c\u4e2d\u5fc3\u5c31\u77e5\u9053\u67d0\u4e2a Dubbo \u670d\u52a1\u7684\u6240\u6709\u670d\u52a1\u63d0\u4f9b\u8005\u4ee5\u53ca\u76f8\u5173\u7684\u534f\u8bae\u3001ip\u3001port\u3001\u914d\u7f6e\u7b49\u4fe1\u606f\uff0c\u90a3\u73b0\u5728\u6ce8\u518c\u4e2d\u5fc3\u4e0a\u53ea\u6709 ip\u3001port\uff0c\u90a3\u5bf9\u4e8e\u670d\u52a1\u6d88\u8d39\u8005\u800c\u8a00\uff1a\u670d\u52a1\u6d88\u8d39\u8005\u600e\u4e48\u77e5\u9053\u73b0\u5728\u5b83\u8981\u7528\u7684\u67d0\u4e2a Dubbo \u670d\u52a1\uff0c\u4e5f\u5c31\u662f\u67d0\u4e2a\u63a5\u53e3\u5bf9\u5e94\u7684\u5e94\u7528\u662f\u54ea\u4e2a\u5462\uff1f<\/p>\n<p>\u5bf9\u4e8e\u8fd9\u4e2a\u95ee\u9898\uff0c\u5728\u8fdb\u884c\u670d\u52a1\u5bfc\u51fa\u7684\u8fc7\u7a0b\u4e2d\uff0c\u4f1a\u5728 Zookeeper \u4e2d\u5b58\u4e00\u4e2a\u6620\u5c04\u5173\u7cfb\uff0c\u5728\u670d\u52a1\u5bfc\u51fa\u7684\u6700\u540e\u4e00\u6b65\uff0c\u5728 ServiceConfig \u7684 exported() \u65b9\u6cd5\u4e2d\uff0c\u4f1a\u4fdd\u5b58\u8fd9\u4e2a\u6620\u5c04\u5173\u7cfb\uff1a<code>\u63a5\u53e3\u540d\uff1a\u5e94\u7528\u540d<\/code>\u3002\u8fd9\u4e2a\u6620\u5c04\u5173\u7cfb\u5b58\u5728 Zookeeper \u7684 \/dubbo\/mapping \u76ee\u5f55\u4e0b\uff0c\u5b58\u4e86\u8fd9\u4e2a\u4fe1\u606f\u540e\uff0c\u6d88\u8d39\u8005\u5c31\u80fd\u6839\u636e\u63a5\u53e3\u540d\u627e\u5230\u6240\u5bf9\u5e94\u7684\u5e94\u7528\u540d\u4e86\u3002<\/p>\n<p>\u6d88\u8d39\u8005\u77e5\u9053\u4e86\u8981\u4f7f\u7528\u7684 Dubbo \u670d\u52a1\u5728\u54ea\u4e2a\u5e94\u7528\uff0c\u90a3\u4e5f\u5c31\u80fd\u4ece\u6ce8\u518c\u4e2d\u5fc3\u4e2d\u6839\u636e\u5e94\u7528\u540d\u67e5\u5230\u5e94\u7528\u7684\u6240\u6709\u5b9e\u4f8b\u4fe1\u606f\uff08 ip + port \uff09\uff0c\u4e5f\u5c31\u662f\u53ef\u4ee5\u53d1\u9001\u65b9\u6cd5\u8c03\u7528\u8bf7\u6c42\u4e86\uff0c\u4f46\u662f\u5728\u771f\u6b63\u53d1\u9001\u8bf7\u6c42\u4e4b\u524d\uff0c\u8fd8\u5f97\u77e5\u9053\u670d\u52a1\u7684\u914d\u7f6e\u4fe1\u606f\uff0c\u5bf9\u4e8e\u6d88\u8d39\u8005\u800c\u8a00\uff0c\u5b83\u5f97\u77e5\u9053\u5f53\u524d\u8981\u8c03\u7528\u7684\u8fd9\u4e2a Dubbo \u670d\u52a1\u652f\u6301\u4ec0\u4e48\u534f\u8bae\u3001timeout \u662f\u591a\u5c11\uff0c\u90a3\u670d\u52a1\u7684\u914d\u7f6e\u4fe1\u606f\u4ece\u54ea\u91cc\u83b7\u53d6\u5462\uff1f<\/p>\n<p>\u4e4b\u524d\u7684\u670d\u52a1\u914d\u7f6e\u4fe1\u606f\u662f\u76f4\u63a5\u4ece\u6ce8\u518c\u4e2d\u5fc3\u5c31\u53ef\u4ee5\u83b7\u53d6\u5230\u7684\uff0c\u5c31\u662f\u670d\u52a1 URL \u540e\u9762\uff0c\u4f46\u662f\u73b0\u5728\u4e0d\u884c\u4e86\uff0c\u73b0\u5728\u9700\u8981\u4ece\u670d\u52a1\u63d0\u4f9b\u8005\u7684\u5143\u6570\u636e\u670d\u52a1\u83b7\u53d6\uff0c\u524d\u9762\u63d0\u5230\u8fc7\uff0c\u5728\u5e94\u7528\u542f\u52a8\u8fc7\u7a0b\u4e2d\u4f1a\u8fdb\u884c\u670d\u52a1\u5bfc\u51fa\u548c\u670d\u52a1\u5f15\u5165\uff0c\u7136\u540e\u5c31\u4f1a\u66b4\u9732\u4e00\u4e2a\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1\uff0c\u5176\u5b9e\u8fd9\u4e2a\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1\u5c31\u662f\u4e00\u4e2a Dubbo \u670d\u52a1\uff08Dubbo \u6846\u67b6\u5185\u7f6e\u7684\uff0c\u81ea\u5df1\u5b9e\u73b0\u7684 \uff09\uff0c\u6d88\u8d39\u8005\u53ef\u4ee5\u8c03\u7528\u8fd9\u4e2a\u670d\u52a1\u6765\u83b7\u53d6\u67d0\u4e2a\u5e94\u7528\u4e2d\u6240\u63d0\u4f9b\u7684\u6240\u6709 Dubbo \u670d\u52a1\u4ee5\u53ca\u670d\u52a1\u914d\u7f6e\u4fe1\u606f\uff0c\u8fd9\u6837\u4e5f\u5c31\u80fd\u77e5\u9053\u670d\u52a1\u7684\u914d\u7f6e\u4fe1\u606f\u4e86\u3002<\/p>\n<p>\u77e5\u9053\u4e86\u5e94\u7528\u6ce8\u518c\u7684\u597d\u5904\uff0c\u4ee5\u53ca\u76f8\u5173\u95ee\u9898\u7684\u89e3\u51b3\u65b9\u5f0f\uff0c\u90a3\u4e48\u6765\u770b\u5b83\u5230\u5e95\u662f\u5982\u4f55\u5b9e\u73b0\u7684\u3002<\/p>\n<p>\u9996\u5148\uff0c\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u914d\u7f6e dubbo.application.register-mode \u6765\u63a7\u5236\uff1a<\/p>\n<p>1.instance\uff1a\u8868\u793a\u53ea\u8fdb\u884c\u5e94\u7528\u7ea7\u6ce8\u518c\uff1b<\/p>\n<p>2.interface\uff1a\u8868\u793a\u53ea\u8fdb\u884c\u63a5\u53e3\u7ea7\u6ce8\u518c\uff1b<\/p>\n<p>3.all\uff1a\u8868\u793a\u5e94\u7528\u7ea7\u6ce8\u518c\u548c\u63a5\u53e3\u7ea7\u6ce8\u518c\u90fd\u8fdb\u884c\uff0c\u9ed8\u8ba4\uff1b<\/p>\n<p>\u4e0d\u7ba1\u662f\u4ec0\u4e48\u6ce8\u518c\uff0c\u90fd\u9700\u8981\u5b58\u6570\u636e\u5230\u6ce8\u518c\u4e2d\u5fc3\uff0c\u800c Dubbo3 \u7684\u6e90\u7801\u5b9e\u73b0\u4e2d\u4f1a\u6839\u636e\u6240\u914d\u7f6e\u7684\u6ce8\u518c\u4e2d\u5fc3\u751f\u6210\u4e24\u4e2a URL\uff08\u4e0d\u662f\u670d\u52a1 URL\uff0c\u53ef\u4ee5\u7406\u89e3\u4e3a\u6ce8\u518c\u4e2d\u5fc3 URL\uff0c\u7528\u6765\u8bbf\u95ee\u6ce8\u518c\u4e2d\u5fc3\u7684\uff09:<\/p>\n<p>1.service-discovery-registry:\/\/127.0.0.1:2181\/org.apache.dubbo.registry.RegistryService?application=dubbospringboot-demoprovider&#038; dubbo=2.0.2\/&amp;pid=13072\/&amp;qos.enable=false\u00aeistry=zookeeper\u00d7tamp=1651755501660<\/p>\n<p>2.registry:\/\/127.0.0.1:2181\/org.apache.dubbo.registry.RegistryService?application=dubbo-springboot-demoprovider&#038; dubbo=2.0.2\/&amp;pid=13072\/&amp;qos.enable=false\u00aeistry=zookeeper\u00d7tamp=1651755501660<\/p>\n<p>\u8fd9\u4e24\u4e2a URL \u53ea\u6709 schema \u4e0d\u4e00\u6837\uff0c\u4e00\u4e2a\u662f service-discovery-registry\uff0c\u4e00\u4e2a\u662f registry\uff0c\u800c registry \u662f Dubbo3 \u4e4b\u524d\u5c31\u5b58\u5728\u7684\uff0c\u4e5f\u5c31\u4ee3\u8868\u63a5\u53e3\u7ea7\u670d\u52a1\u6ce8\u518c\uff0c\u800cservice-discovery-registry \u5c31\u8868\u793a\u5e94\u7528\u7ea7\u670d\u52a1\u6ce8\u518c\u3002<\/p>\n<p>\u5728\u670d\u52a1\u6ce8\u518c\u76f8\u5173\u7684\u6e90\u7801\u4e2d\uff0c\u5f53\u8c03\u7528 RegistryProtocol \u7684 export() \u65b9\u6cd5\u5904\u7406 registry:\/\/ \u65f6\uff0c\u4f1a\u5229\u7528 ZookeeperRegistry \u628a\u670d\u52a1 URL \u6ce8\u518c\u5230 Zookeeper \u4e2d\u53bb\uff0c\u8fd9\u5c31\u662f\u63a5\u53e3\u7ea7\u6ce8\u518c\u3002<\/p>\n<p>\u800c\u7c7b\u4f3c\uff0c\u5f53\u8c03\u7528 RegistryProtocol \u7684 export() \u65b9\u6cd5\u5904\u7406 service-discovery-registry:\/\/ \u65f6\uff0c\u4f1a\u5229\u7528 ServiceDiscoveryRegistry \u6765\u8fdb\u884c\u76f8\u5173\u903b\u8f91\u7684\u5904\u7406\uff0c\u90a3\u662f\u4e0d\u662f\u5c31\u662f\u5728\u8fd9\u91cc\u628a\u5e94\u7528\u4fe1\u606f\u6ce8\u518c\u5230\u6ce8\u518c\u4e2d\u5fc3\u53bb\u5462\uff1f\u5e76\u6ca1\u6709\u8fd9\u4e48\u7b80\u5355\u3002<\/p>\n<p>1.\u9996\u5148\uff0c\u4e0d\u53ef\u80fd\u6bcf\u5bfc\u51fa\u4e00\u4e2a\u670d\u52a1\u5c31\u8fdb\u884c\u4e00\u6b21\u5e94\u7528\u6ce8\u518c\uff0c\u592a\u6d6a\u8d39\u4e86\uff0c\u5e94\u7528\u6ce8\u518c\u53ea\u8981\u505a\u4e00\u6b21\u5c31\u884c\u4e86<\/p>\n<p>2.\u5176\u6b21\uff0c\u5982\u679c\u4e00\u4e2a\u5e94\u7528\u652f\u6301\u4e86\u591a\u4e2a\u7aef\u53e3\uff0c\u90a3\u4e48\u5e94\u7528\u6ce8\u518c\u65f6\u53ea\u8981\u6311\u9009\u5176\u4e2d\u4e00\u4e2a\u7aef\u53e3\u4f5c\u4e3a\u5b9e\u4f8b\u7aef\u53e3\u5c31\u53ef\u4ee5\u4e86\uff08\u8be5\u7aef\u53e3\u53ea\u8981\u80fd\u63a5\u6536\u5230\u6570\u636e\u5c31\u884c\uff09<\/p>\n<p>3.\u524d\u9762\u63d0\u5230\uff0c\u5e94\u7528\u542f\u52a8\u8fc7\u7a0b\u4e2d\u8981\u66b4\u9732\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1\uff0c\u6240\u4ee5\u5728\u6b64\u5904\u4e5f\u8fd8\u662f\u8981\u6536\u96c6\u5f53\u524d\u6240\u66b4\u9732\u7684\u670d\u52a1\u914d\u7f6e\u4fe1\u606f\uff0c\u4ee5\u63d0\u4f9b\u7ed9\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1<\/p>\n<p>\u6240\u4ee5 ServiceDiscoveryRegistry \u5728\u6ce8\u518c\u4e00\u4e2a\u670d\u52a1 URL \u65f6\uff0c\u5e76\u4e0d\u4f1a\u5f80\u6ce8\u518c\u4e2d\u5fc3\u5b58\u6570\u636e\uff0c\u800c\u53ea\u662f\u628a\u670d\u52a1 URL \u5b58\u5230\u5230\u4e00\u4e2a MetadataInfo \u5bf9\u8c61\u4e2d\uff0cMetadataInfo \u5bf9\u8c61\u4e2d\u5c31\u4fdd\u5b58\u4e86\u5f53\u524d\u5e94\u7528\u4e2d\u6240\u6709\u7684 Dubbo \u670d\u52a1\u4fe1\u606f\uff1a\u670d\u52a1\u540d\u3001\u652f\u6301\u7684\u534f\u8bae\u3001\u7ed1\u5b9a\u7684\u7aef\u53e3\u3001timeout \u7b49\u3002<\/p>\n<p>\u524d\u9762\u63d0\u5230\u8fc7\uff0c\u5728\u5e94\u7528\u542f\u52a8\u7684\u6700\u540e\uff0c\u624d\u4f1a\u8fdb\u884c\u5e94\u7528\u7ea7\u6ce8\u518c\uff0c\u800c\u5e94\u7528\u7ea7\u6ce8\u518c\u5c31\u662f\u5f53\u524d\u7684\u5e94\u7528\u5b9e\u4f8b\u4e0a\u76f8\u5173\u7684\u4fe1\u606f\u5b58\u5165\u6ce8\u518c\u4e2d\u5fc3\uff0c\u5305\u62ec\uff1a<\/p>\n<p>1.\u5e94\u7528\u7684\u540d\u5b57\uff1b<\/p>\n<p>2.\u83b7\u53d6\u5e94\u7528\u5143\u6570\u636e\u7684\u65b9\u5f0f\uff1b<\/p>\n<p>3.\u5f53\u524d\u5b9e\u4f8b\u7684 ip \u548c port\uff1b<\/p>\n<p>4.\u5f53\u524d\u5b9e\u4f8b\u652f\u6301\u54ea\u4e9b\u534f\u8bae\u4ee5\u53ca\u5bf9\u5e94\u7684 port\uff1b<\/p>\n<p>\u6bd4\u5982\uff1a<\/p>\n<pre><code>{\n  &quot;name&quot;:&quot;dubbo-springboot-demo-provider&quot;,\n  &quot;id&quot;:&quot;192.168.65.221:20882&quot;,\n  &quot;address&quot;:&quot;192.168.65.221&quot;,\n  &quot;port&quot;:20882,\n  &quot;sslPort&quot;:null,\n  &quot;payload&quot;:{\n    &quot;@class&quot;:&quot;org.apache.dubbo.registry.zookeeper.ZookeeperInstance&quot;,\n    &quot;id&quot;:&quot;192.168.65.221:20882&quot;,\n    &quot;name&quot;:&quot;dubbo-springboot-demo-provider&quot;,\n    &quot;metadata&quot;:{\n      &quot;dubbo.endpoints&quot;:&quot;[{&quot;port&quot;:20882,&quot;protocol&quot;:&quot;dubbo&quot;},{&quot;port&quot;:50051,&quot;protocol&quot;:&quot;tri&quot;}]&quot;,\n      &quot;dubbo.metadata-service.url-params&quot;:&quot;{&quot;connections&quot;:&quot;1&quot;,&quot;version&quot;:&quot;1.0.0&quot;,&quot;dubbo&quot;:&quot;2.0.2&quot;,&quot;side&quot;:&quot;provider&quot;,&quot;port&quot;:&quot;20882&quot;,&quot;protocol&quot;:&quot;dubbo&quot;}&quot;,\n      &quot;dubbo.metadata.revision&quot;:&quot;65d5c7b814616ab10d32860b54781686&quot;,\n      &quot;dubbo.metadata.storage-type&quot;:&quot;local&quot;\n    } \n  },\n  &quot;registrationTimeUTC&quot;:1654585977352,\n  &quot;serviceType&quot;:&quot;DYNAMIC&quot;,\n  &quot;uriSpec&quot;:null\n}\n<\/code><\/pre>\n<p>\u4e00\u4e2a\u5b9e\u4f8b\u4e0a\u53ef\u80fd\u652f\u6301\u591a\u4e2a\u534f\u8bae\u4ee5\u53ca\u591a\u4e2a\u7aef\u53e3\uff0c\u90a3\u5982\u4f55\u786e\u5b9a\u5b9e\u4f8b\u7684 ip \u548c\u7aef\u53e3\u5462\uff1f<\/p>\n<p>\u7b54\u6848\u662f\uff1a\u83b7\u53d6 MetadataInfo \u5bf9\u8c61\u4e2d\u4fdd\u5b58\u7684\u6240\u6709\u670d\u52a1 URL\uff0c\u4f18\u5148\u53d6 dubbo \u534f\u8bae\u5bf9\u5e94 ip \u548c port\uff0c\u6ca1\u6709 dubbo \u534f\u8bae\u5219\u6240\u6709\u670d\u52a1 URL \u4e2d\u7684\u7b2c\u4e00\u4e2a URL \u7684 ip \u548c port\u3002<\/p>\n<p>\u53e6\u5916\u4e00\u4e2a\u534f\u8bae\u4e00\u822c\u53ea\u4f1a\u5bf9\u5e94\u4e00\u4e2a\u7aef\u53e3\uff0c\u4f46\u662f\u5982\u4f55\u5c31\u662f\u5bf9\u5e94\u4e86\u591a\u4e2a\uff0c\u6bd4\u5982\uff1a<\/p>\n<pre><code>dubbo:\n  application:\n    name: dubbo-springboot-demo-provider\n  protocols:\n    p1:\n      name: dubbo\n      port: 20881\n    p2:\n      name: dubbo\n      port: 20882\n    p3:\n      name: tri\n      port: 50051\n<\/code><\/pre>\n<p>\u5982\u679c\u662f\u8fd9\u6837\uff0c\u6700\u7ec8\u5b58\u5165 endpoint \u4e2d\u7684\u4f1a\u4fdd\u8bc1\u4e00\u4e2a\u534f\u8bae\u53ea\u5bf9\u5e94\u4e00\u4e2a\u7aef\u53e3\uff0c\u53e6\u5916\u90a3\u4e2a\u5c06\u88ab\u5ffd\u7565\uff0c\u6700\u7ec8\u670d\u52a1\u6d88\u8d39\u8005\u5728\u8fdb\u884c\u670d\u52a1\u5f15\u5165\u65f6\u5c06\u4f1a\u7528\u5230\u8fd9\u4e2a endpoint \u4fe1\u606f\u3002<\/p>\n<p>\u786e\u5b9a\u597d\u5b9e\u4f8b\u4fe1\u606f\u540e\u4e4b\u540e\uff0c\u5c31\u8fdb\u884c\u6700\u7ec8\u7684\u5e94\u7528\u6ce8\u518c\u4e86\uff0c\u5c31\u628a\u5b9e\u4f8b\u4fe1\u606f\u5b58\u5165\u6ce8\u518c\u4e2d\u5fc3\u7684 \/services\/\u5e94\u7528\u540d\uff0c\u76ee\u5f55\u4e0b\uff1a<\/p>\n<\/p>\n<p><img decoding=\"async\"   referrerpolicy=\"no-referrer\" src=\"https:\/\/i-blog.csdnimg.cn\/direct\/5cb5aa0c768a4e97abb35f42ff0832cd.webp\" alt=\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" title=\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"><\/p>\n<\/p>\n<p>\u53ef\u4ee5\u770b\u51fa services \u8282\u70b9\u4e0b\u5b58\u7684\u662f\u5e94\u7528\u540d\uff0c\u5e94\u7528\u540d\u7684\u8282\u70b9\u4e0b\u5b58\u7684\u662f\u5b9e\u4f8b ip \u548c\u5b9e\u4f8b port\uff0c\u800c ip \u548c port \u8fd9\u4e2a\u8282\u70b9\u4e2d\u7684\u5185\u5bb9\u5c31\u662f\u5b9e\u4f8b\u7684\u4e00\u4e9b\u57fa\u672c\u4fe1\u606f\u3002<\/p>\n<p>\u989d\u5916\uff0c\u6211\u4eec\u53ef\u4ee5\u914d\u7f6e dubbo.metadata.storage-type\uff0c\u9ed8\u8ba4\u65f6 local\uff0c\u53ef\u4ee5\u901a\u8fc7\u914d\u7f6e\u6539\u4e3a remote\uff1a<\/p>\n<pre><code>dubbo:\n    application:\n        name: dubbo-springboot-demo-provider\n        metadata-type: remote\n<\/code><\/pre>\n<p>\u8fd9\u4e2a\u914d\u7f6e\u5176\u5b9e\u8ddf\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1\u6709\u5173\u7cfb\uff1a<\/p>\n<p>1.\u5982\u679c\u4e3a local\uff0c\u90a3\u5c31\u4f1a\u542f\u7528\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1\uff0c\u6700\u7ec8\u670d\u52a1\u6d88\u8d39\u8005\u5c31\u4f1a\u8c03\u7528\u5143\u6570\u636e\u670d\u52a1\u83b7\u53d6\u5230\u5e94\u7528\u5143\u6570\u636e\u4fe1\u606f\uff1b<\/p>\n<p>2.\u5982\u679c\u4e3a remote\uff0c\u90a3\u5c31\u4e0d\u4f1a\u66b4\u9732\u5e94\u7528\u5143\u6570\u636e\u670d\u52a1\uff0c\u90a3\u4e48\u670d\u52a1\u6d88\u8d39\u8005\u4ece\u5143\u6570\u636e\u4e2d\u5fc3\u83b7\u53d6\u5e94\u7528\u5143\u6570\u636e\uff1b<\/p>\n<p>\u5728 Dubbo2.7 \u4e2d\u5c31\u6709\u4e86\u5143\u6570\u636e\u4e2d\u5fc3\uff0c\u5b83\u5176\u5b9e\u5c31\u662f\u7528\u6765\u51cf\u8f7b\u6ce8\u518c\u4e2d\u5fc3\u7684\u538b\u529b\u7684\uff0cDubbo \u4f1a\u628a\u670d\u52a1\u4fe1\u606f\u5b8c\u6574\u7684\u5b58\u4e00\u4efd\u5230\u5143\u6570\u636e\u4e2d\u5fc3\uff0c\u5143\u6570\u636e\u4e2d\u5fc3\u4e5f\u53ef\u4ee5\u7528 Zookeeper\u6765\u5b9e\u73b0\uff0c\u5728\u66b4\u9732\u5b8c\u5143\u6570\u636e\u670d\u52a1\u4e4b\u540e\uff0c\u5728\u6ce8\u518c\u5b9e\u4f8b\u4fe1\u606f\u5230\u6ce8\u518c\u4e2d\u5fc3\u4e4b\u524d\uff0c\u5c31\u4f1a\u628a MetadataInfo \u5b58\u5165\u5143\u6570\u636e\u4e2d\u5fc3\uff0c\u6bd4\u5982\uff1a<\/p>\n<\/p>\n<p><img decoding=\"async\"   referrerpolicy=\"no-referrer\" src=\"https:\/\/i-blog.csdnimg.cn\/direct\/326f9d7a51ce4fba89e8dedb399f4388.webp\" alt=\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" title=\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" loading=\"lazy\"><\/p>\n<\/p>\n<p>\u8282\u70b9\u5185\u5bb9\u4e3a\uff1a<\/p>\n<pre><code>{\n    &quot;app&quot;:&quot;dubbo-springboot-demo-provider&quot;,\n    &quot;revision&quot;:&quot;64e68950e300068e6b5f8632d9fd141d&quot;,\n    &quot;services&quot;:{\n        &quot;org.apache.dubbo.springboot.demo.HelloService:tri&quot;:{\n            &quot;name&quot;:&quot;org.apache.dubbo.springboot.demo.HelloService&quot;,\n            &quot;protocol&quot;:&quot;tri&quot;,\n            &quot;path&quot;:&quot;org.apache.dubbo.springboot.demo.HelloService&quot;,\n            &quot;params&quot;:{\n                &quot;side&quot;:&quot;provider&quot;,\n                &quot;release&quot;:&quot;&quot;,\n                &quot;methods&quot;:&quot;sayHello&quot;,\n                &quot;deprecated&quot;:&quot;false&quot;,\n                &quot;dubbo&quot;:&quot;2.0.2&quot;,\n                &quot;interface&quot;:&quot;org.apache.dubbo.springboot.demo.HelloService&quot;,\n                &quot;service-name-mapping&quot;:&quot;true&quot;,\n                &quot;generic&quot;:&quot;false&quot;,\n                &quot;metadata-type&quot;:&quot;remote&quot;,\n                &quot;application&quot;:&quot;dubbo-springboot-demo-provider&quot;,\n                &quot;background&quot;:&quot;false&quot;,\n                &quot;dynamic&quot;:&quot;true&quot;,\n                &quot;anyhost&quot;:&quot;true&quot;\n            }\n        },\n        &quot;org.apache.dubbo.springboot.demo.DemoService:tri&quot;:{\n            &quot;name&quot;:&quot;org.apache.dubbo.springboot.demo.DemoService&quot;,\n            &quot;protocol&quot;:&quot;tri&quot;,\n            &quot;path&quot;:&quot;org.apache.dubbo.springboot.demo.DemoService&quot;,\n            &quot;params&quot;:{\n                &quot;side&quot;:&quot;provider&quot;,\n                &quot;release&quot;:&quot;&quot;,\n                &quot;methods&quot;:&quot;sayHelloStream,sayHello,sayHelloServerStream&quot;,\n                &quot;deprecated&quot;:&quot;false&quot;,\n                &quot;dubbo&quot;:&quot;2.0.2&quot;,\n                &quot;interface&quot;:&quot;org.apache.dubbo.springboot.demo.DemoService&quot;,\n                &quot;service-name-mapping&quot;:&quot;true&quot;,\n                &quot;generic&quot;:&quot;false&quot;,\n                &quot;metadata-type&quot;:&quot;remote&quot;,\n                &quot;application&quot;:&quot;dubbo-springboot-demo-provider&quot;,\n                &quot;background&quot;:&quot;false&quot;,\n                &quot;dynamic&quot;:&quot;true&quot;,\n                &quot;anyhost&quot;:&quot;true&quot;\n            }\n        }\n    }\n}\n<\/code><\/pre>\n<p>\u8fd9\u91cc\u9762\u5c31\u8bb0\u5f55\u4e86\u5f53\u524d\u5b9e\u4f8b\u4e0a\u63d0\u4f9b\u4e86\u54ea\u4e9b\u670d\u52a1\u4ee5\u53ca\u5bf9\u5e94\u7684\u534f\u8bae\uff0c\u6ce8\u610f\u5e76\u6ca1\u6709\u4fdd\u5b58\u5bf9\u5e94\u7684\u7aef\u53e3&#8230;&#8230;\uff0c\u6240\u4ee5\u540e\u9762\u670d\u52a1\u6d88\u8d39\u8005\u5f97\u5229\u7528\u5b9e\u4f8b\u4fe1\u606f\u4e2d\u7684 endpoint\uff0c\u56e0\u4e3aendpoint \u4e2d\u8bb0\u5f55\u4e86\u534f\u8bae\u5bf9\u5e94\u7684\u7aef\u53e3&#8230;.<\/p>\n<p>\u5176\u5b9e\u5143\u6570\u636e\u4e2d\u5fc3\u548c\u5143\u6570\u636e\u670d\u52a1\u63d0\u4f9b\u7684\u529f\u80fd\u662f\u4e00\u6837\u7684\uff0c\u90fd\u53ef\u4ee5\u7528\u6765\u83b7\u53d6\u67d0\u4e2a\u5b9e\u4f8b\u7684 MetadataInfo\uff0c\u4e0a\u9762\u4e2d\u7684 UUID \u8868\u793a\u5b9e\u4f8b\u7f16\u53f7\uff0c\u53ea\u4e0d\u8fc7\u5143\u6570\u636e\u4e2d\u5fc3\u662f\u96c6\u4e2d\u5f0f\u7684\uff0c\u5143\u6570\u636e\u670d\u52a1\u5f0f\u5206\u6563\u5728\u5404\u4e2a\u63d0\u4f9b\u8005\u5b9e\u4f8b\u4e2d\u7684\uff0c\u5982\u679c\u6574\u4e2a\u5fae\u670d\u52a1\u96c6\u7fa4\u538b\u529b\u4e0d\u5927\uff0c\u90a3\u4e48\u6548\u679c\u5dee\u4e0d\u591a\uff0c\u5982\u679c\u5fae\u670d\u52a1\u96c6\u7fa4\u538b\u529b\u5927\uff0c\u90a3\u4e48\u5143\u6570\u636e\u4e2d\u5fc3\u7684\u538b\u529b\u5c31\u5927\uff0c\u6b64\u65f6\u5355\u4e2a\u5143\u6570\u636e\u670d\u52a1\u5c31\u66f4\u9002\u5408\uff0c\u6240\u4ee5\u9ed8\u8ba4\u4e5f\u662f\u91c7\u7528\u7684\u5143\u6570\u636e\u670d\u52a1\u3002<\/p>\n<p>\u81f3\u6b64\uff0c\u5e94\u7528\u7ea7\u670d\u52a1\u6ce8\u518c\u7684\u539f\u7406\u5c31\u5206\u6790\u5b8c\u4e86\uff0c\u603b\u7ed3\u4e00\u4e0b\uff1a<\/p>\n<p>1.\u5728\u5bfc\u51fa\u67d0\u4e2a Dubbo \u670d\u52a1 URL \u65f6\uff0c\u4f1a\u628a\u670d\u52a1 URL \u5b58\u5165 MetadataInfo \u4e2d\uff1b<\/p>\n<p>2.\u5bfc\u51fa\u5b8c\u67d0\u4e2a Dubbo \u670d\u52a1\u540e\uff0c\u5c31\u4f1a\u628a\u670d\u52a1\u63a5\u53e3\u540d:\u5e94\u7528\u540d\u5b58\u5165\u5143\u6570\u636e\u4e2d\u5fc3\uff08\u53ef\u4ee5\u7528 Zookeeper \u5b9e\u73b0\uff09\uff1b<\/p>\n<p>3.\u5bfc\u51fa\u6240\u6709\u670d\u52a1\u540e\uff0c\u5b8c\u6210\u670d\u52a1\u5f15\u5165\u540e\uff1b<\/p>\n<p>4.\u5224\u65ad\u8981\u4e0d\u8981\u542f\u52a8\u5143\u6570\u636e\u670d\u52a1\uff0c\u5982\u679c\u8981\u5c31\u8fdb\u884c\u5bfc\u51fa\uff0c\u56fa\u5b9a\u4f7f\u7528 Dubbo \u534f\u8bae\uff1b<\/p>\n<p>5.\u5c06 MetadataInfo \u5b58\u5165\u5143\u6570\u636e\u4e2d\u5fc3\uff1b<\/p>\n<p>6.\u786e\u5b9a\u5f53\u524d\u5b9e\u4f8b\u4fe1\u606f\uff08\u5e94\u7528\u540d\u3001ip\u3001port\u3001endpoint\uff09\uff1b<\/p>\n<p>7.\u5c06\u5b9e\u4f8b\u4fe1\u606f\u5b58\u5165\u6ce8\u518c\u4e2d\u5fc3\uff0c\u5b8c\u6210\u5e94\u7528\u6ce8\u518c\uff1b<\/p>\n<h2>\u670d\u52a1\u66b4\u9732<\/h2>\n<p>\u670d\u52a1\u66b4\u9732\u5c31\u662f\u6839\u636e\u4e0d\u540c\u7684\u534f\u8bae\u542f\u52a8\u4e0d\u540c\u7684 Server\uff0c\u6bd4\u5982\uff1adubbo \u548c tri \u534f\u8bae\u542f\u52a8\u7684\u90fd\u662f Netty\uff0c\u50cf Dubbo2.7 \u4e2d\u7684 http \u534f\u8bae\u542f\u52a8\u7684\u5c31\u662f Tomcat\uff0c\u8fd9\u5757\u5728\u670d\u52a1\u8c03\u7528\u7684\u65f6\u5019\u518d\u6765\u5206\u6790\u3002<\/p>\n<h2>\u670d\u52a1\u5f15\u5165<\/h2>\n<pre><code>@DubboReference\nprivate DemoService demoService;\n<\/code><\/pre>\n<p>\u9700\u8981\u5229\u7528 @DubboReference \u6ce8\u89e3\u6765\u5f15\u5165\u67d0\u4e00\u4e2a Dubbo \u670d\u52a1\uff0c\u5e94\u7528\u5728\u542f\u52a8\u8fc7\u7a0b\u4e2d\uff0c\u8fdb\u884c\u5b8c\u670d\u52a1\u5bfc\u51fa\u4e4b\u540e\uff0c\u5c31\u4f1a\u8fdb\u884c\u670d\u52a1\u5f15\u5165\uff0c\u5c5e\u6027\u7684\u7c7b\u578b\u5c31\u662f\u4e00\u4e2a Dubbo \u670d\u52a1\u63a5\u53e3\uff0c\u800c\u670d\u52a1\u5f15\u5165\u6700\u7ec8\u8981\u505a\u5230\u7684\u5c31\u662f\u7ed9\u8fd9\u4e2a\u5c5e\u6027\u8d4b\u503c\u4e00\u4e2a\u63a5\u53e3\u4ee3\u7406\u5bf9\u8c61\u3002<\/p>\n<p>\u5728 Dubbo2.7 \u4e2d\uff0c\u53ea\u6709\u63a5\u53e3\u7ea7\u670d\u52a1\u6ce8\u518c\uff0c\u670d\u52a1\u6d88\u8d39\u8005\u4f1a\u5229\u7528\u63a5\u53e3\u540d\u4ece\u6ce8\u518c\u4e2d\u5fc3\u627e\u5230\u8be5\u670d\u52a1\u63a5\u53e3\u6240\u6709\u7684\u670d\u52a1 URL\uff0c\u670d\u52a1\u6d88\u8d39\u8005\u4f1a\u6839\u636e\u6bcf\u4e2a\u670d\u52a1 URL \u7684 protocol\u3001ip\u3001port \u751f\u6210\u5bf9\u5e94\u7684 Invoker \u5bf9\u8c61\uff0c\u6bd4\u5982\u751f\u6210 TripleInvoker\u3001DubboInvoker \u7b49\uff0c\u8c03\u7528\u8fd9\u4e9b Invoker \u7684 invoke() \u65b9\u6cd5\u5c31\u4f1a\u53d1\u9001\u6570\u636e\u5230\u5bf9\u5e94\u7684 ip\u3001port\uff0c\u751f\u6210\u597d\u6240\u6709\u7684 Invoker \u5bf9\u8c61\u4e4b\u540e\uff0c\u5c31\u4f1a\u628a\u8fd9\u4e9b Invoker \u5bf9\u8c61\u8fdb\u884c\u5c01\u88c5\u5e76\u751f\u6210\u4e00\u4e2a\u670d\u52a1\u63a5\u53e3\u7684\u4ee3\u7406\u5bf9\u8c61\uff0c\u4ee3\u7406\u5bf9\u8c61\u8c03\u7528\u67d0\u4e2a\u65b9\u6cd5\u65f6\uff0c\u4f1a\u628a\u6240\u8c03\u7528\u7684\u65b9\u6cd5\u4fe1\u606f\u751f\u6210\u4e00\u4e2a Invocation \u5bf9\u8c61\uff0c\u5e76\u6700\u7ec8\u901a\u8fc7\u67d0\u4e00\u4e2a Invoker \u7684 invoke() \u65b9\u6cd5\u628a Invocation \u5bf9\u8c61\u53d1\u9001\u51fa\u53bb\uff0c\u6240\u4ee5\u4ee3\u7406\u5bf9\u8c61\u4e2d\u7684 Invoker \u5bf9\u8c61\u662f\u5173\u952e\uff0c\u670d\u52a1\u5f15\u5165\u6700\u6838\u5fc3\u7684\u5c31\u662f\u8981\u751f\u6210\u8fd9\u4e9b Invoker \u5bf9\u8c61\u3002<\/p>\n<p>Invoker \u662f\u975e\u5e38\u6838\u5fc3\u7684\u4e00\u4e2a\u6982\u5ff5\uff0c\u4e5f\u6709\u975e\u5e38\u591a\u79cd\u7c7b\uff0c\u6bd4\u5982\uff1a<\/p>\n<p>1.TripleInvoker\uff1a\u8868\u793a\u5229\u7528 tri \u534f\u8bae\u628a Invocation \u5bf9\u8c61\u53d1\u9001\u51fa\u53bb\uff1b<\/p>\n<p>2.DubboInvoker\uff1a\u8868\u793a\u5229\u7528 dubbo \u534f\u8bae\u628a Invocation \u5bf9\u8c61\u53d1\u9001\u51fa\u53bb\uff1b<\/p>\n<p>3.ClusterInvoker\uff1a\u6709\u8d1f\u8f7d\u5747\u8861\u529f\u80fd\uff1b<\/p>\n<p>4.MigrationInvoker\uff1a\u8fc1\u79fb\u529f\u80fd\uff0cDubbo3.0 \u65b0\u589e\u7684<\/p>\n<p>\u50cf TripleInvoker \u548c DubboInvoker \u5bf9\u5e94\u7684\u5c31\u662f\u5177\u4f53\u670d\u52a1\u63d0\u4f9b\u8005\uff0c\u5305\u542b\u4e86\u670d\u52a1\u63d0\u4f9b\u8005\u7684 ip \u5730\u5740\u548c\u7aef\u53e3\uff0c\u5e76\u4e14\u4f1a\u8d1f\u8d23\u8ddf\u5bf9\u5e94\u7684 ip \u548c port \u5efa\u7acb Socket \u8fde\u63a5\uff0c\u540e\u7eed\u5c31\u53ef\u4ee5\u57fa\u4e8e\u8fd9\u4e2a Socket \u8fde\u63a5\u5e76\u6309\u534f\u8bae\u683c\u5f0f\u53d1\u9001 Invocation \u5bf9\u8c61\u3002<\/p>\n<p>\u6bd4\u5982\u73b0\u5728\u5f15\u5165\u4e86 DemoService \u8fd9\u4e2a\u670d\u52a1\uff0c\u90a3\u5982\u679c\u8be5\u670d\u52a1\u652f\u6301\uff1a<\/p>\n<p>1.\u4e00\u4e2a tri \u534f\u8bae\uff0c\u7ed1\u5b9a\u7684\u7aef\u53e3\u4e3a 20881\uff1b<\/p>\n<p>2.\u4e00\u4e2a tri \u534f\u8bae\uff0c\u7ed1\u5b9a\u7684\u7aef\u53e3\u4e3a 20882\uff1b<\/p>\n<p>3.\u4e00\u4e2a dubbo \u534f\u8bae\uff0c\u7ed1\u5b9a\u7684\u7aef\u53e3\u4e3a 20883\uff1b<\/p>\n<p>\u90a3\u4e48\u5728\u670d\u52a1\u6d88\u8d39\u7aef\u8fd9\u8fb9\uff0c\u5c31\u4f1a\u751f\u6210\u4e24\u4e2a TripleInvoker \u548c\u4e00\u4e2a DubboInvoker\uff0c\u4ee3\u7406\u5bf9\u8c61\u6267\u884c\u65b9\u6cd5\u65f6\u5c31\u4f1a\u8fdb\u884c\u8d1f\u8f7d\u5747\u8861\u9009\u62e9\u5176\u4e2d\u4e00\u4e2a Invoker \u8fdb\u884c\u8c03\u7528\u3002<\/p>\n<h2>\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165<\/h2>\n<p>\u5728\u670d\u52a1\u5bfc\u51fa\u65f6\uff0cDubbo3.0 \u9ed8\u8ba4\u60c5\u51b5\u4e0b\u5373\u4f1a\u8fdb\u884c\u63a5\u53e3\u7ea7\u6ce8\u518c\uff0c\u4e5f\u4f1a\u8fdb\u884c\u5e94\u7528\u7ea7\u6ce8\u518c\uff0c\u76ee\u7684\u5c31\u662f\u4e3a\u4e86\u517c\u5bb9\u670d\u52a1\u6d88\u8d39\u8005\u5e94\u7528\uff0c\u7528\u7684\u8fd8\u662f Dubbo2.7\uff0c\u7528 Dubbo2.7 \u5c31\u53ea\u80fd\u8001\u8001\u5b9e\u5b9e\u7684\u8fdb\u884c\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\u3002<\/p>\n<p>\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\u6838\u5fc3\u5c31\u662f\u8981\u627e\u5230\u5f53\u524d\u6240\u5f15\u5165\u7684\u670d\u52a1\u6709\u54ea\u4e9b\u670d\u52a1 URL\uff0c\u7136\u540e\u6839\u636e\u6bcf\u4e2a\u670d\u52a1 URL \u751f\u6210\u5bf9\u5e94\u7684 Invoker\uff0c\u6d41\u7a0b\u4e3a\uff1a<\/p>\n<p>1.\u9996\u5148\uff0c\u6839\u636e\u5f53\u524d\u5f15\u5165\u7684\u670d\u52a1\u63a5\u53e3\u751f\u6210\u4e00\u4e2a RegistryDirectory \u5bf9\u8c61\uff0c\u8868\u793a\u52a8\u6001\u670d\u52a1\u76ee\u5f55\uff0c\u7528\u6765\u67e5\u8be2\u5e76\u7f13\u5b58\u670d\u52a1\u63d0\u4f9b\u8005\u4fe1\u606f\uff1b<\/p>\n<p>2.RegistryDirectory \u5bf9\u8c61\u4f1a\u6839\u636e\u670d\u52a1\u63a5\u53e3\u540d\u53bb\u6ce8\u518c\u4e2d\u5fc3\uff0c\u6bd4\u5982\uff1aZookeeper \u4e2d\u7684 \/dubbo\/\u670d\u52a1\u63a5\u53e3\u540d\/providers\/ \u8282\u70b9\u4e0b\u67e5\u627e\u6240\u6709\u7684\u670d\u52a1 URL\uff1b<\/p>\n<p>3.\u6839\u636e\u6bcf\u4e2a\u670d\u52a1 URL \u751f\u6210\u5bf9\u5e94\u7684 Invoker \u5bf9\u8c61\uff0c\u5e76\u628a Invoker \u5bf9\u8c61\u5b58\u5728 RegistryDirectory \u5bf9\u8c61\u7684 invokers \u5c5e\u6027\u4e2d\uff1b<\/p>\n<p>4.RegistryDirectory \u5bf9\u8c61\u4e5f\u4f1a\u76d1\u542c \/dubbo\/\u670d\u52a1\u63a5\u53e3\u540d\/providers\/ \u8282\u70b9\u7684\u6570\u636e\u53d8\u5316\uff0c\u4e00\u65e6\u53d1\u751f\u4e86\u53d8\u5316\u5c31\u8981\u8fdb\u884c\u76f8\u5e94\u7684\u6539\u53d8\uff1b<\/p>\n<p>5.\u6700\u540e\u5c06 RegistryDirectory \u5bf9\u8c61\u751f\u6210\u4e00\u4e2a ClusterInvoker \u5bf9\u8c61\uff0c\u5230\u65f6\u5019\u8c03\u7528 ClusterInvoker \u5bf9\u8c61\u7684 invoke() \u65b9\u6cd5\u5c31\u4f1a\u8fdb\u884c\u8d1f\u8f7d\u5747\u8861\u9009\u51fa\u67d0\u4e00\u4e2a Invoker \u8fdb\u884c\u8c03\u7528\uff1b<\/p>\n<p><img decoding=\"async\"   referrerpolicy=\"no-referrer\" src=\"https:\/\/i-blog.csdnimg.cn\/direct\/d03c4690141843c3a4e066baa515f072.webp\" alt=\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" title=\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" loading=\"lazy\"><\/p>\n<h2>\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165<\/h2>\n<p>\u5728 Dubbo \u4e2d\uff0c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\uff0c\u5e76\u4e0d\u662f\u6307\u5f15\u5165\u67d0\u4e2a\u5e94\u7528\uff0c\u8fd9\u91cc\u548c SpringCloud \u662f\u6709\u533a\u522b\u7684\uff0c\u5728 SpringCloud \u4e2d\uff0c\u670d\u52a1\u6d88\u8d39\u8005\u53ea\u8981\u4ece\u6ce8\u518c\u4e2d\u5fc3\u627e\u5230\u8981\u8c03\u7528\u7684\u5e94\u7528\u7684\u6240\u6709\u5b9e\u4f8b\u5730\u5740\u5c31\u53ef\u4ee5\u4e86\uff0c\u4f46\u662f\u5728 Dubbo \u4e2d\u627e\u5230\u5e94\u7528\u7684\u5b9e\u4f8b\u5730\u5740\u8fd8\u8fdc\u8fdc\u4e0d\u591f\uff0c\u56e0\u4e3a\u5728 Dubbo \u4e2d\u662f\u76f4\u63a5\u4f7f\u7528\u7684\u63a5\u53e3\uff0c\u6240\u4ee5\u5728 Dubbo \u4e2d\u5c31\u7b97\u662f\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\uff0c\u6700\u7ec8\u8fd8\u662f\u5f97\u627e\u5230\u670d\u52a1\u63a5\u53e3\u6709\u54ea\u4e9b\u670d\u52a1\u63d0\u4f9b\u8005\u3002<\/p>\n<p>\u6240\u4ee5\uff0c\u5bf9\u4e8e\u670d\u52a1\u6d88\u8d39\u8005\u800c\u8a00\uff0c\u4e0d\u7ba1\u662f\u4f7f\u7528\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\uff0c\u8fd8\u662f\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\uff0c\u6700\u7ec8\u7684\u7ed3\u679c\u5e94\u8be5\u5f97\u662f\u4e00\u6837\u7684\uff0c\u4e5f\u5c31\u662f\u67d0\u4e2a\u670d\u52a1\u63a5\u53e3\u7684\u63d0\u4f9b\u8005 Invoker \u662f\u4e00\u6837\u7684\uff0c\u4e0d\u53ef\u80fd\u4f7f\u7528\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u5f97\u5230\u7684 Invoker \u591a\u4e00\u4e2a\u6216\u5c11\u4e00\u4e2a\uff0c\u4f46\u662f\uff01\uff01\uff01\uff0c\u76ee\u524d\u4f1a\u6709\u60c5\u51b5\u4e0d\u4e00\u81f4\uff0c\u5c31\u662f\u4e00\u4e2a\u534f\u8bae\u6709\u591a\u4e2a\u7aef\u53e3\u65f6\uff0c\u6bd4\u5982\u5728\u670d\u52a1\u63d0\u4f9b\u8005\u5e94\u7528\u8fd9\u8fb9\u652f\u6301\uff1a<\/p>\n<pre><code>dubbo:\n  application:\n    name: dubbo-springboot-demo-provider\n  protocols:\n    p1:\n      name: dubbo\n      port: 20881\n    p2:\n      name: tri\n      port: 20882\n    p3:\n      name: tri\n      port: 50051\n<\/code><\/pre>\n<p>\u90a3\u4e48\u5728\u6d88\u8d39\u7aef\u8fdb\u884c\u670d\u52a1\u5f15\u5165\u65f6\uff0c\u6bd4\u5982\uff1a\u5f15\u5165 DemoService \u65f6\uff0c\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\u4f1a\u751f\u6210 3 \u4e2a Invoker\uff082\u4e2a TripleInvoker\uff0c1\u4e2aDubboInvoker\uff09\uff0c\u800c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u53ea\u4f1a\u751f\u6210 2 \u4e2a Invoker\uff081\u4e2aTripleInvoker\uff0c1\u4e2aDubboInvoker\uff09\uff0c\u539f\u56e0\u5c31\u662f\u5728\u8fdb\u884c\u5e94\u7528\u7ea7\u6ce8\u518c\u65f6\u662f\u6309\u7167\u4e00\u4e2a\u534f\u8bae\u5bf9\u5e94\u4e00\u4e2aport\u5b58\u7684\u3002<\/p>\n<p>\u90a3\u65e2\u7136\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\u548c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u6700\u7ec8\u7684\u7ed3\u679c\u5dee\u4e0d\u591a\uff0c\u53ef\u80fd\u5c31\u4e0d\u7406\u89e3\u4e86\uff0c\u90a3\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u6709\u4ec0\u4e48\u597d\u5904\u5462\uff1f\u8981\u77e5\u9053\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u548c\u5e94\u7528\u7ea7\u670d\u52a1\u6ce8\u518c\u662f\u5bf9\u5e94\uff0c\u670d\u52a1\u63d0\u4f9b\u8005\u5e94\u7528\u5982\u679c\u53ea\u505a\u5e94\u7528\u7ea7\u6ce8\u518c\uff0c\u90a3\u4e48\u5bf9\u5e94\u7684\u670d\u52a1\u6d88\u8d39\u8005\u5c31\u53ea\u80fd\u8fdb\u884c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\uff0c\u597d\u5904\u5c31\u662f\u524d\u9762\u6240\u8bf4\u7684\uff0c\u51cf\u8f7b\u4e86\u6ce8\u518c\u4e2d\u5fc3\u7684\u538b\u529b\u7b49\uff0c\u90a3\u4e48\u5e26\u6765\u7684\u5f71\u54cd\u5c31\u662f\u670d\u52a1\u6d88\u8d39\u8005\u7aef\u5bfb\u627e\u670d\u52a1 URL \u7684\u903b\u8f91\u66f4\u590d\u6742\u4e86\u3002<\/p>\n<p>\u53ea\u8981\u627e\u5230\u4e86\u5f53\u524d\u5f15\u5165\u670d\u52a1\u5bf9\u5e94\u7684\u670d\u52a1 URL\uff0c\u7136\u540e\u751f\u6210\u5bf9\u5e94\u7684 Invoker\uff0c\u5e76\u6700\u7ec8\u751f\u6210\u4e00\u4e2a ClusterInvoker\u3002<\/p>\n<p>\u5728\u8fdb\u884c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u65f6\uff1a<\/p>\n<p>1.\u9996\u5148\uff0c\u6839\u636e\u5f53\u524d\u5f15\u5165\u7684\u670d\u52a1\u63a5\u53e3\u751f\u6210\u4e00\u4e2a ServiceDiscoveryRegistryDirectory \u5bf9\u8c61\uff0c\u8868\u793a\u52a8\u6001\u670d\u52a1\u76ee\u5f55\uff0c\u7528\u6765\u67e5\u8be2\u5e76\u7f13\u5b58\u670d\u52a1\u63d0\u4f9b\u8005\u4fe1\u606f\uff1b<\/p>\n<p>2.\u6839\u636e\u63a5\u53e3\u540d\u53bb\u83b7\u53d6 \/dubbo\/mapping\/\u670d\u52a1\u63a5\u53e3\u540d\u8282\u70b9\u7684\u5185\u5bb9\uff0c\u62ff\u5230\u7684\u5c31\u662f\u8be5\u63a5\u53e3\u6240\u5bf9\u5e94\u7684\u5e94\u7528\u540d\uff1b<\/p>\n<p>3.\u6709\u4e86\u5e94\u7528\u540d\u4e4b\u540e\uff0c\u518d\u53bb\u83b7\u53d6 \/services\/\u5e94\u7528\u540d\u8282\u70b9\u4e0b\u7684\u5b9e\u4f8b\u4fe1\u606f\uff1b<\/p>\n<p>4.\u4f9d\u6b21\u904d\u5386\u6bcf\u4e2a\u5b9e\u4f8b\uff0c\u6bcf\u4e2a\u5b9e\u4f8b\u90fd\u6709\u4e00\u4e2a\u7f16\u53f7 revision<\/p>\n<p>5.\u6839\u636e metadata-type \u8fdb\u884c\u5224\u65ad\u5982\u679c\u662f local\uff1a\u5219\u8c03\u7528\u5b9e\u4f8b\u4e0a\u7684\u5143\u6570\u636e\u670d\u52a1\u83b7\u53d6\u5e94\u7528\u5143\u6570\u636e\uff08MetadataInfo\uff09\uff1b\u5982\u679c\u662f remote\uff1a\u5219\u6839\u636e\u5e94\u7528\u540d\u4ece\u5143\u6570\u636e\u4e2d\u5fc3\u83b7\u53d6\u5e94\u7528\u5143\u6570\u636e\uff08MetadataInfo\uff09\uff1b<\/p>\n<p>6.\u83b7\u53d6\u5230\u5e94\u7528\u5143\u6570\u636e\u4e4b\u540e\u5c31\u8fdb\u884c\u7f13\u5b58\uff0ckey \u4e3a revision\uff0cMetadataInfo \u5bf9\u8c61\u4e3a value<\/p>\n<p>7.\u8fd9\u91cc\u4e3a\u4ec0\u4e48\u8981\u53bb\u6bcf\u4e2a\u5b9e\u4f8b\u4e0a\u83b7\u53d6\u5e94\u7528\u7684\u5143\u6570\u636e\u4fe1\u606f\u5462\uff1f\u56e0\u4e3a\u6709\u53ef\u80fd\u4e0d\u4e00\u6837\uff0c\u867d\u7136\u662f\u540c\u4e00\u4e2a\u5e94\u7528\uff0c\u4f46\u662f\u5728\u8fd0\u884c\u4e0d\u540c\u7684\u5b9e\u4f8b\u7684\u65f6\u5019\uff0c\u53ef\u4ee5\u6307\u5b9a\u4e0d\u540c\u7684\u53c2\u6570\uff0c\u6bd4\u5982\u4e0d\u540c\u7684\u534f\u8bae\uff0c\u4e0d\u540c\u7684\u7aef\u53e3\uff0c\u867d\u7136\u5728\u751f\u4ea7\u4e0a\u57fa\u672c\u4e0d\u4f1a\u8fd9\u4e48\u505a\uff0c\u4f46\u662f Dubbo \u8fd8\u662f\u652f\u6301\u4e86\u8fd9\u79cd\u60c5\u51b5<\/p>\n<p>8.\u6839\u636e\u4ece\u6240\u6709\u5b9e\u4f8b\u4e0a\u83b7\u53d6\u5230\u7684 MetadataInfo \u4ee5\u53ca endpoint \u4fe1\u606f\uff0c\u5c31\u80fd\u77e5\u9053\u6240\u6709\u5b9e\u4f8b\u4e0a\u6240\u6709\u7684\u670d\u52a1 URL\uff08\u6ce8\u610f\uff1a\u4e00\u4e2a\u63a5\u53e3+\u4e00\u4e2a\u534f\u8bae+\u4e00\u4e2a\u5b9e\u4f8b : \u5bf9\u5e94\u4e00\u4e2a\u670d\u52a1URL\uff09<\/p>\n<p>9.\u62ff\u5230\u4e86\u8fd9\u4e9b\u670d\u52a1 URL \u4e4b\u540e\uff0c\u5c31\u6839\u636e\u5f53\u524d\u5f15\u5165\u670d\u52a1\u7684\u4fe1\u606f\u8fdb\u884c\u8fc7\u6ee4\uff0c\u4f1a\u6839\u636e\u5f15\u5165\u670d\u52a1\u7684\u63a5\u53e3\u540d+\u534f\u8bae\u540d\uff0c\u6d88\u8d39\u8005\u53ef\u4ee5\u5728 @DubboReference \u4e2d\u6307\u5b9a\u534f\u8bae\uff0c\u8868\u793a\u53ea\u4f7f\u7528\u8fd9\u4e2a\u534f\u8bae\u8c03\u7528\u5f53\u524d\u670d\u52a1\uff0c\u5982\u679c\u6ca1\u6709\u6307\u5b9a\u534f\u8bae\uff0c\u90a3\u4e48\u5c31\u4f1a\u53bb\u83b7\u53d6 tri\u3001dubbo\u3001rest \u8fd9\u4e09\u4e2a\u534f\u8bae\u5bf9\u5e94\u7684\u670d\u52a1 URL\uff08Dubbo3.0 \u9ed8\u8ba4\u53ea\u652f\u6301\u8fd9\u4e09\u4e2a\u534f\u8bae\uff09<\/p>\n<p>10.\u8fd9\u6837\uff0c\u7ecf\u8fc7\u8fc7\u6ee4\u4e4b\u540e\uff0c\u5c31\u5f97\u5230\u4e86\u5f53\u524d\u6240\u5f15\u5165\u7684\u670d\u52a1\u5bf9\u5e94\u7684\u670d\u52a1 URL \u4e86<\/p>\n<p>11.\u6839\u636e\u6bcf\u4e2a\u670d\u52a1 URL \u751f\u6210\u5bf9\u5e94\u7684 Invoker \u5bf9\u8c61\uff0c\u5e76\u628a Invoker \u5bf9\u8c61\u5b58\u5728 ServiceDiscoveryRegistryDirectory \u5bf9\u8c61\u7684 invokers \u5c5e\u6027\u4e2d<\/p>\n<p>12.\u6700\u540e\u5c06 ServiceDiscoveryRegistryDirectory \u5bf9\u8c61\u751f\u6210\u4e00\u4e2a ClusterInvoker \u5bf9\u8c61\uff0c\u5230\u65f6\u5019\u8c03\u7528 ClusterInvoker \u5bf9\u8c61\u7684 invoke() \u65b9\u6cd5\u5c31\u4f1a\u8fdb\u884c\u8d1f\u8f7d\u5747\u8861\u9009\u51fa\u67d0\u4e00\u4e2a Invoker \u8fdb\u884c\u8c03\u7528<\/p>\n<h2>MigrationInvoker \u7684\u751f\u6210<\/h2>\n<p>\u4e0a\u9762\u5206\u6790\u4e86\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\u548c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\uff0c\u6700\u7ec8\u90fd\u662f\u5f97\u5230\u67d0\u4e2a\u670d\u52a1\u5bf9\u5e94\u7684\u670d\u52a1\u63d0\u4f9b\u8005 Invoker\uff0c\u90a3\u6700\u7ec8\u8fdb\u884c\u670d\u52a1\u8c03\u7528\u65f6\uff0c\u5230\u5e95\u8be5\u600e\u4e48\u9009\u62e9\u5462\uff1f<\/p>\n<p>\u6240\u4ee5\u5728 Dubbo3.0 \u4e2d\uff0c\u53ef\u4ee5\u914d\u7f6e\uff1a<\/p>\n<pre><code># dubbo.application.service-discovery.migration \u4ec5\u652f\u6301\u901a\u8fc7 -D \u4ee5\u53ca \u5168\u5c40\u914d\u7f6e\u4e2d\u5fc3 \u4e24\u79cd\u65b9\u5f0f\u8fdb\u884c\u914d\u7f6e\u3002\n\ndubbo.application.service-discovery.migration=APPLICATION_FIRST\n\n # \u53ef\u9009\u503c\n # FORCE_INTERFACE\uff0c\u5f3a\u5236\u4f7f\u7528\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\n # FORCE_APPLICATION\uff0c\u5f3a\u5236\u4f7f\u7528\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\n # APPLICATION_FIRST\uff0c\u667a\u80fd\u9009\u62e9\u662f\u63a5\u53e3\u7ea7\u8fd8\u662f\u5e94\u7528\u7ea7\uff0c\u9ed8\u8ba4\u5c31\u662f\u8fd9\u4e2a\n<\/code><\/pre>\n<p>\u5bf9\u4e8e\u524d\u4e24\u79cd\u5f3a\u5236\u7684\u65b9\u5f0f\uff0c\u6ca1\u4ec0\u4e48\u7279\u6b8a\uff0c\u5c31\u662f\u4e0a\u9762\u8d70\u4e0a\u9762\u5206\u6790\u7684\u4e24\u4e2a\u8fc7\u7a0b\uff0c\u6ca1\u6709\u989d\u5916\u7684\u903b\u8f91\uff0c\u90a3\u5bf9\u4e8e APPLICATION\/_FIRST \u5c31\u9700\u8981\u6709\u989d\u5916\u7684\u903b\u8f91\u4e86\uff0c\u4e5f\u5c31\u662f Dubbo \u8981\u5224\u65ad\uff0c\u5f53\u524d\u6240\u5f15\u5165\u7684\u8fd9\u4e2a\u670d\u52a1\uff0c\u5e94\u8be5\u8d70\u63a5\u53e3\u7ea7\u8fd8\u662f\u5e94\u7528\u7ea7\uff0c\u8fd9\u8be5\u5982\u4f55\u5224\u65ad\u5462\uff1f<\/p>\n<p>\u4e8b\u5b9e\u4e0a\uff0c\u5728\u8fdb\u884c\u67d0\u4e2a\u670d\u52a1\u7684\u670d\u52a1\u5f15\u5165\u65f6\uff0c\u4f1a\u7edf\u4e00\u5229\u7528 InterfaceCompatibleRegistryProtocol \u7684 refer \u6765\u751f\u6210\u4e00\u4e2a MigrationInvoker \u5bf9\u8c61\uff0c\u5728 MigrationInvoker \u4e2d\u6709\u4e09\u4e2a\u5c5e\u6027\uff1a<\/p>\n<pre><code>private volatile ClusterInvoker&lt;T&gt; invoker; \/\/ \u7528\u6765\u8bb0\u5f55\u63a5\u53e3\u7ea7ClusterInvoker\nprivate volatile ClusterInvoker&lt;T&gt; serviceDiscoveryInvoker; \/\/ \u7528\u6765\u8bb0\u5f55\u5e94\u7528\u7ea7\u7684ClusterInvoker\n\nprivate volatile ClusterInvoker&lt;T&gt; currentAvailableInvoker; \/\/ \u7528\u6765\u8bb0\u5f55\u5f53\u524d\u4f7f\u7528\u7684ClusterInvoker\uff0c\u8981\u4e48\u662f\u63a5\u53e3\u7ea7\uff0c\u8981\u4e48\u5e94\u7528\u7ea7\n<\/code><\/pre>\n<p>\u4e00\u5f00\u59cb\u6784\u9020\u51fa\u6765\u7684 MigrationInvoker \u5bf9\u8c61\u4e2d\u4e09\u4e2a\u5c5e\u6027\u90fd\u4e3a\u7a7a\uff0c\u63a5\u4e0b\u6765\u4f1a\u5229\u7528 MigrationRuleListener \u6765\u5904\u7406 MigrationInvoker \u5bf9\u8c61\uff0c\u4e5f\u5c31\u662f\u7ed9\u8fd9\u4e09\u4e2a\u5c5e\u6027\u8d4b\u503c\u3002<\/p>\n<p>\u5728 MigrationRuleListener \u7684\u6784\u9020\u65b9\u6cd5\u4e2d\uff0c\u4f1a\u4ece\u914d\u7f6e\u4e2d\u5fc3\u8bfb\u53d6 DUBBO\/_SERVICEDISCOVERY\/_MIGRATION \u7ec4\u4e0b\u9762\u7684&#8221;\u5f53\u524d\u5e94\u7528\u540d+.migration&#8221;\u7684\u914d\u7f6e\u9879\uff0c\u914d\u7f6e\u9879\u4e3a yml \u683c\u5f0f\uff0c\u5bf9\u5e94\u7684\u5bf9\u8c61\u4e3a MigrationRule\uff0c\u4e5f\u5c31\u662f\u53ef\u4ee5\u914d\u7f6e\u5177\u4f53\u7684\u8fc1\u79fb\u89c4\u5219\uff0c\u6bd4\u5982\uff1a\u67d0\u4e2a\u63a5\u53e3\u6216\u67d0\u4e2a\u5e94\u7528\u7684 MigrationStep\uff08FORCE\/_INTERFACE\u3001APPLICATION\/_FIRST\u3001FORCE\/_APPLICATION\uff09\uff0c\u8fd8\u53ef\u4ee5\u914d\u7f6e threshold\uff0c\u8868\u793a\u4e00\u4e2a\u9608\u503c\uff0c\u6bd4\u5982\uff1a\u914d\u7f6e\u4e3a 2\uff0c\u8868\u793a\u5e94\u7528\u7ea7 Invoker \u6570\u91cf\u662f\u63a5\u53e3\u7ea7 Invoker \u6570\u91cf\u7684\u4e24\u500d\u65f6\u624d\u4f7f\u7528\u5e94\u7528\u7ea7 Invoker\uff0c\u4e0d\u7136\u5c31\u4f7f\u7528\u63a5\u53e3\u7ea7\u6570\u91cf\uff0c\u53ef\u4ee5\u53c2\u8003\uff1a<a href=\"https:\/\/link.segmentfault.com\/?enc=rW7esT6INEofUpNoc5eWQA%3D%3D.8ON48RTvd3doW7ODB%2Bx2X4wlF%2FIzJ2AfVM6pGXWN8cgIjUW8r9vjvke2ncHmXTpeUQm6orPSQFkvxWbt2Fr8SA%3D%3D\" rel=\"nofollow noopener noreferrer\" target=\"_blank\">https:\/\/cn.dubbo.apache.org\/zh\/docs\/advanced\/migration-invoker\/<\/a><\/p>\n<p>\u5982\u679c\u6ca1\u6709\u914d\u7f6e\u8fc1\u79fb\u89c4\u5219\uff0c\u5219\u4f1a\u770b\u5f53\u524d\u5e94\u7528\u4e2d\u662f\u5426\u914d\u7f6e\u4e86 migration.step\uff0c\u5982\u679c\u6ca1\u6709\uff0c\u90a3\u5c31\u4ece\u5168\u5c40\u914d\u7f6e\u4e2d\u5fc3\u8bfb\u53d6 dubbo.application.service-discovery.migration \u6765\u83b7\u53d6 MigrationStep\uff0c\u5982\u679c\u4e5f\u6ca1\u6709\u914d\u7f6e\uff0c\u90a3 MigrationStep \u9ed8\u8ba4\u4e3a APPLICATION\/_FIRST<\/p>\n<p>\u5982\u679c\u6ca1\u6709\u914d\u7f6e\u8fc1\u79fb\u89c4\u5219\uff0c\u5219\u4f1a\u770b\u5f53\u524d\u5e94\u7528\u4e2d\u662f\u5426\u914d\u7f6e\u4e86 migration.threshold\uff0c\u5982\u679c\u6ca1\u6709\u914d\uff0c\u5219 threshold \u9ed8\u8ba4\u4e3a -1\u3002<\/p>\n<p>\u5728\u5e94\u7528\u4e2d\u53ef\u4ee5\u8fd9\u4e48\u914d\u7f6e\uff1a<\/p>\n<pre><code>dubbo:\n    application:\n        name: dubbo-springboot-demo-consumer\n        parameters:\n            migration.step: FORCE_APPLICATION\n            migration.threshold: 2\n<\/code><\/pre>\n<p>\u786e\u5b9a\u4e86 step \u548c threshold \u4e4b\u540e\uff0c\u5c31\u8981\u771f\u6b63\u5f00\u59cb\u7ed9 MigrationInvoker \u5bf9\u8c61\u4e2d\u7684\u4e09\u4e2a\u5c5e\u6027\u8d4b\u503c\u4e86\uff0c\u5148\u6839\u636e step \u8c03\u7528\u4e0d\u540c\u7684\u65b9\u6cd5<\/p>\n<pre><code>switch (step) {\n case APPLICATION_FIRST:\n \/\/ \u5148\u8fdb\u884c\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\u5f97\u5230\u5bf9\u5e94\u7684ClusterInvoker\uff0c\u5e76\u8d4b\u503c\u7ed9invoker\u5c5e\u6027\n \/\/ \u518d\u8fdb\u884c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u5f97\u5230\u5bf9\u5e94\u7684ClusterInvoker\uff0c\u5e76\u8d4b\u503c\u7ed9serviceDiscoveryInvoker\u5c5e\u6027\n\/\/ \u518d\u6839\u636e\u4e24\u8005\u7684\u6570\u91cf\u5224\u65ad\u5230\u5e95\u7528\u54ea\u4e2a\uff0c\u5e76\u4e14\u628a\u786e\u5b9a\u7684ClusterInvoker\u8d4b\u503c\u7ed9currentAvailableInvoker\u5c5e\u6027\n\n migrationInvoker.migrateToApplicationFirstInvoker(newRule);\n break;\n case FORCE_APPLICATION:\n\/\/ \u53ea\u8fdb\u884c\u5e94\u7528\u7ea7\u670d\u52a1\u5f15\u5165\u5f97\u5230\u5bf9\u5e94\u7684ClusterInvoker\uff0c\u5e76\u8d4b\u503c\u7ed9serviceDiscoveryInvoker\u548ccurrentAvailableInvoker\u5c5e\u6027\n\n success = migrationInvoker.migrateToForceApplicationInvoker(newRule);\n break;\n case FORCE_INTERFACE:\n default:\n\/\/ \u53ea\u8fdb\u884c\u63a5\u53e3\u7ea7\u670d\u52a1\u5f15\u5165\u5f97\u5230\u5bf9\u5e94\u7684ClusterInvoker\uff0c\u5e76\u8d4b\u503c\u7ed9invoker\u548ccurrentAvailableInvoker\u5c5e\u6027\n\n success = migrationInvoker.migrateToForceInterfaceInvoker(newRule);\n }\n<\/code><\/pre>\n<p>\u8fd9\u91cc\u53ea\u9700\u8981\u5206\u6790\u5f53 step \u4e3a APPLICATION\/_FIRST \u65f6\uff0c\u662f\u5982\u4f55\u786e\u5b9a\u6700\u7ec8\u8981\u4f7f\u7528\u7684 ClusterInvoker \u7684\u3002<\/p>\n<p>\u5f97\u5230\u4e86\u63a5\u53e3\u7ea7 ClusterInvoker \u548c\u5e94\u7528\u7ea7 ClusterInvoker \u4e4b\u540e\uff0c\u5c31\u4f1a\u5229\u7528 DefaultMigrationAddressComparator \u6765\u8fdb\u884c\u5224\u65ad\uff1a<\/p>\n<p>1.\u5982\u679c\u5e94\u7528\u7ea7 ClusterInvoker \u4e2d\u6ca1\u6709\u5177\u4f53\u7684 Invoker\uff0c\u90a3\u5c31\u8868\u793a\u53ea\u80fd\u7528\u63a5\u53e3\u7ea7 Invoker<\/p>\n<p>2.\u5982\u679c\u63a5\u53e3\u7ea7 ClusterInvoker \u4e2d\u6ca1\u6709\u5177\u4f53\u7684 Invoker\uff0c\u90a3\u5c31\u8868\u793a\u53ea\u80fd\u7528\u5e94\u7528\u7ea7 Invoker<\/p>\n<p>3.\u5982\u679c\u5e94\u7528\u7ea7 ClusterInvoker \u548c\u63a5\u53e3\u7ea7 ClusterInvoker \u4e2d\u90fd\u6709\u5177\u4f53\u7684 Invoker\uff0c\u5219\u83b7\u53d6\u5bf9\u5e94\u7684 Invoker \u4e2a\u6570<\/p>\n<p>4.\u5982\u679c\u5728\u8fc1\u79fb\u89c4\u5219\u548c\u5e94\u7528\u53c2\u6570\u4e2d\u90fd\u6ca1\u6709\u914d\u7f6e threshold\uff0c\u90a3\u5c31\u8bfb\u53d6\u5168\u5c40\u914d\u7f6e\u4e2d\u5fc3\u7684 dubbo.application.migration.threshold \u53c2\u6570\uff0c\u5982\u679c\u4e5f\u6ca1\u6709\u914d\u7f6e\uff0c\u5219threshold \u9ed8\u8ba4\u4e3a 0\uff08\u4e0d\u662f-1\u4e86\uff09<\/p>\n<p>5.\u7528\u5e94\u7528\u7ea7 Invoker \u6570\u91cf \/ \u63a5\u53e3\u7ea7 Invoker \u6570\u91cf\uff0c\u5f97\u5230\u7684\u7ed3\u679c\u5982\u679c\u5927\u4e8e\u7b49\u4e8e threshold\uff0c\u90a3\u5c31\u7528\u5e94\u7528\u7ea7 ClusterInvoker\uff0c\u5426\u5219\u7528\u63a5\u53e3\u7ea7 ClusterInvoker<\/p>\n<p>threshold \u9ed8\u8ba4\u4e3a 0\uff0c\u90a3\u5c31\u8868\u793a\u5728\u65e2\u6709\u5e94\u7528\u7ea7 Invoker \u53c8\u6709\u63a5\u53e3\u7ea7 Invoker \u7684\u60c5\u51b5\u4e0b\uff0c\u5c31\u4e00\u5b9a\u4f1a\u7528\u5e94\u7528\u7ea7 Invoker\uff0c\u4e24\u4e2a\u6b63\u6570\u76f8\u9664\uff0c\u7ed3\u679c\u80af\u5b9a\u4e3a\u6b63\u6570\uff0c\u5f53\u7136\u4f60\u81ea\u5df1\u53ef\u4ee5\u63a7\u5236 threshold\uff0c\u5982\u679c\u65e2\u6709\u65e2\u6709\u5e94\u7528\u7ea7 Invoker \u53c8\u6709\u63a5\u53e3\u7ea7 Invoker \u7684\u60c5\u51b5\u4e0b\uff0c\u4f60\u60f3\u5728\u5e94\u7528\u7ea7 Invoker \u7684\u4e2a\u6570\u5927\u4e8e\u63a5\u53e3\u7ea7 Invoker \u7684\u4e2a\u6570\u65f6\u91c7\u7528\u5e94\u7528\u7ea7Invoker\uff0c\u90a3\u5c31\u53ef\u4ee5\u628a threshold \u8bbe\u7f6e\u4e3a 1\uff0c\u8868\u793a\u4e2a\u6570\u76f8\u7b49\uff0c\u6216\u8005\u4e2a\u6570\u76f8\u9664\u4e4b\u540e\u7684\u7ed3\u679c\u5927\u4e8e 1 \u65f6\u7528\u5e94\u7528\u7ea7 Invoker\uff0c\u5426\u8005\u7528\u63a5\u53e3\u7ea7 Invoker<\/p>\n<p>\u8fd9\u6837 MigrationInvoker \u5bf9\u8c61\u4e2d\u7684\u4e09\u4e2a\u6570\u636e\u5c31\u80fd\u786e\u5b9a\u597d\u503c\u4e86\uff0c\u548c\u5728\u6700\u7ec8\u7684\u63a5\u53e3\u4ee3\u7406\u5bf9\u8c61\u6267\u884c\u67d0\u4e2a\u65b9\u6cd5\u65f6\uff0c\u5c31\u4f1a\u8c03\u7528 MigrationInvoker \u5bf9\u8c61\u7684 invoke\uff0c\u5728\u8fd9\u4e2ainvoke \u65b9\u6cd5\u4e2d\u4f1a\u76f4\u63a5\u6267\u884c currentAvailableInvoker \u5bf9\u5e94\u7684 invoker \u7684 invoker \u65b9\u6cd5\uff0c\u4ece\u800c\u8fdb\u5165\u5230\u4e86\u63a5\u53e3\u7ea7 ClusterInvoker \u6216\u5e94\u7528\u7ea7 ClusterInvoker \u4e2d\uff0c\u4ece\u800c\u8fdb\u884c\u8d1f\u8f7d\u5747\u8861\uff0c\u9009\u62e9\u51fa\u5177\u4f53\u7684 DubboInvoer \u6216 TripleInvoker\uff0c\u5b8c\u6210\u771f\u6b63\u7684\u670d\u52a1\u8c03\u7528\u3002<\/p>\n<h2>\u670d\u52a1\u8c03\u7528\u5e95\u5c42\u539f\u7406<\/h2>\n<p>\u5728 Dubbo2.7 \u4e2d\uff0c\u9ed8\u8ba4\u7684\u662f Dubbo \u534f\u8bae\uff0c\u56e0\u4e3a Dubbo \u534f\u8bae\u76f8\u6bd4\u8f83\u4e8e Http1.1 \u800c\u8a00\uff0cDubbo \u534f\u8bae\u6027\u80fd\u4e0a\u662f\u8981\u66f4\u597d\u7684\u3002<\/p>\n<p>\u4f46\u662f Dubbo \u534f\u8bae\u81ea\u5df1\u7684\u7f3a\u70b9\u5c31\u662f\u4e0d\u901a\u7528\uff0c\u5047\u5982\u73b0\u5728\u901a\u8fc7 Dubbo \u534f\u8bae\u63d0\u4f9b\u4e86\u4e00\u4e2a\u670d\u52a1\uff0c\u90a3\u5982\u679c\u60f3\u8981\u8c03\u7528\u8be5\u670d\u52a1\u5c31\u5fc5\u987b\u8981\u6c42\u670d\u52a1\u6d88\u8d39\u8005\u4e5f\u8981\u652f\u6301 Dubbo \u534f\u8bae\uff0c\u6bd4\u5982\u60f3\u901a\u8fc7\u6d4f\u89c8\u5668\u76f4\u63a5\u8c03\u7528 Dubbo \u670d\u52a1\u662f\u4e0d\u884c\u7684\uff0c\u60f3\u901a\u8fc7 Nginx \u8c03 Dubbo \u670d\u52a1\u4e5f\u662f\u4e0d\u884c\u5f97\u3002<\/p>\n<p>\u800c\u968f\u7740\u4f01\u4e1a\u7684\u53d1\u5c55\uff0c\u5f80\u5f80\u53ef\u80fd\u4f1a\u51fa\u73b0\u516c\u53f8\u5185\u90e8\u4f7f\u7528\u591a\u79cd\u6280\u672f\u6808\uff0c\u53ef\u80fd\u8fd9\u4e2a\u90e8\u95e8\u4f7f\u7528 Dubbo\uff0c\u53e6\u5916\u4e00\u4e2a\u90e8\u95e8\u4f7f\u7528 Spring Cloud\uff0c\u53e6\u5916\u4e00\u4e2a\u90e8\u95e8\u4f7f\u7528 gRPC\uff0c\u90a3\u6b64\u65f6\u90e8\u95e8\u4e4b\u95f4\u8981\u60f3\u76f8\u4e92\u8c03\u7528\u670d\u52a1\u5c31\u6bd4\u8f83\u590d\u6742\u4e86\uff0c\u6240\u4ee5\u9700\u8981\u4e00\u4e2a\u901a\u7528\u7684\u3001\u6027\u80fd\u4e5f\u597d\u7684\u534f\u8bae\uff0c\u8fd9\u5c31\u662f Triple \u534f\u8bae\u3002<\/p>\n<p>Triple \u534f\u8bae\u662f\u57fa\u4e8e Http2 \u534f\u8bae\u7684\uff0c\u4e5f\u5c31\u662f\u5728\u4f7f\u7528 Triple \u534f\u8bae\u53d1\u9001\u6570\u636e\u65f6\uff0c\u4f1a\u6309 HTTP2 \u534f\u8bae\u7684\u683c\u5f0f\u6765\u53d1\u9001\u6570\u636e\uff0c\u800c HTTP2 \u534f\u8bae\u76f8\u6bd4\u8f83\u4e8e HTTP1 \u534f\u8bae\u800c\u8a00\uff0cHTTP2\u662f HTTP1 \u7684\u5347\u7ea7\u7248\uff0c\u5b8c\u5168\u517c\u5bb9 HTTP1\uff0c\u800c\u4e14 HTTP2 \u534f\u8bae\u4ece\u8bbe\u8ba1\u5c42\u9762\u5c31\u89e3\u51b3\u4e86 HTTP1 \u6027\u80fd\u4f4e\u7684\u95ee\u9898\u3002<\/p>\n<p>\u53e6\u5916\uff0cGoogle \u516c\u53f8\u5f00\u53d1\u7684 gRPC\uff0c\u4e5f\u57fa\u4e8e\u7684 HTTP2\uff0c\u76ee\u524d gRPC \u662f\u4e91\u539f\u751f\u4e8b\u5b9e\u4e0a\u534f\u8bae\u6807\u51c6\uff0c\u5305\u62ec k8s\/etcd \u7b49\u90fd\u652f\u6301 gRPC \u534f\u8bae\u3002<\/p>\n<p>\u6240\u4ee5 Dubbo3.0 \u4e3a\u4e86\u80fd\u591f\u66f4\u65b9\u4fbf\u7684\u548c k8s \u8fdb\u884c\u901a\u4fe1\uff0c\u5728\u5b9e\u73b0 Triple \u7684\u65f6\u5019\u4e5f\u517c\u5bb9\u4e86 gRPC\uff0c\u4e5f\u5c31\u662f\u53ef\u4ee5\u7528 gPRC \u7684\u5ba2\u6237\u7aef\u8c03\u7528 Dubbo3.0 \u6240\u63d0\u4f9b\u7684 triple \u670d\u52a1\uff0c\u4e5f\u53ef\u4ee5\u7528 triple \u670d\u52a1\u8c03\u7528 gRPC \u7684\u670d\u52a1\u3002<\/p>\n<h3>Triple \u7684\u5e95\u5c42\u539f\u7406\u5206\u6790<\/h3>\n<p>\u5c31\u662f\u56e0\u4e3a HTTP2 \u4e2d\u7684\u6570\u636e\u5e27\u673a\u5236\uff0cTriple \u534f\u8bae\u624d\u80fd\u652f\u6301 UNARY\u3001SERVER\/_STREAM\u3001BI\/_STREAM \u4e09\u79cd\u6a21\u5f0f\u3002<\/p>\n<p>1.UNARY\uff1a\u5c31\u662f\u6700\u666e\u901a\u7684\uff0c\u670d\u52a1\u7aef\u53ea\u6709\u5728\u63a5\u6536\u5230\u5b8c\u8bf7\u6c42\u5305\u62ec\u7684\u6240\u6709\u7684 HEADERS \u5e27\u548c DATA \u5e27\u4e4b\u540e(\u901a\u8fc7\u8c03\u7528 onCompleted() \u53d1\u9001\u6700\u540e\u4e00\u4e2a DATA \u5e27)\uff0c\u624d\u4f1a\u5904\u7406\u6570\u636e\uff0c\u5ba2\u6237\u7aef\u4e5f\u53ea\u6709\u63a5\u6536\u5b8c\u54cd\u5e94\u5305\u62ec\u7684\u6240\u6709\u7684 HEADERS \u5e27\u548c DATA \u5e27\u4e4b\u540e\uff0c\u624d\u4f1a\u5904\u7406\u54cd\u5e94\u7ed3\u679c\u3002<\/p>\n<p>2.SERVER\/_STREAM\uff1a\u670d\u52a1\u7aef\u6d41\uff0c\u7279\u6b8a\u7684\u5730\u65b9\u5728\u4e8e\uff0c\u670d\u52a1\u7aef\u5728\u63a5\u6536\u5b8c\u8bf7\u6c42\u5305\u62ec\u7684\u6240\u6709\u7684 DATA \u5e27\u4e4b\u540e\uff0c\u624d\u4f1a\u5904\u7406\u6570\u636e\uff0c\u4e0d\u8fc7\u5728\u5904\u7406\u6570\u636e\u7684\u8fc7\u7a0b\u4e2d\uff0c\u53ef\u4ee5\u591a\u6b21\u53d1\u9001\u54cd\u5e94 DATA \u5e27\uff08\u7b2c\u4e00\u4e2a DATA \u5e27\u53d1\u9001\u4e4b\u524d\u4f1a\u53d1\u9001\u4e00\u4e2a HEADERS \u5e27\uff09\uff0c\u5ba2\u6237\u7aef\u6bcf\u63a5\u6536\u5230\u4e00\u4e2a\u54cd\u5e94 DATA \u5e27\u5c31\u53ef\u4ee5\u76f4\u63a5\u5904\u7406\u8be5\u54cd\u5e94 DATA \u5e27\uff0c\u8fd9\u4e2a\u6a21\u5f0f\u4e0b\uff0c\u5ba2\u6237\u7aef\u53ea\u80fd\u53d1\u4e00\u6b21\u6570\u636e\uff0c\u4f46\u80fd\u591a\u6b21\u5904\u7406\u54cd\u5e94 DATA \u5e27\u3002<\/p>\n<p>3.BI\/_STREAM\uff1a\u53cc\u7aef\u6d41\uff0c\u6216\u8005\u5ba2\u6237\u7aef\u6d41\uff0c\u7279\u6b8a\u7684\u5730\u65b9\u5728\u4e8e\uff0c\u5ba2\u6237\u7aef\u53ef\u4ee5\u63a7\u5236\u53d1\u9001\u591a\u4e2a\u8bf7\u6c42 DATA \u5e27\uff08\u7b2c\u4e00\u4e2a DATA \u5e27\u53d1\u9001\u4e4b\u524d\u4f1a\u53d1\u9001\u4e00\u4e2a HEADERS \u5e27\uff09\uff0c\u670d\u52a1\u7aef\u4f1a\u4e0d\u65ad\u7684\u63a5\u6536\u5230\u8bf7\u6c42 DATA \u5e27\u5e76\u8fdb\u884c\u5904\u7406\uff0c\u5e76\u4e14\u53ca\u65f6\u7684\u628a\u5904\u7406\u7ed3\u679c\u4f5c\u4e3a\u54cd\u5e94 DATA \u5e27\u53d1\u9001\u7ed9\u5ba2\u6237\u7aef\uff08\u7b2c\u4e00\u4e2a DATA \u5e27\u53d1\u9001\u4e4b\u524d\u4f1a\u53d1\u9001\u4e00\u4e2a HEADERS \u5e27\uff09\uff0c\u800c\u5ba2\u6237\u7aef\u6bcf\u63a5\u6536\u5230\u4e00\u4e2a\u54cd\u5e94\u7ed3\u679c DATA \u5e27\u4e5f\u4f1a\u76f4\u63a5\u5904\u7406\uff0c\u8fd9\u79cd\u6a21\u5f0f\u4e0b\uff0c\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u7aef\u90fd\u5728\u4e0d\u65ad\u7684\u63a5\u6536\u548c\u53d1\u9001 DATA \u5e27\u5e76\u8fdb\u884c\u5904\u7406\uff0c\u6ce8\u610f\u8bf7\u6c42 HEADER \u5e27\u548c\u54cd\u5e94 HEADERS \u5e27\u90fd\u53ea\u53d1\u4e86\u4e00\u4e2a\u3002<\/p>\n<h3>Triple \u8bf7\u6c42\u8c03\u7528\u548c\u54cd\u5e94\u5904\u7406<\/h3>\n<p>\u521b\u5efa\u4e00\u4e2a Stream \u7684\u524d\u63d0\u662f\u5148\u5f97\u6709\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u6240\u4ee5\u6211\u4eec\u5f97\u5148\u77e5\u9053 Socket \u8fde\u63a5\u662f\u5728\u54ea\u521b\u5efa\u7684\u3002<\/p>\n<p>\u5728\u670d\u52a1\u63d0\u4f9b\u8005\u8fdb\u884c\u670d\u52a1\u5bfc\u51fa\u65f6\uff0c\u4f1a\u6309\u7167\u534f\u8bae\u4ee5\u53ca\u5bf9\u5e94\u7684\u7aef\u53e3\u542f\u52a8 Server\uff0c\u6bd4\u5982\uff1aTriple \u534f\u8bae\u5c31\u4f1a\u542f\u52a8 Netty \u5e76\u7ed1\u5b9a\u6307\u5b9a\u7684\u7aef\u53e3\uff0c\u7b49\u5f85 Socket \u8fde\u63a5\uff0c\u5728\u8fdb\u884c\u670d\u52a1\u6d88\u8d39\u8005\u8fdb\u884c\u670d\u52a1\u5f15\u5165\u7684\u8fc7\u7a0b\u4e2d\uff0c\u4f1a\u751f\u6210 TripleInvoker \u5bf9\u8c61\uff0c\u5728\u6784\u9020 TripleInvoker \u5bf9\u8c61\u7684\u6784\u9020\u65b9\u6cd5\u4e2d\uff0c\u4f1a\u5229\u7528 ConnectionManager \u521b\u5efa\u4e00\u4e2a Connection \u5bf9\u8c61\uff0c\u800cConnection \u5bf9\u8c61\u4e2d\u5305\u542b\u4e86\u4e00\u4e2a Bootstrap \u5bf9\u8c61\uff08Netty \u4e2d\u7528\u6765\u5efa\u7acb Socket \u8fde\u63a5\u7684\uff09\uff0c\u4e0d\u8fc7\u4ee5\u4e0a\u90fd\u53ea\u662f\u521b\u5efa\u5bf9\u8c61\uff0c\u5e76\u4e0d\u4f1a\u771f\u6b63\u548c\u670d\u52a1\u53bb\u5efa\u7acb Socket \u8fde\u63a5\uff0c\u6240\u4ee5\u5728\u751f\u6210 TripleInvoker \u5bf9\u8c61\u8fc7\u7a0b\u4e2d\u4e0d\u4f1a\u771f\u6b63\u53bb\u521b\u5efa Socket \u8fde\u63a5\uff0c\u90a3\u4ec0\u4e48\u65f6\u5019\u521b\u5efa\u7684\u5462\uff1f<\/p>\n<p>\u5f53\u6211\u4eec\u5728\u670d\u52a1\u6d88\u8d39\u7aef\u6267\u884c\u4ee5\u4e0b\u4ee3\u7801\u65f6\uff1a<code>demoService.sayHello(&quot;habit&quot;)<\/code><\/p>\n<p>demoService \u662f\u4e00\u4e2a\u4ee3\u7406\u5bf9\u8c61\uff0c\u5728\u6267\u884c\u65b9\u6cd5\u7684\u8fc7\u7a0b\u4e2d\uff0c\u6700\u7ec8\u4f1a\u8c03\u7528 TripleInvoker \u7684 doInvoke() \u65b9\u6cd5\uff0c\u5728 doInvoke() \u65b9\u6cd5\u4e2d\uff0c\u4f1a\u5229\u7528 Connection \u5bf9\u8c61\u6765\u5224\u65adSocket \u8fde\u63a5\u662f\u5426\u53ef\u7528\uff0c\u5982\u679c\u4e0d\u53ef\u7528\u5e76\u4e14\u6ca1\u6709\u521d\u59cb\u5316\uff0c\u90a3\u5c31\u4f1a\u521b\u5efa Socket \u8fde\u63a5\u3002<\/p>\n<p>\u4e00\u4e2a Connection \u5bf9\u8c61\u5c31\u8868\u793a\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u5728 TripleInvoker \u5bf9\u8c61\u4e2d\u4e5f\u53ea\u6709\u4e00\u4e2a Connection \u5bf9\u8c61\uff0c\u4e5f\u5c31\u662f\u4e00\u4e2a TripleInvoker \u5bf9\u8c61\u53ea\u5bf9\u5e94\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u8fd9\u4e2a\u548c DubboInvoker \u4e0d\u592a\u4e00\u6837\uff0c\u4e00\u4e2a DubboInvoker \u4e2d\u53ef\u4ee5\u6709\u591a\u4e2a ExchangeClient\uff0c\u6bcf\u4e2a ExchangeClient \u90fd\u4f1a\u4e0e\u670d\u52a1\u7aef\u521b\u5efa\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u6240\u4ee5\u4e00\u4e2aDubboInvoker \u53ef\u4ee5\u5bf9\u5e94\u591a\u4e2a Socket \u8fde\u63a5\uff0c\u5f53\u7136\u591a\u4e2a Socket \u8fde\u63a5\u7684\u76ee\u7684\u5c31\u662f\u63d0\u9ad8\u5e76\u53d1\uff0c\u4e0d\u8fc7\u5728 TripleInvoker \u5bf9\u8c61\u4e2d\u5c31\u4e0d\u9700\u8981\u8fd9\u4e48\u6765\u8bbe\u8ba1\u4e86\uff0c\u56e0\u4e3a\u53ef\u4ee5 Stream\u673a\u5236\u6765\u63d0\u9ad8\u5e76\u53d1\u3002<\/p>\n<p>\u4ee5\u4e0a\uff0c\u6211\u4eec\u77e5\u9053\u4e86\uff0c\u5f53\u6211\u4eec\u5229\u7528\u670d\u52a1\u63a5\u53e3\u7684\u4ee3\u7406\u5bf9\u8c61\u6267\u884c\u65b9\u6cd5\u65f6\u5c31\u4f1a\u521b\u5efa\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u5c31\u7b97\u8fd9\u4e2a\u4ee3\u7406\u5bf9\u8c61\u518d\u6b21\u6267\u884c\u65b9\u6cd5\u65f6\u4e5f\u4e0d\u4f1a\u518d\u6b21\u521b\u5efa Socket \u8fde\u63a5\u4e86\uff0c\u503c\u5f97\u6ce8\u610f\u7684\u662f\uff0c\u6709\u53ef\u80fd\u4e24\u4e2a\u670d\u52a1\u63a5\u53e3\u5bf9\u5e94\u7684\u662f\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u4e3e\u4e2a\u4f8b\u5b50\u3002<\/p>\n<p>\u6bd4\u5982\u670d\u52a1\u63d0\u4f9b\u8005\u5e94\u7528 A\uff0c\u63d0\u4f9b\u4e86 DemoService \u548c HelloService \u4e24\u4e2a\u670d\u52a1\uff0c\u670d\u52a1\u6d88\u8d39\u8005\u5e94\u7528 B \u5f15\u5165\u4e86\u8fd9\u4e24\u4e2a\u670d\u52a1\uff0c\u90a3\u4e48\u5728\u670d\u52a1\u6d88\u8d39\u8005\u8fd9\u7aef\uff0c\u8fd9\u4e2a\u4e24\u4e2a\u63a5\u53e3\u5bf9\u5e94\u7684\u4ee3\u7406\u5bf9\u8c61\u5bf9\u5e94\u7684 TripleInvoker \u662f\u4e0d\u540c\u7684\u4e24\u4e2a\uff0c\u4f46\u662f\u8fd9\u4e24\u4e2a TripleInvoker \u4f1a\u516c\u7528\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u56e0\u4e3a ConnectionManager \u5728\u521b\u5efa Connection \u5bf9\u8c61\u65f6\u4f1a\u6839\u636e\u670d\u52a1 URL \u7684 address \u8fdb\u884c\u7f13\u5b58\uff0c\u540e\u7eed\u8fd9\u4e24\u4e2a\u4ee3\u7406\u5bf9\u8c61\u5728\u6267\u884c\u65b9\u6cd5\u65f6\u4f7f\u7528\u7684\u5c31\u662f\u540c\u4e00\u4e2a Socket \u8fde\u63a5\uff0c\u4f46\u662f\u662f\u4e0d\u540c\u7684 Stream\u3002<\/p>\n<p>Socket \u8fde\u63a5\u521b\u5efa\u597d\u4e4b\u540e\uff0c\u5c31\u9700\u8981\u53d1\u9001 Invocation \u5bf9\u8c61\u7ed9\u670d\u52a1\u63d0\u4f9b\u8005\u4e86\uff0c\u56e0\u4e3a\u662f\u57fa\u4e8e\u7684 HTTP2\uff0c\u6240\u4ee5\u8981\u5148\u521b\u5efa\u4e00\u4e2a Stream\uff0c\u7136\u540e\u518d\u901a\u8fc7 Stream \u6765\u53d1\u9001\u6570\u636e\u3002<\/p>\n<p>TripleInvoker \u4e2d\u7528\u7684\u662f Netty\uff0c\u6240\u4ee5\u6700\u7ec8\u4f1a\u5229\u7528 Netty \u6765\u521b\u5efa Stream\uff0c\u5bf9\u5e94\u7684\u5bf9\u8c61\u4e3a Http2StreamChannel\uff0c\u6d88\u8d39\u7aef\u7684 TripleInvoker \u6700\u7ec8\u4f1a\u5229\u7528Http2StreamChannel \u6765\u53d1\u9001\u548c\u63a5\u6536\u6570\u636e\u5e27\uff0c\u6570\u636e\u5e27\u5bf9\u5e94\u7684\u5bf9\u8c61\u4e3a Http2Frame\uff0c\u5b83\u53c8\u5206\u4e3a Http2DataFrame\u3001Http2HeadersFrame \u7b49\u5177\u4f53\u7c7b\u578b\u3002<\/p>\n<p>\u6b63\u5e38\u60c5\u51b5\u4e0b\uff0c\u4f1a\u6bcf\u751f\u6210\u4e00\u4e2a\u6570\u636e\u5e27\u5c31\u4f1a\u901a\u8fc7 Http2StreamChannel \u53d1\u9001\u51fa\u53bb\uff0c\u4f46\u662f\u5728 Triple \u4e2d\u6709\u4e00\u4e2a\u5c0f\u5c0f\u7684\u4f18\u5316\uff0c\u4f1a\u6709\u4e00\u4e2a\u6279\u91cf\u53d1\u9001\u7684\u601d\u60f3\uff0c\u5f53\u8981\u53d1\u9001\u4e00\u4e2a\u6570\u636e\u5e27\u65f6\uff0c\u4f1a\u5148\u628a\u6570\u636e\u5e27\u653e\u5165\u4e00\u4e2a WriteQueue \u4e2d\uff0c\u7136\u540e\u4f1a\u4ece\u7ebf\u7a0b\u6c60\u4e2d\u62ff\u5230\u4e00\u4e2a\u7ebf\u7a0b\u8c03\u7528 WriteQueue \u7684 flush \u65b9\u6cd5\uff0c\u8be5\u65b9\u6cd5\u7684\u5b9e\u73b0\u4e3a\uff1a<\/p>\n<pre><code>private void flush() {\n        try {\n            QueuedCommand cmd;\n            int i = 0;\n            boolean flushedOnce = false;\n            \/\/ \u53ea\u8981\u961f\u5217\u4e2d\u6709\u5143\u7d20\u5c31\u53d6\u51fa\u6765\uff0c\u6ca1\u6709\u5219\u9000\u51fawhile\n            while ((cmd = queue.poll()) != null) {\n                \/\/ \u628a\u6570\u636e\u5e27\u6dfb\u52a0\u5230Http2StreamChannel\u4e2d\uff0c\u6dfb\u52a0\u5e76\u4e0d\u4f1a\u7acb\u9a6c\u53d1\u9001\uff0c\u8c03\u7528\u4e86flush\u624d\u53d1\u9001\n                cmd.run(channel);\n                i++;\n\n                \/\/ DEQUE_CHUNK_SIZE=128\n                \/\/ \u8fde\u7eed\u4ece\u961f\u5217\u4e2d\u53d6\u5230\u4e86128\u4e2a\u6570\u636e\u5e27\u5c31flush\u4e00\u6b21\n                if (i == DEQUE_CHUNK_SIZE) {\n                    i = 0;\n                    channel.flush();\n                    flushedOnce = true;\n                }\n            }\n\n            \/\/ i != 0 \u8868\u793a\u4ece\u961f\u5217\u4e2d\u53d6\u5230\u4e86\u6570\u636e\u4f46\u662f\u6ca1\u6ee1128\u4e2a\n            \/\/ \u5982\u679ci=0\uff0cflushedOnce=false\u4e5fflush\u4e00\u6b21\n            if (i != 0 || !flushedOnce) {\n                channel.flush();\n            }\n        } finally {\n            scheduled.set(false);\n\n            \/\/ \u5982\u679c\u961f\u5217\u4e2d\u53c8\u6709\u6570\u636e\u4e86\uff0c\u5219\u7ee7\u7eed\u4f1a\u9012\u5f52\u8c03\u7528flush\n            if (!queue.isEmpty()) {\n                scheduleFlush();\n            }\n        }\n    }\n<\/code><\/pre>\n<p>\u603b\u4f53\u601d\u60f3\u662f\uff0c\u53ea\u8981\u5411 WriteQueue \u4e2d\u6dfb\u52a0\u4e00\u4e2a\u6570\u636e\u5e27\u4e4b\u540e\uff0c\u90a3\u5c31\u4f1a\u5c1d\u8bd5\u5f00\u542f\u4e00\u4e2a\u7ebf\u7a0b\uff0c\u8981\u4e0d\u8981\u5f00\u542f\u7ebf\u7a0b\u8981\u770b CAS\uff0c\u6bd4\u5982\u73b0\u5728\u6709 10 \u4e2a\u7ebf\u7a0b\u540c\u65f6\u5411 WriteQueue \u4e2d\u6dfb\u52a0\u4e86\u4e00\u4e2a\u6570\u636e\u5e27\uff0c\u90a3\u4e48\u8fd9 10 \u4e2a\u7ebf\u7a0b\u4e2d\u7684\u67d0\u4e00\u4e2a\u4f1a CAS \u6210\u529f\uff0c\u5176\u4ed6\u4f1a CAS \u5931\u8d25\uff0c\u90a3\u4e48\u6b64\u65f6 CAS \u6210\u529f\u7684\u7ebf\u7a0b\u4f1a\u8d1f\u8d23\u4ece\u7ebf\u7a0b\u6c60\u4e2d\u83b7\u53d6\u53e6\u5916\u4e00\u4e2a\u7ebf\u7a0b\u6267\u884c\u4e0a\u9762\u7684 flush \u65b9\u6cd5\uff0c\u4ece\u800c\u83b7\u53d6 WriteQueue \u4e2d\u7684\u6570\u636e\u5e27\u7136\u540e\u53d1\u9001\u51fa\u53bb\u3002<\/p>\n<p>\u6709\u4e86\u5e95\u5c42\u8fd9\u5957\u8bbe\u8ba1\u4e4b\u540e\uff0c\u5bf9\u4e8e TripleInvoker \u800c \uff0c\u5b83\u53ea\u9700\u8981\u628a\u8981\u53d1\u9001\u7684\u6570\u636e\u5c01\u88c5\u4e3a\u6570\u636e\u5e27\uff0c\u7136\u540e\u6dfb\u52a0\u5230 WriteQueue \u4e2d\u5c31\u53ef\u4ee5\u4e86\u3002<\/p>\n<p>\u5728 TripleInvoker \u7684 doInvoke() \u6e90\u7801\u4e2d\uff0c\u5728\u521b\u5efa\u5b8c\u6210 Socket \u8fde\u63a5\u540e\uff0c\u5c31\u4f1a\uff1a<\/p>\n<p>1.\u57fa\u4e8e Socket \u8fde\u63a5\u5148\u6784\u9020\u4e00\u4e2a ClientCall \u5bf9\u8c61<\/p>\n<p>2.\u6839\u636e\u5f53\u524d\u8c03\u7528\u7684\u65b9\u6cd5\u4fe1\u606f\u6784\u9020\u4e00\u4e2a RequestMetadata \u5bf9\u8c61\uff0c\u8fd9\u4e2a\u5bf9\u8c61\u8868\u793a\uff0c\u5f53\u524d\u8c03\u7528\u7684\u662f\u54ea\u4e2a\u63a5\u53e3\u7684\u54ea\u4e2a\u65b9\u6cd5\uff0c\u5e76\u4e14\u8bb0\u5f55\u4e86\u6240\u914d\u7f6e\u7684\u5e8f\u5217\u5316\u65b9\u5f0f\uff0c\u538b\u7f29\u65b9\u5f0f\uff0c\u8d85\u65f6\u65f6\u95f4\u7b49<\/p>\n<p>3.\u7d27\u63a5\u7740\u6784\u9020\u4e00\u4e2a ClientCall.Listener\uff0c\u8fd9\u4e2a Listener \u662f\u7528\u6765\u5904\u7406\u54cd\u5e94\u7ed3\u679c\u7684\uff0c\u9488\u5bf9\u4e0d\u540c\u7684\u6d41\u5f0f\u8c03\u7528\u7c7b\u578b\uff0c\u4f1a\u6784\u9020\u51fa\u4e0d\u540c\u7684 ClientCall.Listener\uff1aUNARY\uff1a\u4f1a\u6784\u9020\u51fa\u4e00\u4e2a UnaryClientCallListener\uff0c\u5185\u90e8\u5305\u542b\u4e86\u4e00\u4e2a DeadlineFuture\uff0cDeadlineFuture \u662f\u7528\u6765\u63a7\u5236 timeout \u7684SERVER\/_STREAM\uff1a\u4f1a\u6784\u9020\u51fa\u4e00\u4e2a ObserverToClientCallListenerAdapter\uff0c\u5185\u90e8\u5305\u542b\u4e86\u8c03\u7528\u65b9\u6cd5\u65f6\u4f20\u5165\u8fdb\u6765\u7684 StreamObserver \u5bf9\u8c61\uff0c\u6700\u7ec8\u5c31\u662f\u7531\u8fd9\u4e2aStreamObserver \u5bf9\u8c61\u6765\u5904\u7406\u54cd\u5e94\u7ed3\u679c\u7684BI\/_STREAM\uff1a\u548c SERVER\/_STREAM \u4e00\u6837\uff0c\u4e5f\u4f1a\u6784\u9020\u51fa\u6765\u4e00\u4e2a ObserverToClientCallListenerAdapter<\/p>\n<p>4.\u7d27\u7740\u7740\uff0c\u5c31\u4f1a\u8c03\u7528 ClientCall \u5bf9\u8c61\u7684 start \u65b9\u6cd5\u521b\u5efa\u4e00\u4e2a Stream\uff0c\u5e76\u4e14\u8fd4\u56de\u4e00\u4e2a StreamObserver \u5bf9\u8c61<\/p>\n<p>5.\u5f97\u5230\u4e86 StreamObserver \u5bf9\u8c61\u540e\uff0c\u4f1a\u6839\u636e\u4e0d\u540c\u7684\u6d41\u5f0f\u8c03\u7528\u7c7b\u578b\u6765\u4f7f\u7528\u8fd9\u4e2a StreamObserver \u5bf9\u8c61UNARY\uff1a\u76f4\u63a5\u8c03\u7528 StreamObserver \u5bf9\u8c61\u7684 onNext() \u65b9\u6cd5\u6765\u53d1\u9001\u65b9\u6cd5\u53c2\u6570\uff0c\u7136\u540e\u8c03\u7528 onCompleted \u65b9\u6cd5\uff0c\u7136\u540e\u8fd4\u56de\u4e00\u4e2a new AsyncRpcResult(future, invocation)\uff0cfuture \u5c31\u662f DeadlineFuture\uff0c\u540e\u7eed\u4f1a\u901a\u8fc7 DeadlineFuture \u540c\u6b65\u7b49\u5f85\u54cd\u5e94\u7ed3\u679c\u7684\u5230\u6765\uff0c\u5e76\u6700\u7ec8\u628a\u83b7\u53d6\u5230\u7684\u54cd\u5e94\u7ed3\u679c\u8fd4\u56de\u7ed9\u4e1a\u52a1\u65b9\u6cd5\u3002SERVER\/_STREAM\uff1a\u76f4\u63a5\u8c03\u7528 StreamObserver \u5bf9\u8c61\u7684 onNext() \u65b9\u6cd5\u6765\u53d1\u9001\u65b9\u6cd5\u53c2\u6570\uff0c\u7136\u540e\u8c03\u7528 onCompleted \u65b9\u6cd5\uff0c\u7136\u540e\u8fd4\u56de\u4e00\u4e2a new AsyncRpcResult(CompletableFuture.completedFuture(new AppResponse()), invocation)\uff0c\u540e\u7eed\u4e0d\u4f1a\u540c\u6b65\u4e86\uff0c\u5e76\u4e14\u8fd4\u56de null \u7ed9\u4e1a\u52a1\u65b9\u6cd5\u3002BI\/_STREAM\uff1a\u76f4\u63a5\u8fd4\u56de new AsyncRpcResult( CompletableFuture.completedFuture(new AppResponse(requestObserver)), invocation)\uff0c\u4e5f\u4e0d\u540c\u540c\u6b65\u7b49\u5f85\u54cd\u5e94\u7ed3\u679c\u4e86\uff0c\u800c\u662f\u76f4\u63a5\u628a requestObserver \u5bf9\u8c61\u8fd4\u56de\u7ed9\u4e86\u4e1a\u52a1\u65b9\u6cd5\u3002\u6240\u4ee5\u6211\u4eec\u53ef\u4ee5\u53d1\u73b0\uff0c\u4e0d\u7ba1\u662f\u54ea\u79cd\u6d41\u5f0f\u8c03\u7528\u7c7b\u578b\uff0c\u90fd\u4f1a\u5148\u521b\u5efa\u4e00\u4e2a Stream\uff0c\u5f97\u5230\u5bf9\u5e94\u7684\u4e00\u4e2a StreamObserver \u5bf9\u8c61\uff0c\u7136\u540e\u8c03\u7528 StreamObserver \u5bf9\u8c61\u7684onNext \u65b9\u6cd5\u6765\u53d1\u9001\u6570\u636e\uff0c\u6bd4\u5982\u53d1\u9001\u670d\u52a1\u63a5\u53e3\u65b9\u6cd5\u7684\u5165\u53c2\u503c\uff0c\u6bd4\u5982\u4e00\u4e2a User \u5bf9\u8c61\uff1a\u5728\u53d1\u9001 User \u5bf9\u8c61\u4e4b\u524d\uff0c\u4f1a\u5148\u53d1\u9001\u8bf7\u6c42\u5934\uff0c\u8bf7\u6c42\u5934\u4e2d\u5305\u542b\u4e86\u5f53\u524d\u8c03\u7528\u7684\u662f\u54ea\u4e2a\u63a5\u53e3\u3001\u54ea\u4e2a\u65b9\u6cd5\u3001\u7248\u672c\u53f7\u3001\u5e8f\u5217\u5316\u65b9\u5f0f\u3001\u538b\u7f29\u65b9\u5f0f\u7b49\u4fe1\u606f\uff0c\u6ce8\u610f\u8bf7\u6c42\u5934\u4e2d\u4f1a\u5305\u542b\u4e00\u4e9b gRPC \u76f8\u5173\u7684 key\uff0c\u4e3b\u8981\u5c31\u662f\u4e3a\u4e86\u517c\u5bb9 gRPC\u7136\u540e\u5c31\u662f\u53d1\u9001\u8bf7\u6c42\u4f53\u7136\u540e\u518d\u5bf9 User \u5bf9\u8c61\u8fdb\u884c\u5e8f\u5217\u5316\uff0c\u5f97\u5230\u5b57\u8282\u6570\u7ec4\u7136\u540e\u518d\u538b\u7f29\u5b57\u8282\u6570\u7ec4\u7136\u540e\u628a\u538b\u7f29\u4e4b\u540e\u7684\u5b57\u8282\u6570\u7ec4\u4ee5\u53ca\u662f\u5426\u538b\u7f29\u6807\u8bb0\u751f\u6210\u4e00\u4e2a DataQueueCommand \u5bf9\u8c61\uff0c\u5e76\u4e14\u628a\u8fd9\u4e2a\u5bf9\u8c61\u6dfb\u52a0\u5230 writeQueue \u4e2d\u53bb\uff0c\u7136\u540e\u6267\u884cscheduleFlush()\uff0c\u8be5\u65b9\u6cd5\u5c31\u4f1a\u5f00\u542f\u4e00\u4e2a\u7ebf\u7a0b\u4ece writeQueue \u4e2d\u83b7\u53d6\u6570\u636e\u8fdb\u884c\u53d1\u9001\uff0c\u53d1\u9001\u65f6\u5c31\u4f1a\u89e6\u53d1 DataQueueCommand \u5bf9\u8c61\u7684 doSend \u65b9\u6cd5\u8fdb\u884c\u53d1\u9001\uff0c\u8be5\u65b9\u6cd5\u4e2d\u4f1a\u6784\u9020\u4e00\u4e2a DefaultHttp2DataFrame \u5bf9\u8c61\uff0c\u8be5\u5bf9\u8c61\u4e2d\u7531\u4e24\u4e2a\u5c5e\u6027 endStream\uff0c\u8868\u793a\u662f\u4e0d\u662f Stream \u4e2d\u7684\u6700\u540e\u4e00\u5e27\uff0c\u53e6\u5916\u4e00\u4e2a\u5c5e\u6027\u4e3acontent\uff0c\u8868\u793a\u5e27\u643a\u5e26\u7684\u6838\u5fc3\u6570\u636e\uff0c\u8be5\u6570\u636e\u683c\u5f0f\u4e3a\uff1a\u7b2c\u4e00\u4e2a\u5b57\u8282\u8bb0\u5f55\u8bf7\u6c42\u4f53\u662f\u5426\u88ab\u538b\u7f29\u7d27\u7740\u7684\u56db\u4e2a\u5b57\u8282\u8bb0\u5f55\u5b57\u8282\u6570\u7ec4\u7684\u957f\u5ea6\u540e\u9762\u5c31\u771f\u6b63\u7684\u5b57\u8282\u6570\u636e\u4ee5\u4e0a\u662f TripleInvoker \u53d1\u9001\u6570\u636e\u7684\u6d41\u7a0b\uff0c\u63a5\u4e0b\u6765\u5c31\u662f TripleInvoker \u63a5\u6536\u54cd\u5e94\u6570\u636e\u7684\u6d41\u7a0b\uff0cClientCall.Listener \u5c31\u662f\u7528\u6765\u76d1\u542c\u662f\u5426\u63a5\u6536\u5230\u7684\u54cd\u5e94\u6570\u636e\u7684\uff0c\u4e0d\u540c\u7684\u6d41\u5f0f\u8c03\u7528\u65b9\u5f0f\u4f1a\u5bf9\u5e94\u4e0d\u540c\u7684 ClientCall.Listener\uff1aUNARY\uff1aUnaryClientCallListener\uff0c\u5185\u90e8\u5305\u542b\u4e86\u4e00\u4e2a DeadlineFuture\uff0cDeadlineFuture \u662f\u7528\u6765\u63a7\u5236 timeout \u7684SERVER\/_STREAM\uff1aObserverToClientCallListenerAdapter\uff0c\u5185\u90e8\u5305\u542b\u4e86\u8c03\u7528\u65b9\u6cd5\u65f6\u4f20\u5165\u8fdb\u6765\u7684 StreamObserver \u5bf9\u8c61\uff0c\u6700\u7ec8\u5c31\u662f\u7531\u8fd9\u4e2aStreamObserver \u5bf9\u8c61\u6765\u5904\u7406\u54cd\u5e94\u7ed3\u679c\u7684BI\/_STREAM\uff1a\u548c SERVER\/_STREAM \u4e00\u6837\uff0c\u4e5f\u4f1a\u6784\u9020\u51fa\u6765\u4e00\u4e2a ObserverToClientCallListenerAdapter\u90a3\u73b0\u5728\u8981\u4e86\u89e3\u7684\u5c31\u662f\uff0c\u5982\u4f55\u77e5\u9053\u67d0\u4e2a Stream \u4e2d\u6709\u54cd\u5e94\u6570\u636e\uff0c\u7136\u540e\u89e6\u53d1\u8c03\u7528 ClientCall.Listener \u5bf9\u8c61\u7684\u76f8\u5e94\u7684\u65b9\u6cd5\u3002\u8981\u76d1\u542c\u67d0\u4e2a Stream \u4e2d\u662f\u5426\u6709\u54cd\u5e94\u6570\u636e\uff0c\u8fd9\u4e2a\u80af\u5b9a\u662f Netty \u6765\u505a\u7684\uff0c\u5b9e\u9645\u4e0a\uff0c\u5728\u4e4b\u524d\u521b\u5efa Stream \u65f6\uff0c\u4f1a\u5411 Http2StreamChannel \u7ed1\u5b9a\u4e00\u4e2aTripleHttp2ClientResponseHandler\uff0c\u5f88\u660e\u663e\u8fd9\u4e2a Handler \u5c31\u662f\u7528\u6765\u5904\u7406\u63a5\u6536\u5230\u7684\u54cd\u5e94\u6570\u636e\u7684\u3002\u5728 TripleHttp2ClientResponseHandler \u7684 channelRead0 \u65b9\u6cd5\u4e2d\uff0c\u6bcf\u63a5\u6536\u4e00\u4e2a\u54cd\u5e94\u6570\u636e\u5c31\u4f1a\u5224\u65ad\u662f Http2HeadersFrame \u8fd8\u662f Http2DataFrame\uff0c\u7136\u540e\u8c03\u7528 ClientTransportListener \u4e2d\u5bf9\u5e94\u7684 onHeader \u65b9\u6cd5\u548c onData \u65b9\u6cd5\uff1aonHeader \u65b9\u6cd5\u901a\u8fc7\u5904\u7406\u54cd\u5e94\u5934\uff0c\u4f1a\u751f\u6210\u4e00\u4e2a TriDecoder\uff0c\u5b83\u662f\u7528\u6765\u89e3\u538b\u5e76\u5904\u7406\u54cd\u5e94\u4f53\u7684onData \u65b9\u6cd5\u4f1a\u5229\u7528 TriDecoder \u7684 deframe() \u65b9\u6cd5\u6765\u5904\u7406\u54cd\u5e94\u4f53\u53e6\u5916\u5982\u679c\u670d\u52a1\u63d0\u4f9b\u8005\u90a3\u8fb9\u8c03\u7528\u4e86 onCompleted \u65b9\u6cd5\uff0c\u4f1a\u5411\u5ba2\u6237\u7aef\u54cd\u5e94\u4e00\u4e2a\u8bf7\u6c42\u5934\uff0cendStream \u4e3a true\uff0c\u8868\u793a\u54cd\u5e94\u7ed3\u675f\uff0c\u4e5f\u4f1a\u89e6\u53d1\u6267\u884c onHeader \u65b9\u6cd5\uff0c\u4ece\u800c\u4f1a\u8c03\u7528 TriDecoder \u7684 close() \u65b9\u6cd5.TriDecoder \u7684 deframe() \u65b9\u6cd5\u5728\u5904\u7406\u54cd\u5e94\u4f53\u6570\u636e\u65f6\uff0c\u4f1a\u5206\u4e3a\u4e24\u4e2a\u6b65\u9aa4\uff1a\u5148\u89e3\u6790\u524d 5 \u4e2a\u5b57\u8282\uff0c\u5148\u89e3\u6790\u7b2c 1 \u4e2a\u5b57\u8282\u786e\u5b9a\u8be5\u54cd\u5e94\u4f53\u662f\u5426\u538b\u7f29\u4e86\uff0c\u518d\u89e3\u6790\u540e\u7eed 4 \u4e2a\u5b57\u8282\u786e\u5b9a\u54cd\u5e94\u4f53\u5185\u5bb9\u7684\u5b57\u8282\u957f\u5ea6\u7136\u540e\u518d\u53d6\u51fa\u8be5\u957f\u5ea6\u7684\u5b57\u8282\u4f5c\u4e3a\u54cd\u5e94\u4f53\u6570\u636e\uff0c\u5982\u679c\u538b\u7f29\u4e86\uff0c\u90a3\u5c31\u8fdb\u884c\u89e3\u538b\uff0c\u7136\u540e\u628a\u89e3\u538b\u4e4b\u540e\u7684\u5b57\u8282\u6570\u7ec4\u4f20\u9012\u7ed9 ClientStreamListenerImpl \u7684onMessage() \u65b9\u6cd5\uff0c\u8be5\u65b9\u6cd5\u5c31\u4f1a\u6309\u5bf9\u5e94\u7684\u5e8f\u5217\u5316\u65b9\u5f0f\u8fdb\u884c\u53cd\u5e8f\u5217\u5316\uff0c\u5f97\u5230\u6700\u7ec8\u7684\u5bf9\u8c61\uff0c\u7136\u540e\u518d\u8c03\u7528\u5230\u6700\u7ec8\u7684 UnaryClientCallListener \u6216\u8005ObserverToClientCallListenerAdapter \u7684 onMessage() \u65b9\u6cd5\u3002TriDecoder \u7684 close() \u65b9\u6cd5\u6700\u7ec8\u4e5f\u4f1a\u8c03\u7528\u5230 UnaryClientCallListener \u6216\u8005 ObserverToClientCallListenerAdapter \u7684 close() \u65b9\u6cd5\u3002UnaryClientCallListener\uff0c\u6784\u9020\u5b83\u65f6\u4f20\u9012\u4e86\u4e00\u4e2a DeadlineFuture \u5bf9\u8c61\uff1aonMessage() \u63a5\u6536\u5230\u54cd\u5e94\u7ed3\u679c\u5bf9\u8c61\u540e\uff0c\u4f1a\u628a\u7ed3\u679c\u5bf9\u8c61\u8d4b\u503c\u7ed9 appResponse \u5c5e\u6027onClose() \u4f1a\u53d6\u51fa appResponse \u5c5e\u6027\u8bb0\u5f55\u7684\u7ed3\u679c\u5bf9\u8c61\u6784\u9020\u51fa\u6765\u4e00\u4e2a AppResponse \u5bf9\u8c61\uff0c\u7136\u540e\u8c03\u7528 DeadlineFuture \u7684 received \u65b9\u6cd5\uff0c\u4ece\u800c\u5c06\u65b9\u6cd5\u8c03\u7528\u7ebf\u7a0b\u63a5\u963b\u585e\uff0c\u5e76\u5f97\u5230\u54cd\u5e94\u7ed3\u679c\u5bf9\u8c61\u3002ObserverToClientCallListenerAdapter\uff0c\u6784\u9020\u5b83\u65f6\u4f20\u9012\u4e86\u4e00\u4e2a StreamObserver \u5bf9\u8c61\uff1aonMessage() \u63a5\u6536\u5230\u54cd\u5e94\u7ed3\u679c\u5bf9\u8c61\u540e\uff0c\u4f1a\u8c03\u7528 StreamObserver \u5bf9\u8c61\u7684 onNext()\uff0c\u5e76\u628a\u7ed3\u679c\u5bf9\u8c61\u4f20\u7ed9 onNext() \u65b9\u6cd5\uff0c\u4ece\u89e6\u53d1\u4e86\u7a0b\u5e8f\u5458\u7684 onNext() \u65b9\u6cd5\u903b\u8f91\u3002onClose() \u5c31\u4f1a\u8c03\u7528 StreamObserver \u5bf9\u8c61\u7684 onCompleted()\uff0c\u6216\u8005\u8c03\u7528 onError() \u65b9\u6cd5<\/p>\n<h3>Triple \u8bf7\u6c42\u5904\u7406\u548c\u54cd\u5e94\u7ed3\u679c\u53d1\u9001<\/h3>\n<p>\u5176\u5b9e\u8fd9\u90e8\u5206\u5185\u5bb9\u548c\u53d1\u9001\u8bf7\u6c42\u548c\u5904\u7406\u54cd\u5e94\u662f\u975e\u5e38\u7c7b\u4f3c\u7684\uff0c\u65e0\u975e\u5c31\u662f\u628a\u89c6\u89d2\u4ece\u6d88\u8d39\u7aef\u5207\u6362\u5230\u670d\u52a1\u7aef\uff0c\u524d\u9762\u5206\u6790\u7684\u662f\u6d88\u8d39\u7aef\u53d1\u9001\u548c\u63a5\u6536\u6570\u636e\uff0c\u73b0\u5728\u8981\u5206\u6790\u7684\u662f\u670d\u52a1\u7aef\u63a5\u6536\u548c\u53d1\u9001\u6570\u636e\u3002<\/p>\n<p>\u6d88\u8d39\u7aef\u5728\u521b\u5efa\u4e00\u4e2a Stream \u540e\uff0c\u4f1a\u751f\u6210\u4e00\u4e2a\u5bf9\u5e94\u7684 StreamObserver \u5bf9\u8c61\u7528\u6765\u53d1\u9001\u6570\u636e\u548c\u4e00\u4e2a ClientCall.Listener \u7528\u6765\u63a5\u6536\u54cd\u5e94\u6570\u636e\uff0c\u5bf9\u4e8e\u670d\u52a1\u7aef\u5176\u5b9e\u4e5f\u4e00\u6837\uff0c\u5728\u63a5\u6536\u5230\u6d88\u8d39\u7aef\u521b\u5efa Stream \u7684\u547d\u4ee4\u540e\uff0c\u4e5f\u9700\u8981\u751f\u6210\u4e00\u4e2a\u5bf9\u5e94\u7684 StreamObserver \u5bf9\u8c61\u7528\u6765\u54cd\u5e94\u6570\u636e\u4ee5\u53ca\u4e00\u4e2a ServerCall.Listener \u7528\u6765\u63a5\u6536\u8bf7\u6c42\u6570\u636e\u3002<\/p>\n<p>\u5728\u670d\u52a1\u5bfc\u51fa\u65f6\uff0cTripleProtocol \u7684 export \u65b9\u6cd5\u4e2d\u4f1a\u5f00\u542f\u4e00\u4e2a ServerBootstrap\uff0c\u5e76\u7ed1\u5b9a\u6307\u5b9a\u7684\u7aef\u53e3\uff0c\u5e76\u4e14\u6700\u91cd\u8981\u7684\u662f\uff0cNetty \u4f1a\u8d1f\u8d23\u63a5\u6536\u521b\u5efa Stream \u7684\u4fe1\u606f\uff0c\u4e00\u65e6\u5c31\u6536\u5230\u8fd9\u4e2a\u4fe1\u53f7\uff0c\u5c31\u4f1a\u751f\u6210\u4e00\u4e2a ChannelPipeline\uff0c\u5e76\u7ed9 ChannelPipeline \u7ed1\u5b9a\u4e00\u4e2a TripleHttp2FrameServerHandler\uff0c\u800c\u8fd9\u4e2aTripleHttp2FrameServerHandler \u5c31\u53ef\u4ee5\u7528\u6765\u5904\u7406 Http2HeadersFrame \u548c Http2DataFrame\u3002<\/p>\n<p>\u6bd4\u5982\u5728\u63a5\u6536\u5230\u8bf7\u6c42\u5934\u540e\uff0c\u4f1a\u6784\u9020\u4e00\u4e2a ServerStream \u5bf9\u8c61\uff0c\u8be5\u5bf9\u8c61\u6709\u4e00\u4e2a ServerTransportObserver \u5bf9\u8c61\uff0cServerTransportObserver \u5bf9\u8c61\u5c31\u4f1a\u771f\u6b63\u6765\u5904\u7406\u8bf7\u6c42\u5934\u548c\u8bf7\u6c42\u4f53\uff1a<\/p>\n<p>1.onHeader() \u65b9\u6cd5\uff0c\u7528\u6765\u5904\u7406\u8bf7\u6c42\u5934\u6bd4\u5982\u4ece\u8bf7\u6c42\u5934\u4e2d\u5f97\u5230\u5f53\u524d\u8bf7\u6c42\u8c03\u7528\u7684\u662f\u54ea\u4e2a\u670d\u52a1\u63a5\u53e3\uff0c\u54ea\u4e2a\u65b9\u6cd5\u6784\u9020\u4e00\u4e2a TriDecoder \u5bf9\u8c61\uff0cTriDecoder \u5bf9\u8c61\u7528\u6765\u5904\u7406\u8bf7\u6c42\u4f53\u6784\u9020\u4e00\u4e2a ReflectionServerCall \u5bf9\u8c61\u5e76\u8c03\u7528\u5b83\u7684 doStartCall() \u65b9\u6cd5\uff0c\u4ece\u800c\u751f\u6210\u4e0d\u540c\u7684 ServerCall.ListenerUNARY\uff1aUnaryServerCallListenerSERVER\/_STREAM\uff1aServerStreamServerCallListenerBI\/_STREAM\uff1aBiStreamServerCallListener\u5e76\u4e14\u5728\u6784\u9020\u8fd9\u4e9b ServerCall.Listener \u65f6\u4f1a\u628a ReflectionServerCall \u5bf9\u8c61\u4f20\u5165\u8fdb\u53bb\uff0cReflectionServerCall \u5bf9\u8c61\u53ef\u4ee5\u7528\u6765\u5411\u5ba2\u6237\u7aef\u53d1\u9001\u6570\u636e<\/p>\n<p>2.onData() \u65b9\u6cd5\uff0c\u7528\u6765\u5904\u7406\u8bf7\u6c42\u4f53\uff0c\u8c03\u7528 TriDecoder \u5bf9\u8c61\u7684 deframe \u65b9\u6cd5\u6765\u5904\u7406\u8bf7\u6c42\u4f53\uff0c\u5982\u679c\u662f endStream\uff0c\u90a3\u8fd8\u4f1a\u8c03\u7528 TriDecoder \u5bf9\u8c61\u7684 close \u65b9\u6cd5<\/p>\n<h4>TriDecoder\uff1a<\/h4>\n<p>deframe()\uff1a\u8fd9\u4e2a\u65b9\u6cd5\u7684\u4f5c\u7528\u548c\u5ba2\u6237\u7aef\u65f6\u4e00\u6837\u7684\uff0c\u90fd\u662f\u5148\u89e3\u6790\u8bf7\u6c42\u4f53\u7684\u524d 5 \u4e2a\u5b57\u8282\uff0c\u7136\u540e\u89e3\u538b\u8bf7\u5168\u4f53\uff0c\u7136\u540e\u53cd\u5e8f\u5217\u5316\u5f97\u5230\u8bf7\u6c42\u53c2\u6570\u5bf9\u8c61\uff0c\u7136\u540e\u8c03\u7528\u4e0d\u540c\u7684ServerCall.Listener \u4e2d\u7684 onMessage()<\/p>\n<p>close()\uff1a\u5f53\u5ba2\u6237\u7aef\u8c03\u7528 onCompleted \u65b9\u6cd5\u65f6\uff0c\u5c31\u8868\u793a\u53d1\u9001\u6570\u636e\u5b8c\u6bd5\uff0c\u6b64\u65f6\u4f1a\u53d1\u9001\u4e00\u4e2a DefaultHttp2DataFrame \u5e76\u4e14 endStream \u4e3a true\uff0c\u4ece\u800c\u4f1a\u89e6\u53d1\u670d\u52a1\u7aefTriDecoder \u5bf9\u8c61\u7684 close() \u65b9\u6cd5\uff0c\u4ece\u800c\u8c03\u7528\u4e0d\u540c\u7684 ServerCall.Listener \u4e2d\u7684 onComplete()<\/p>\n<h4>UnaryServerCallListener\uff1a<\/h4>\n<p>1.\u5728\u63a5\u6536\u5230\u8bf7\u6c42\u5934\u65f6\uff0c\u4f1a\u6784\u9020 UnaryServerCallListener \u5bf9\u8c61\uff0c\u6ca1\u4ec0\u4e48\u7279\u6b8a\u7684<\/p>\n<p>2.\u7136\u540e\u63a5\u6536\u5230\u8bf7\u6c42\u4f53\u65f6\uff0c\u8bf7\u6c42\u4f53\u4e2d\u7684\u6570\u636e\u5c31\u662f\u8c03\u7528\u63a5\u53e3\u65b9\u6cd5\u7684\u5165\u53c2\u503c\uff0c\u6bd4\u5982 User \u5bf9\u8c61\uff0c\u90a3\u4e48\u5c31\u4f1a\u8c03\u7528 UnaryServerCallListener \u7684 onMessage() \u65b9\u6cd5\uff0c\u5728\u8fd9\u4e2a\u65b9\u6cd5\u4e2d\u4f1a\u628a User \u5bf9\u8c61\u8bbe\u7f6e\u5230 invocation \u5bf9\u8c61\u4e2d<\/p>\n<p>3.\u5f53\u6d88\u8d39\u7aef\u8c03\u7528 onCompleted() \u65b9\u6cd5\uff0c\u8868\u793a\u8bf7\u6c42\u4f53\u6570\u636e\u53d1\u9001\u5b8c\u6bd5\uff0c\u4ece\u800c\u89e6\u53d1 UnaryServerCallListener \u7684 onComplete() \u65b9\u6cd5\uff0c\u5728\u8be5\u65b9\u6cd5\u4e2d\u4f1a\u8c03\u7528 invoke() \u65b9\u6cd5\uff0c\u4ece\u800c\u6267\u884c\u670d\u52a1\u65b9\u6cd5\uff0c\u5e76\u5f97\u5230\u7ed3\u679c\uff0c\u5f97\u5230\u7ed3\u679c\u540e\uff0c\u4f1a\u8c03\u7528 UnaryServerCallListener \u7684 onReturn() \u65b9\u6cd5\uff0c\u628a\u7ed3\u679c\u901a\u8fc7 responseObserver \u53d1\u9001\u7ed9\u6d88\u8d39\u7aef\uff0c\u5e76\u8c03\u7528 responseObserver \u7684 onCompleted() \u65b9\u6cd5\uff0c\u8868\u793a\u54cd\u5e94\u6570\u636e\u53d1\u9001\u5b8c\u6bd5\uff0cresponseObserver \u662f ReflectionServerCall \u5bf9\u8c61\u7684\u4e00\u4e2a StreamObserver \u9002\u914d\u5bf9\u8c61\uff08ServerCallToObserverAdapter\uff09\u3002<\/p>\n<h4>\u518d\u6765\u770b ServerStreamServerCallListener\uff1a<\/h4>\n<p>1.\u5728\u63a5\u6536\u5230\u8bf7\u6c42\u5934\u65f6\uff0c\u4f1a\u6784\u9020 ServerStreamServerCallListener \u5bf9\u8c61\uff0c\u6ca1\u4ec0\u4e48\u7279\u6b8a\u7684<\/p>\n<p>2.\u7136\u540e\u63a5\u6536\u5230\u8bf7\u6c42\u4f53\u65f6\uff0c\u8bf7\u6c42\u4f53\u4e2d\u7684\u6570\u636e\u5c31\u662f\u8c03\u7528\u63a5\u53e3\u65b9\u6cd5\u7684\u5165\u53c2\u503c\uff0c\u6bd4\u5982 User \u5bf9\u8c61\uff0c\u90a3\u4e48\u5c31\u4f1a\u8c03\u7528 ServerStreamServerCallListener \u7684 onMessage() \u65b9\u6cd5\uff0c\u5728\u8fd9\u4e2a\u65b9\u6cd5\u4e2d\u4f1a\u628a User \u5bf9\u8c61\u4ee5\u53ca responseObserver \u5bf9\u8c61\u8bbe\u7f6e\u5230 invocation \u5bf9\u8c61\u4e2d\uff0c\u8fd9\u662f\u548c UnaryServerCallListener \u4e0d\u540c\u7684\u5730\u65b9\uff0cUnaryServerCallListener \u53ea\u4f1a\u628a User \u5bf9\u8c61\u8bbe\u7f6e\u7ed9 invocation\uff0c\u800c ServerStreamServerCallListener \u8fd8\u4f1a\u628a responseObserver \u5bf9\u8c61\u8bbe\u7f6e\u8fdb\u53bb\uff0c\u56e0\u4e3a\u670d\u52a1 \u7aef\u6d41\u9700\u8981\u8fd9\u4e2a responseObserver \u5bf9\u8c61\uff0c\u670d\u52a1\u65b9\u6cd5\u62ff\u5230\u8fd9\u4e2a\u5bf9\u8c61\u540e\u5c31\u53ef\u4ee5\u81ea\u5df1\u6765\u63a7\u5236\u5982\u4f55\u53d1\u9001\u54cd\u5e94\u4f53\uff0c\u5e76\u4ec0\u4e48\u65f6\u5019\u8c03\u7528 onCompleted() \u65b9\u6cd5\u6765\u8868\u793a\u54cd\u5e94\u4f53\u53d1\u9001\u5b8c\u6bd5\u3002<\/p>\n<p>3.\u5f53\u6d88\u8d39\u7aef\u8c03\u7528 onCompleted() \u65b9\u6cd5\uff0c\u8868\u793a\u8bf7\u6c42\u4f53\u6570\u636e\u53d1\u9001\u5b8c\u6bd5\uff0c\u4ece\u800c\u89e6\u53d1 ServerStreamServerCallListener \u7684 onComplete() \u65b9\u6cd5\uff0c\u5728\u8be5\u65b9\u6cd5\u4e2d\u4f1a\u8c03\u7528invoke() \u65b9\u6cd5\uff0c\u4ece\u800c\u6267\u884c\u670d\u52a1\u65b9\u6cd5\uff0c\u4ece\u800c\u4f1a\u901a\u8fc7 responseObserver \u5bf9\u8c61\u6765\u53d1\u9001\u6570\u636e<\/p>\n<p>4.\u65b9\u6cd5\u6267\u884c\u5b8c\u540e\uff0c\u4ecd\u7136\u4f1a\u8c03\u7528 ServerStreamServerCallListener\u7684onReturn() \u65b9\u6cd5\uff0c\u4f46\u662f\u4e2a\u7a7a\u65b9\u6cd5<\/p>\n<h4>\u518d\u6765\u770b\u6700\u540e\u4e00\u4e2a BiStreamServerCallListener\uff1a<\/h4>\n<p>1.\u5728\u63a5\u6536\u5230\u8bf7\u6c42\u5934\u65f6\uff0c\u4f1a\u6784\u9020 BiStreamServerCallListener \u5bf9\u8c61\uff0c\u8fd9\u91cc\u6bd4\u8f83\u7279\u6b8a\uff0c\u4f1a\u628a responseObserver \u8bbe\u7f6e\u7ed9 invocation \u5e76\u6267\u884c invoke() \u65b9\u6cd5\uff0c\u4ece\u800c\u6267\u884c\u670d\u52a1\u65b9\u6cd5\uff0c\u5e76\u6267\u884c onReturn() \u65b9\u6cd5\uff0conReturn() \u65b9\u6cd5\u4e2d\u4f1a\u628a\u670d\u52a1\u65b9\u6cd5\u7684\u6267\u884c\u7ed3\u679c\uff0c\u4e5f\u662f\u4e00\u4e2a StreamObserver \u5bf9\u8c61\uff0c\u8d4b\u503c\u7ed9 BiStreamServerCallListener \u5bf9\u8c61\u7684requestObserver \u5c5e\u6027\u3002<\/p>\n<p>2.\u8fd9\u6837\uff0c\u5728\u63a5\u6536\u5230\u8bf7\u6c42\u5934\u65f6\uff0c\u670d\u52a1\u65b9\u6cd5\u5c31\u4f1a\u6267\u884c\u4e86\uff0c\u5e76\u4e14\u5f97\u5230\u4e86\u4e00\u4e2a requestObserver\uff0c\u5b83\u662f\u7a0b\u5e8f\u5458\u5b9a\u4e49\u7684\uff0c\u662f\u7528\u6765\u5904\u7406\u8bf7\u6c42\u4f53\u7684\uff0c\u53e6\u5916\u7684 responseObserver\u662f\u7528\u6765\u53d1\u9001\u54cd\u5e94\u4f53\u7684\u3002<\/p>\n<p>3.\u7d27\u63a5\u7740\u5c31\u4f1a\u6536\u5230\u8bf7\u6c42\u4f53\uff0c\u4ece\u800c\u89e6\u53d1 onMessage() \u65b9\u6cd5\uff0c\u8be5\u65b9\u6cd5\u4e2d\u4f1a\u8c03\u7528 requestObserver \u7684 onNext() \u65b9\u6cd5\uff0c\u8fd9\u6837\u5c31\u53ef\u4ee5\u505a\u5230\uff0c\u670d\u52a1\u7aef\u80fd\u5b9e\u65f6\u7684\u63a5\u6536\u5230\u6d88\u8d39\u7aef\u6bcf\u6b21\u6240\u53d1\u9001\u8fc7\u6765\u7684\u6570\u636e\uff0c\u5e76\u4e14\u8fdb\u884c\u5904\u7406\uff0c\u5904\u7406\u8fc7\u7a0b\u4e2d\uff0c\u5982\u679c\u9700\u8981\u54cd\u5e94\u5c31\u53ef\u4ee5\u5229\u7528 responseObserver \u8fdb\u884c\u54cd\u5e94<\/p>\n<p>4.\u4e00\u65e6\u6d88\u8d39\u7aef\u90a3\u8fb9\u8c03\u7528\u4e86 onCompleted() \u65b9\u6cd5\uff0c\u90a3\u4e48\u5c31\u4f1a\u89e6\u53d1 BiStreamServerCallListener \u7684 onComplete \u65b9\u6cd5\uff0c\u8be5\u65b9\u6cd5\u4e2d\u4e5f\u5c31\u662f\u8c03\u7528 requestObserver \u7684onCompleted()\uff0c\u4e3b\u8981\u5c31\u89e6\u53d1\u7a0b\u5e8f\u5458\u81ea\u5df1\u5199\u7684 StreamObserver \u5bf9\u8c61\u4e2d\u7684 onCompleted()\uff0c\u5e76\u6ca1\u6709\u9488\u5bf9\u5e95\u5c42\u7684 Stream \u505a\u4ec0\u4e48\u4e8b\u60c5\u3002<\/p>\n<h3>\u603b\u7ed3<\/h3>\n<p>\u4e0d\u7ba1\u662f Unary\uff0c\u8fd8\u662f ServerStream\uff0c\u8fd8\u662f BiStream\uff0c\u5e95\u5c42\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u7aef\u4e4b\u524d\u90fd\u53ea\u6709\u4e00\u4e2a Stream\uff0c\u5b83\u4eec\u4e09\u8005\u7684\u533a\u522b\u5728\u4e8e\uff1a<\/p>\n<p>1.Unary\uff1a\u901a\u8fc7\u6d41\uff0c\u5c06\u65b9\u6cd5\u5165\u53c2\u503c\u4f5c\u4e3a\u8bf7\u6c42\u4f53\u53d1\u9001\u51fa\u53bb\uff0c\u800c\u4e14\u53ea\u53d1\u9001\u4e00\u6b21\uff0c\u670d\u52a1\u7aef\u8fd9\u8fb9\u63a5\u6536\u5230\u8bf7\u6c42\u4f53\u4e4b\u540e\uff0c\u4f1a\u6267\u884c\u670d\u52a1\u65b9\u6cd5\uff0c\u5f97\u5230\u7ed3\u679c\uff0c\u628a\u7ed3\u679c\u8fd4\u56de\u7ed9\u5ba2\u6237\u7aef\uff0c\u4e5f\u53ea\u54cd\u5e94\u4e00\u6b21\u3002<\/p>\n<p>2.ServerStream\uff1a\u901a\u8fc7\u6d41\uff0c\u5c06\u65b9\u6cd5\u5165\u53c2\u503c\u4f5c\u4e3a\u8bf7\u6c42\u4f53\u53d1\u9001\u51fa\u53bb\uff0c\u800c\u4e14\u53ea\u53d1\u9001\u4e00\u6b21\uff0c\u670d\u52a1\u7aef\u8fd9\u8fb9\u63a5\u6536\u5230\u8bf7\u6c42\u4f53\u4e4b\u540e\uff0c\u4f1a\u6267\u884c\u670d\u52a1\u65b9\u6cd5\uff0c\u5e76\u4e14\u4f1a\u628a\u5f53\u524d\u6d41\u5bf9\u5e94\u7684StreamObserver \u5bf9\u8c61\u4e5f\u4f20\u7ed9\u670d\u52a1\u65b9\u6cd5\uff0c\u7531\u670d\u52a1\u65b9\u6cd5\u81ea\u5df1\u63a7\u5236\u5982\u4f55\u54cd\u5e94\uff0c\u54cd\u5e94\u51e0\u6b21\uff0c\u54cd\u5e94\u4ec0\u4e48\u6570\u636e\uff0c\u4ec0\u4e48\u65f6\u5019\u54cd\u5e94\u7ed3\u675f\uff0c\u90fd\u7531\u670d\u52a1\u65b9\u6cd5\u81ea\u5df1\u63a7\u5236\u3002<\/p>\n<p>3.BiStream\uff0c\u901a\u8fc7\u6d41\uff0c\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u7aef\uff0c\u90fd\u53ef\u4ee5\u53d1\u9001\u548c\u54cd\u5e94\u591a\u6b21\u3002<\/p>\n<p><a href=\"https:\/\/segmentfault.com\/a\/1190000045438781\">https:\/\/segmentfault.com\/a\/1190000045438781<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u4f5c\u8005\uff1a\u4eac\u4e1c\u7269\u6d41 \u5f20\u58eb\u6b23 \u4e0d\u7ba1\u662f\u670d\u52a1\u5bfc\u51fa\u8fd8\u662f\u670d\u52a1\u5f15\u5165\uff0c\u90fd\u53d1\u751f\u5728\u5e94\u7528\u542f\u52a8\u8fc7\u7a0b\u4e2d\uff0c\u6bd4\u5982\uff1a\u5728\u542f\u52a8\u7c7b\u4e0a\u52a0\u4e0a @Enabl [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[4],"tags":[],"class_list":["post-10020374","post","type-post","status-publish","format-standard","hentry","category-share"],"jetpack_sharing_enabled":true,"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts\/10020374","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=10020374"}],"version-history":[{"count":0,"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts\/10020374\/revisions"}],"wp:attachment":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=10020374"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=10020374"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=10020374"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}