{"id":1926,"date":"2023-04-01T09:49:37","date_gmt":"2023-04-01T01:49:37","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1926"},"modified":"2023-04-22T08:49:19","modified_gmt":"2023-04-22T00:49:19","slug":"dubbo-spring-cloud-service-consumer-development-steps","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/04\/01\/dubbo-spring-cloud-service-consumer-development-steps\/","title":{"rendered":"Dubbo Spring Cloud \u670d\u52a1\u6d88\u8d39\u65b9\u5f00\u53d1\u6b65\u9aa4"},"content":{"rendered":"
\n

\u6ce8\u518c\u4e2d\u5fc3\u91c7\u7528\u963f\u91cc\u5df4\u5df4Nacos<\/p>\n<\/blockquote>\n

\u63a5\u53e3\u5b9a\u4e49<\/h2>\n
public interface UserService {\n\n    boolean save(User user);\n\n    boolean remove(Long userId);\n\n    Collection<User> findAll();\n}<\/code><\/pre>\n
<\/p>\n
public interface RestService {\n\n    String param(String param);\n\n    String params(int a, String b);\n\n    String headers(String header, String header2, Integer param);\n\n    String pathVariables(String path1, String path2, String param);\n\n    String form(String form);\n\n    User requestBodyMap(Map<String, Object> data, String param);\n\n    Map<String, Object> requestBodyUser(User user);\n}<\/code><\/pre>\n
\u4f9d\u8d56\u5f15\u5165<\/h2>\n
<dependencies>\n\n    <dependency>\n        <groupId>org.springframework.boot<\/groupId>\n        <artifactId>spring-boot-starter-web<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.springframework.boot<\/groupId>\n        <artifactId>spring-boot-actuator<\/artifactId>\n    <\/dependency>\n\n    <!-- Spring Cloud Open Feign -->\n    <dependency>\n        <groupId>org.springframework.cloud<\/groupId>\n        <artifactId>spring-cloud-starter-openfeign<\/artifactId>\n    <\/dependency>\n\n    <!-- Spring Retry -->\n    <dependency>\n        <groupId>org.springframework.retry<\/groupId>\n        <artifactId>spring-retry<\/artifactId>\n    <\/dependency>\n\n    <!-- Sample API -->\n    <dependency>\n        <groupId>com.alibaba.cloud<\/groupId>\n        <artifactId>spring-cloud-dubbo-sample-api<\/artifactId>\n        <version>${project.version}<\/version>\n    <\/dependency>\n\n    <!-- Dubbo Spring Cloud Starter -->\n    <dependency>\n        <groupId>com.alibaba.cloud<\/groupId>\n        <artifactId>spring-cloud-starter-dubbo<\/artifactId>\n    <\/dependency>\n\n    <!-- Spring Cloud Nacos Service Discovery -->\n    <dependency>\n        <groupId>com.alibaba.cloud<\/groupId>\n        <artifactId>spring-cloud-starter-alibaba-nacos-discovery<\/artifactId>\n    <\/dependency>\n\n<\/dependencies><\/code><\/pre>\n
\u9879\u76ee\u914d\u7f6e<\/h2>\n
    \n
  • bootstrap.yaml<\/code><\/li>\n<\/ul>\n
    spring:\n  application:\n    name: spring-cloud-alibaba-dubbo-consumer\n  main:\n    allow-bean-definition-overriding: true\n  profiles: nacos\n  cloud:\n    nacos:\n      username: test\n      password: test\n      discovery:\n        enabled: true\n        register-enabled: true\n        server-addr: 192.168.1.5:8848\n        context-path: \/nacos\n        ephemeral: false\n\nribbon:\n  nacos:\n    enabled: true<\/code><\/pre>\n
      \n
    • application.yaml<\/code><\/li>\n<\/ul>\n
      dubbo:\n  cloud:\n    # The subscribed services in consumer side\n    subscribed-services: ${provider.application.name}\n  protocols:\n    dubbo:\n      port: -1\n  consumer:\n    check: false\n\nprovider:\n  application:\n    name: spring-cloud-alibaba-dubbo-provider<\/code><\/pre>\n
      \u6d88\u8d39\u5b9e\u73b0<\/h2>\n
      dubbo\u670d\u52a1\u57fa\u672c\u8c03\u7528<\/h3>\n
      @DubboReference\nprivate UserService userService;\n\n@DubboReference(version = "1.0.0", protocol = "dubbo")\nprivate RestService restService;<\/code><\/pre>\n
      FeignClient<\/h3>\n
        \n
      • \u8d70http\u534f\u8bae<\/li>\n<\/ul>\n
        @FeignClient("${provider.application.name}")\npublic interface FeignRestService {\n    ...\n}<\/code><\/pre>\n
          \n
        • \u8d70dubbo\u534f\u8bae<\/li>\n<\/ul>\n
          @FeignClient("${provider.application.name}")\n@DubboTransported(protocol = "dubbo")\npublic interface DubboFeignRestService {\n    ...\n}<\/code><\/pre>\n
          RestTemplate<\/h3>\n
            \n
          • \u8d70http\u534f\u8bae<\/li>\n<\/ul>\n
            @Bean\n@LoadBalanced\npublic RestTemplate restTemplate() {\n    return new RestTemplate();\n}<\/code><\/pre>\n
              \n
            • \u8d70dubbo\u534f\u8bae<\/li>\n<\/ul>\n
              @Bean\n@LoadBalanced\n@DubboTransported\npublic RestTemplate restTemplate() {\n    return new RestTemplate();\n}<\/code><\/pre>\n
              \u5b8c\u6574\u4ee3\u7801<\/h3>\n
              import com.alibaba.cloud.dubbo.annotation.DubboTransported;\nimport com.alibaba.cloud.dubbo.service.RestService;\nimport com.alibaba.cloud.dubbo.service.User;\nimport com.alibaba.cloud.dubbo.service.UserService;\n\nimport org.apache.dubbo.config.annotation.DubboReference;\n\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.beans.factory.annotation.Value;\nimport org.springframework.boot.ApplicationRunner;\nimport org.springframework.boot.autoconfigure.EnableAutoConfiguration;\nimport org.springframework.boot.builder.SpringApplicationBuilder;\nimport org.springframework.cache.annotation.EnableCaching;\nimport org.springframework.cloud.client.discovery.EnableDiscoveryClient;\nimport org.springframework.cloud.client.loadbalancer.LoadBalanced;\nimport org.springframework.cloud.openfeign.EnableFeignClients;\nimport org.springframework.cloud.openfeign.FeignClient;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.context.annotation.Lazy;\nimport org.springframework.scheduling.annotation.EnableScheduling;\nimport org.springframework.scheduling.annotation.Scheduled;\nimport org.springframework.web.bind.annotation.GetMapping;\nimport org.springframework.web.bind.annotation.PathVariable;\nimport org.springframework.web.bind.annotation.PostMapping;\nimport org.springframework.web.bind.annotation.RequestBody;\nimport org.springframework.web.bind.annotation.RequestHeader;\nimport org.springframework.web.bind.annotation.RequestParam;\nimport org.springframework.web.client.RestTemplate;\n\nimport static org.springframework.http.MediaType.APPLICATION_JSON_UTF8_VALUE;\nimport static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;\n\n\/**\n * Dubbo Spring Cloud Consumer Bootstrap\n *\/\n@EnableDiscoveryClient\n@EnableAutoConfiguration\n@EnableFeignClients\n@EnableScheduling\n@EnableCaching\npublic class DubboSpringCloudConsumerBootstrap {\n\n    @DubboReference\n    private UserService userService;\n\n    @DubboReference(version = "1.0.0", protocol = "dubbo")\n    private RestService restService;\n\n    @Autowired\n    @Lazy\n    private FeignRestService feignRestService;\n\n    @Autowired\n    @Lazy\n    private DubboFeignRestService dubboFeignRestService;\n\n    @Value("${provider.application.name}")\n    private String providerApplicationName;\n\n    @Autowired\n    @LoadBalanced\n    private RestTemplate restTemplate;\n\n    @Bean\n    public ApplicationRunner userServiceRunner() {\n        return arguments -> {\n\n            User user = new User();\n            user.setId(1L);\n            user.setName("\u5c0f\u9a6c\u54e5");\n            user.setAge(33);\n\n            \/\/ save User\n            System.out.printf("UserService.save(%s) : %s\\n", user,\n                    userService.save(user));\n\n            \/\/ find all Users\n            System.out.printf("UserService.findAll() : %s\\n", user,\n                    userService.findAll());\n\n            \/\/ remove User\n            System.out.printf("UserService.remove(%d) : %s\\n", user.getId(),\n                    userService.remove(user.getId()));\n\n        };\n    }\n\n    @Bean\n    public ApplicationRunner callRunner() {\n        return arguments -> {\n            callAll();\n        };\n    }\n\n    private void callAll() {\n\n        \/\/ To call \/path-variables\n        callPathVariables();\n\n        \/\/ To call \/headers\n        callHeaders();\n\n        \/\/ To call \/param\n        callParam();\n\n        \/\/ To call \/params\n        callParams();\n\n        \/\/ To call \/request\/body\/map\n        callRequestBodyMap();\n    }\n\n    @Scheduled(fixedDelay = 10 * 1000L)\n    public void onScheduled() {\n        callAll();\n    }\n\n    private void callPathVariables() {\n        \/\/ Dubbo Service call\n        System.out.println(restService.pathVariables("a", "b", "c"));\n        \/\/ Spring Cloud Open Feign REST Call (Dubbo Transported)\n        System.out.println(dubboFeignRestService.pathVariables("c", "b", "a"));\n        \/\/ Spring Cloud Open Feign REST Call\n        \/\/System.out.println(feignRestService.pathVariables("b", "a", "c"));\n\n        \/\/ RestTemplate call\n        System.out.println(restTemplate.getForEntity(\n                "http:\/\/" + providerApplicationName + "\/\/path-variables\/{p1}\/{p2}?v=c",\n                String.class, "a", "b"));\n    }\n\n    private void callHeaders() {\n        \/\/ Dubbo Service call\n        System.out.println(restService.headers("a", "b", 10));\n        \/\/ Spring Cloud Open Feign REST Call (Dubbo Transported)\n        System.out.println(dubboFeignRestService.headers("b", 10, "a"));\n        \/\/ Spring Cloud Open Feign REST Call\n        \/\/System.out.println(feignRestService.headers("b", "a", 10));\n    }\n\n    private void callParam() {\n        \/\/ Dubbo Service call\n        System.out.println(restService.param("appblog.cn"));\n        \/\/ Spring Cloud Open Feign REST Call (Dubbo Transported)\n        System.out.println(dubboFeignRestService.param("appblog.cn"));\n        \/\/ Spring Cloud Open Feign REST Call\n        \/\/System.out.println(feignRestService.param("appblog.cn"));\n    }\n\n    private void callParams() {\n        \/\/ Dubbo Service call\n        System.out.println(restService.params(1, "1"));\n        \/\/ Spring Cloud Open Feign REST Call (Dubbo Transported)\n        System.out.println(dubboFeignRestService.params("1", 1));\n        \/\/ Spring Cloud Open Feign REST Call\n        \/\/System.out.println(feignRestService.params(1, "1"));\n\n        \/\/ RestTemplate call\n        System.out.println(restTemplate.getForEntity(\n                "http:\/\/" + providerApplicationName + "\/param?param=\u5c0f\u9a6c\u54e5", String.class));\n    }\n\n    private void callRequestBodyMap() {\n\n        Map<String, Object> data = new HashMap<>();\n        data.put("id", 1);\n        data.put("name", "\u5c0f\u9a6c\u54e5");\n        data.put("age", 33);\n\n        \/\/ Dubbo Service call\n        System.out.println(restService.requestBodyMap(data, "Hello,World"));\n        \/\/ Spring Cloud Open Feign REST Call (Dubbo Transported)\n        System.out.println(dubboFeignRestService.requestBody("Hello,World", data));\n        \/\/ Spring Cloud Open Feign REST Call\n        \/\/System.out.println(feignRestService.requestBody("Hello,World", data));\n\n        \/\/ RestTemplate call\n        System.out.println(restTemplate.postForObject(\n                "http:\/\/" + providerApplicationName + "\/request\/body\/map?param=\u5c0f\u9a6c\u54e5", data,\n                User.class));\n    }\n\n    @Bean\n    @LoadBalanced\n    @DubboTransported\n    public RestTemplate restTemplate() {\n        return new RestTemplate();\n    }\n\n    public static void main(String[] args) {\n        new SpringApplicationBuilder(DubboSpringCloudConsumerBootstrap.class)\n                .properties("spring.profiles.active=nacos").run(args);\n    }\n\n    @FeignClient("${provider.application.name}")\n    public interface FeignRestService {\n\n        @GetMapping("\/param")\n        String param(@RequestParam("param") String param);\n\n        @PostMapping("\/params")\n        String params(@RequestParam("a") int a, @RequestParam("b") String b);\n\n        @PostMapping(value = "\/request\/body\/map", produces = APPLICATION_JSON_VALUE)\n        User requestBody(@RequestParam("param") String param,\n                @RequestBody Map<String, Object> data);\n\n        @GetMapping("\/headers")\n        String headers(@RequestHeader("h2") String header2,\n                @RequestHeader("h") String header, @RequestParam("v") Integer value);\n\n        @GetMapping("\/path-variables\/{p1}\/{p2}")\n        String pathVariables(@PathVariable("p2") String path2,\n                @PathVariable("p1") String path1, @RequestParam("v") String param);\n\n    }\n\n    @FeignClient("${provider.application.name}")\n    @DubboTransported(protocol = "dubbo")\n    public interface DubboFeignRestService {\n\n        @GetMapping("\/param")\n        String param(@RequestParam("param") String param);\n\n        @PostMapping("\/params")\n        String params(@RequestParam("b") String paramB, @RequestParam("a") int paramA);\n\n        @PostMapping(value = "\/request\/body\/map", produces = APPLICATION_JSON_UTF8_VALUE)\n        User requestBody(@RequestParam("param") String param,\n                @RequestBody Map<String, Object> data);\n\n        @GetMapping("\/headers")\n        String headers(@RequestHeader("h2") String header2,\n                @RequestParam("v") Integer value, @RequestHeader("h") String header);\n\n        @GetMapping("\/path-variables\/{p1}\/{p2}")\n        String pathVariables(@RequestParam("v") String param,\n                @PathVariable("p2") String path2, @PathVariable("p1") String path1);\n\n    }\n}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
              \u6ce8\u518c\u4e2d\u5fc3\u91c7\u7528\u963f\u91cc\u5df4\u5df4Nacos \u63a5\u53e3\u5b9a\u4e49 public interface UserService { boo […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[196],"tags":[],"class_list":["post-1926","post","type-post","status-publish","format-standard","hentry","category-dubbo"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1926","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=1926"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1926\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1926"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1926"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1926"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}