springboot2 springcloud Greenwich.SR3 构建微服务--3.服务间调用

桃扇骨 2023-10-11 09:59 34阅读 0赞

先闲扯几句 , 其实不想写这么原理, 理论什么的, 因为本系列的博客侧重点在于spring cloud 的使用. 其中的原理也不是我这么点10多篇博文就能写明白的.

后来又浏览了这一系列的博客, 还是加进去了很多的文字性的表述,希望你们能学到一些. 因为我没有时间去打字打那么多的废话.

如果想知道理论, 请直接到最后一篇博文去, 有书目推荐.

看完了上面两个, 就可以做一个eureka的server 和多个注册的应用了. 因为我这是本地开发, 所以只用了一个eureka 作为注册中心.

说到了微服务, 必然会涉及到 , 多个服务之间调用, 可以使用rpc的方式, 或者使用http的方式. 使用rpc的方式,相当于耦合性更强了, 微服务就是为了解耦的存在的, 所以我们不用rpc

以dubbo举例, 作为rpc的典型代表, 在服务启动的时候, 会检查server-cunsomer之间的接口情况. 使用http的方式, 不大容易去检查两边的接口.

其实是使用rpc, 还是使用http 的方式, 完全是由自己的业务方和团队的人员水平决定的.我这里并没有强制.

**规则对于智者是推荐, 对蠢蛋是强制, 如果你足够强, 你完全可以指定一系列的规则, 标准.**

现在我们回退前面已经存在的eureka-server项目, 到第一章的时候的状态. 不做高可用了, 用它作为注册中心,

**新建一个product的springboot项目作为商品库存的服务,spring.application.anem =product-service**

**新建一个order的springboot项目作为订单的服务.spring.application.anem =order-service**

**order 和 product 都需要添加eureka-client 依赖.**

**order项目的配置文件为:**

server.port=8082
    spring.application.name=order-service
    eureka.client.eureka-server-u-r-l-context=http://localhost:8761/eureka
    #数据库的配置
    spring.datasource.username=root
    spring.datasource.password=123
    spring.datasource.url=jdbc:mysql://127.0.0.1:3306/mydb?characterEncoding=utf-8&serverTimezone=UTC
    # 现在已经废弃的驱动类
    # spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

**product项目的配置文件是:**

server.port=8081
    #注册到eureka之后都会编程 product-service
    spring.application.name=product-service
    eureka.client.eureka-server-u-r-l-context=http://localhost:8761/eureka
    #数据库的配置
    spring.datasource.username=root
    spring.datasource.password=123456
    spring.datasource.url=jdbc:mysql://127.0.0.1:3306/mydb?characterEncoding=utf-8&serverTimezone=UTC
    #spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

order 和product 项目都需要再启动类上加注解 :    @EnableEurekaClient   项eureka注册

**现在我们在订单的服务中,需要去调用product服务. 具体使用如下:**

1.在创建订单的时候, 需要去减去产品的库存.

2.在查看订单详情的时候, 需要去下旬产品的详情

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.stereotype.Component;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * @author zk
     * @Description: 已经废弃,现在使用feign进行应用之间的通信
     * @date 2019-09-18 10:44
     */
    @Component
    public class RestTemplateConfig {
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate(){
            RestTemplate template = new RestTemplate();
            return template;
        }
    
    }

@Autowired
        private LoadBalancerClient loadBalancerClient;
        @Autowired
        private RestTemplate restTemplate;
    
    //在方法中进行调用
    
    
    
    //第一种方式
     //耦合性太高了,不大可能知道ip地址,以及端口号, 还有涉及到多个服务的问题
    RestTemplate template = new RestTemplate();
    String object = template.getForObject("http://localhost:8081/hello", String.class);
    System.out.println(object);
    return object
    
            //第二种,利用LoadBalancerClient,利用应用名字获取
            //注册在eureka中的服务名字
    ServiceInstance serviceInstance = loadBalancerClient.choose("PRODUCT-SERVICE");
    String format = String.format("http://%s:%s", serviceInstance.getHost(), serviceInstance.getPort()) + "/hello";
    RestTemplate template = new RestTemplate();
    String object = template.getForObject(format, String.class);
    System.out.println(object);
     return object;
    
            //第三种方式,使用RestTemplateConfig ,利用LoadBalanced 使用名字
    String object = restTemplate.getForObject("http://PRODUCT-SERVICE/hello", String.class);
    System.out.println(object);
    return object;

这是三种通信方式.

现在我们还有第四种使用方式,使用feign进行.

1.在order项目中添加依赖

注意这是springboot2的依赖, artifactId名字改了. 以前srpingboot1是 spring-cloud-starter-feign, 注意了

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>

2.新建一个接口,用于调用

@FeignClient(name = "product-service")   标明这个服务是去调用product的服务

import com.example.common.entity.CartDTO;
    import com.example.product.entity.ProductInfo;
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestBody;
    
    import java.util.List;
    
    /**
     * @author zk
     * @Description:
     * @date 2019-09-18 12:10
     */
    
    /**
     * 调用哪个服务的接口, product的服务
     * 注意了,这里的名字要求是小写的, 如果写成 PRODUCT-SERVICE  会报错, 找不到服务...
     */
    @FeignClient(name = "product-service")
    public interface ProductList {
    
        /**
         * 请求的url,下面的方法名可以随意
         * @return
         */
        @GetMapping("/hello")
        String productMessage();
    
    
        /**
         * 这里的PostMapping 和 product中的/product/listForOrder 的postmapping 相互对应
         * @param productList
         * @return
         */
        @PostMapping("/product/listForOrder")
        List<ProductInfo> listForOrder(List<String> productList);
    
    
        /**
         * 扣库存
         * @param list
         */
        @PostMapping("/product/descProductStock")
        void descProductStock(@RequestBody List<CartDTO> list);
    
    
    }

这里面的GetMapping 和PostMapping 就是我们日常使用的get / post 方法. 是一致的.

这里的访问链接就很重要了, 要求是和product中的controller中的链接是一致的.至于方法名, 随便你自己改了.

调用的时候:

在order项目的启动类上加上注解:

@EnableFeignClients(basePackages = "com.example.product.client")

后面的basePackages 是上面的ProductList.java 所在的包名..

import com.example.common.entity.CartDTO;
    import com.example.product.entity.ProductInfo;
    import com.example.product.client.ProductList;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.List;
    
    /**
     * @author zk
     * @Description:
     * @date 2019-09-18 14:03
     */
    @RestController
    public class ClientController {
    
        @Autowired(required = false)
        private ProductList productList;
    
    
        @GetMapping("getProductMsg")
        public String getProductMsg(){
            String message = productList.productMessage();
            System.out.println(message);
            return message;
        }
    
    
    }

这样就可以实现服务的调用了, 之所以加上

(required = false)  是因为IDEA的提示, 说没有实现. 所以加上 , 免得看到心烦.

这样就可以调用了.

自己写个单元测试, 调用整个过程实施

整个代码地址是:

[https://github.com/changhe626/micro-service][https_github.com_changhe626_micro-service]

Java Framework,欢迎各位前来交流java相关  
QQ群:965125360

[https_github.com_changhe626_micro-service]: https://github.com/changhe626/micro-service