{"id":1727,"date":"2023-03-26T19:52:58","date_gmt":"2023-03-26T11:52:58","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1727"},"modified":"2023-04-23T21:34:30","modified_gmt":"2023-04-23T13:34:30","slug":"spring-cloud-synchronous-call-asynchronous-call-responsive-call","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/26\/spring-cloud-synchronous-call-asynchronous-call-responsive-call\/","title":{"rendered":"Spring Cloud\u540c\u6b65\u8c03\u7528\u3001\u5f02\u6b65\u8c03\u7528\u3001\u54cd\u5e94\u5f0f\u8c03\u7528"},"content":{"rendered":"

\u540c\u6b65\u8c03\u7528<\/h2>\n
@Configuration\npublic class WebConfig {\n\n    @Bean\n    @LoadBalanced\n    RestTemplate restTemplate(){\n        return new RestTemplate();\n    }\n}<\/code><\/pre>\n
<\/p>\n
@Service\npublic class HelloService {\n    @Autowired\n    RestTemplate restTemplate;\n\n    @HystrixCommand(fallbackMethod = "helloFallBack")\n    public String hello() {\n        return restTemplate.getForEntity("http:\/\/HI-SERVICE\/hello?name=Joe", String.class).getBody();\n    }\n\n    public String helloFallBack() {\n        return "error";\n    }\n}<\/code><\/pre>\n
@RestController\npublic class HelloController {\n\n    @Autowired\n    HelloService helloService;\n\n    @RequestMapping(value = "\/ribbon-hello", method = RequestMethod.GET)\n    public String hello() {\n      return helloService.hello();\n    }\n}<\/code><\/pre>\n
\u5f02\u6b65\u8c03\u7528<\/h2>\n
\u4fee\u6539Service<\/p>\n
@Service\npublic class HelloService {\n    @Autowired\n    RestTemplate restTemplate;\n\n    @HystrixCommand(fallbackMethod = "helloFallBack")\n    public String hello() {\n        return restTemplate.getForEntity("http:\/\/HI-SERVICE\/hello?name=Joe", String.class).getBody();\n    }\n\n    @HystrixCommand(fallbackMethod = "helloFallBack")\n    public Future<String> helloAsync() {\n        return new AsyncResult<String>() {\n            @Override\n            public String invoke() {\n                return restTemplate.getForEntity("http:\/\/HI-SERVICE\/hello?name=Joe", String.class).getBody();\n            }\n        };\n    }\n\n    public String helloFallBack() {\n        return "error";\n    }\n}<\/code><\/pre>\n
\u4fee\u6539Controller<\/p>\n
@RestController\npublic class HelloController {\n\n    @Autowired\n    HelloService helloService;\n\n    @RequestMapping(value = "\/ribbon-hello", method = RequestMethod.GET)\n    public String hello() {\n      return helloService.hello();\n    }\n\n    @RequestMapping(value = "\/ribbon-hello-async", method = RequestMethod.GET)\n    public String helloAsync() throws ExecutionException, InterruptedException {\n        return helloService.helloAsync().get();\n    }\n}<\/code><\/pre>\n
\u54cd\u5e94\u5f0f\u8c03\u7528<\/h2>\n
pom\u6587\u4ef6\u589e\u52a0\u4f9d\u8d56<\/p>\n
<!-- https:\/\/mvnrepository.com\/artifact\/io.reactivex.rxjava2\/rxjava -->\n<dependency>\n    <groupId>io.reactivex.rxjava2<\/groupId>\n    <artifactId>rxjava<\/artifactId>\n    <version>2.2.19<\/version>\n<\/dependency><\/code><\/pre>\n
\u4fee\u6539Service<\/p>\n
@Service\npublic class HelloService {\n    @Autowired\n    RestTemplate restTemplate;\n\n    @HystrixCommand(fallbackMethod = "helloFallBack")\n    public String hello() {\n        return restTemplate.getForEntity("http:\/\/HI-SERVICE\/hello?name=Joe", String.class).getBody();\n    }\n\n    @HystrixCommand(fallbackMethod = "helloFallBack")\n    public Future<String> helloAsync() {\n        return new AsyncResult<String>() {\n            @Override\n            public String invoke() {\n                return restTemplate.getForEntity("http:\/\/HI-SERVICE\/hello?name=Joe", String.class).getBody();\n            }\n        };\n    }\n\n    @HystrixCommand(fallbackMethod = "helloFallBack")\n    public Observable<String> helloResponse() {\n        return Observable.create(new Observable.OnSubscribe<String>() {\n            @Override\n            public void call(Subscriber<? super String> subscriber) {\n                String body = restTemplate.getForEntity("http:\/\/HI-SERVICE\/hello?name=Joe", String.class).getBody();\n                subscriber.onNext(body);\n                subscriber.onCompleted();\n            }\n        });\n    }\n\n    public String helloFallBack() {\n        return "error";\n    }\n}<\/code><\/pre>\n
\u4fee\u6539Controller<\/p>\n
@RequestMapping(value = "\/ribbon-response", method = RequestMethod.GET)\npublic String helloResponse() throws ExecutionException, InterruptedException {\n    helloService.helloConsumerResponse().subscribe(new Subscriber<String>() {\n        @Override\n        public void onCompleted() {\n            System.out.println("\u5b8c\u6210");\n        }\n\n        @Override\n        public void onError(Throwable e) {\n\n        }\n\n        @Override\n        public void onNext(String s) {\n            System.out.println("\u63a5\u6536\u5230\u4e86:"+s);\n        }\n    });\n    return "ok";\n}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
\u540c\u6b65\u8c03\u7528 @Configuration public class WebConfig { @Bean @Loa […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[42],"tags":[433],"class_list":["post-1727","post","type-post","status-publish","format-standard","hentry","category-spring-cloud","tag-433"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1727","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1727"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1727\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1727"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1727"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1727"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}