zoukankan      html  css  js  c++  java
  • Spring Cloud Alibaba | Dubbo Spring Cloud 之 HTTP 实战

    上一篇文章《Spring Cloud Alibaba | Dubbo 与 Spring Cloud 完美结合》我们介绍了Dubbo Spring Cloud的基本使用,使用的服务中心为Spring Cloud Alibaba提供的Nacos,Dubbo内部提供了基于Dubbo的RPC调用,同时,Dubbo Spring Cloud在整合了Spring Cloud之后,可以直接提供HTTP接口,同Spring Cloud无缝衔接,直接支持Feign、RestTemplate等方式的远程调用,在提供HTTP服务的同时可以提供Dubbo服务。Dubbo Spring Cloud支持HTTP远程调用级大的方便了我们的对接外部系统,无需对Dubbo再做二次封装。

    1. 案例实战

    接下来,我们通过一个简单的案例来介绍一下Dubbo Spring Cloud通过注解的方式是如何同时提供Dubbo服务和HTTP服务的。

    1.1 创建父工程dubbo-spring-cloud-http

    工程依赖pom.xml如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/pom.xml


    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Spring Cloud Nacos Service Discovery -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
    
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
    

    1.2 创建子工程dubbo_provider_web,服务提供方

    工程依赖pom.xml如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/dubbo_provider_web/pom.xml


    <dependencies>
        <!-- API -->
        <dependency>
            <groupId>com.springcloud</groupId>
            <artifactId>dubbo_api</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!-- Dubbo Spring Cloud Starter -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
    </dependencies>
    

    这里引入Dubbo Spring Cloud工具包和Dubbo API依赖包。

    配置文件参考上一节配置,这里不再赘述。

    接口实现类UserServiceI.java如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/dubbo_provider_web/src/main/java/com/springcloud/dubbo_provider_web/service/UserServiceI.java


    @Service(version = "1.0.0")
    @RestController
    @Slf4j
    public class UserServiceI implements UserService {
    
        private Map<Long, UserModel> usersRepository = Maps.newHashMap();
    
        @Override
        @PostMapping("/save")
        public UserModel save(@RequestBody UserModel user) {
            return usersRepository.put(user.getId(), user);
        }
    
        @Override
        @DeleteMapping("/remove")
        public void remove(@RequestParam("id") Long userId) {
            usersRepository.remove(userId);
        }
    
        @Override
        @GetMapping("/findAll")
        public Collection<UserModel> findAll() {
            return usersRepository.values();
        }
    }
    
    • @Service注解有很多有关服务的配置属性,这里使用 version 定义当前接口版本,此处版本仅在 Dubbo 调用时生效, HTTP 调用无效,更多相关配置可以参考源码org.apache.dubbo.config.annotation.Service

    1.3 创建子工程 spring_cloud_consumer , web 服务消费方

    工程依赖pom.xml如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/spring_cloud_consumer/pom.xml


    <dependencies>
        <!-- API -->
        <dependency>
            <groupId>com.springcloud</groupId>
            <artifactId>dubbo_api</artifactId>
            <version>${project.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>
    

    配置文件application.yml如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/spring_cloud_consumer/src/main/resources/application.yml


    server:
    port: 8080
    spring:
    application:
        name: spring-cloud-consumer-server
    cloud:
        nacos:
        discovery:
            server-addr: 192.168.44.129:8848
    

    接口测试类UserController.java如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/spring_cloud_consumer/src/main/java/com/springcloud/spring_cloud_consumer/controller/UserController.java


    @RestController
    public class UserController {
    
        @Autowired
        UserRemote userRemote;
    
        @Autowired
        RestTemplate restTemplate;
    
        @PostMapping("/saveByFeign")
        public UserModel saveByFeign(@RequestBody UserModel user) {
            return userRemote.save(user);
        }
    
        @DeleteMapping("/removeByFeign")
        public void removeByFeign(@RequestParam("id") Long userId) {
            userRemote.remove(userId);
        }
    
        @GetMapping("/findAllByFeign")
        public Collection<UserModel> findAllByFeign() {
            return userRemote.findAll();
        }
    
        @PostMapping("/saveByRestTemplate")
        public UserModel saveByRestTemplate(@RequestBody UserModel user) {
            return restTemplate.postForObject("http://dubbo-spring-cloud-provider-web/save/", user, UserModel.class);
        }
    
        @DeleteMapping("/removeByRestTemplate")
        public void removeByRestTemplate(@RequestParam("id") Long userId) {
            restTemplate.delete("http://dubbo-spring-cloud-provider-web/remove?id=" + userId);
        }
    
        @GetMapping("/findAllByRestTemplate")
        public Collection<UserModel> findAllByRestTemplate() {
            return restTemplate.getForObject("http://dubbo-spring-cloud-provider-web/findAll/", Collection.class);
        }
    }
    

    共计三个测试接口,这里提供两种测试方式,一种是通过Feign调用,另一种是通过RestTemplate调用。

    SpringCloudConsumerApplication.java如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/spring_cloud_consumer/src/main/java/com/springcloud/spring_cloud_consumer/SpringCloudConsumerApplication.java


    @SpringBootApplication
    @EnableFeignClients
    @EnableDiscoveryClient
    public class SpringCloudConsumerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(SpringCloudConsumerApplication.class, args);
        }
    
        @LoadBalanced
        @Bean
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }
    

    使用@EnableFeignClients开启Feign功能,将RestTemplate以Bean的形式注入Spring中。

    1.4 创建子工程dubbo_consumer作为Dubbo服务的消费方

    接口测试类UserController.java如下:

    代码清单:Alibaba/dubbo-spring-cloud-http/dubbo_consumer/src/main/java/com/springcloud/dubbo_consumer/controller/UserController.java


    @RestController
    public class UserController {
    
        @Reference(version = "1.0.0")
        UserService userService;
    
        @PostMapping("/save")
        public UserModel save(@RequestBody UserModel user) {
            return userService.save(user);
        }
    
        @DeleteMapping("/remove")
        public void remove(@RequestParam("id") Long userId) {
            userService.remove(userId);
        }
    
        @GetMapping("/findAll")
        public Collection<UserModel> findAll() {
            return userService.findAll();
        }
    }
    

    这里@Reference注解需指明调用服务提供者接口的版本号,如果未指明版本号,将无法调用我们前面的服务提供者的接口。

    2. 测试

    我们使用测试工具PostMan进行测试,顺次启动三个子工程provider_web、spring_cloud_consumer和dubbo_consumer,首先测试组件Feign访问,使用PostMan向:http://localhost:8080/saveByFeign 发送 POST 请求,如图:

    测试链接:http://localhost:8080/findAllByFeign ,如图:

    测试 RestTemplate 访问,如图:

    至此,spring_cloud_consumer测试成功,下面继续测试dubbo_consumer,如图:

    3. 示例代码

    示例代码-Github

    示例代码-Gitee

    4. 参考

    Dubbo Spring Cloud 官方文档

  • 相关阅读:
    [原创] 如何在ietester下使用firebug
    Undeclared identifier: 'XXXX'
    图解SQL多表关联查询
    如何去掉Delphi自动生成的~.pas等临时文件
    DataSetProvider的Option属性
    DELPHI DATASNAP 2010 入门操作(2)不写一行代码,绿色三层我也行
    Windows下搭建Android开发环境
    Delphi快捷键大全
    DevExpress的TcxDBLookupComboBox使用方法及问题
    SQL的重复记录处理大全
  • 原文地址:https://www.cnblogs.com/babycomeon/p/11553757.html
Copyright © 2011-2022 走看看