Spring Cloud知识点全总结（二）-阿里云开发者社区

下面就简单列一下order-service子项目的代码：

server:
  port: 8080
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/cloud_order?useSSL=false
    username: root
    password: zc20020106
    driver-class-name: com.mysql.cj.jdbc.Driver
mybatis:
  type-aliases-package: com.haiexijun.user.pojo
  configuration:
    map-underscore-to-camel-case: true
logging:
  level:
    com.haiexijun: debug
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS

controller层：

package com.haiexijun.order.web;
import com.haiexijun.order.pojo.Order;
import com.haiexijun.order.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("order")
public class OrderController {
   @Autowired
   private OrderService orderService;
    @GetMapping("{orderId}")
    public Order queryOrderByUserId(@PathVariable("orderId") Long orderId) {
        // 根据id查询订单并返回
        return orderService.queryOrderById(orderId);
    }
}

service层：

package com.haiexijun.order.service;
import com.haiexijun.order.mapper.OrderMapper;
import com.haiexijun.order.pojo.Order;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class OrderService {
    @Autowired
    private OrderMapper orderMapper;
    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        // 4.返回
        return order;
    }
}

pojo和mapper：

package com.haiexijun.order.pojo;
import lombok.Data;
@Data
public class User {
    private Long id;
    private String username;
    private String address;
}

package com.haiexijun.order.pojo;
import lombok.Data;
@Data
public class Order {
    private Long id;
    private Long price;
    private String name;
    private Integer num;
    private Long userId;
    private User user;
}

package com.haiexijun.order.mapper;
import com.haiexijun.order.pojo.Order;
import org.apache.ibatis.annotations.Select;
import org.springframework.stereotype.Repository;
@Repository
public interface OrderMapper {
    @Select("select * from tb_order where id = #{id}")
    Order findById(Long id);
}

我们分别启动这两个项目（一定要都运行起来），分别访问不同的端口，进行数据访问：

到这来，我们就完成了项目的准备工作。同时实现了服务拆分。下一节就来学习如何做远程调用。

3.微服务远程调用

在学习之前先来引出案例需求：

我们要实现根据订单Id查询订单的同时，把订单所属的用户信息一起返回。

现在我们的订单服务还不能做到这一点，而且我们不能直接通过访问用户服务的数据库获得信息，要去访问用户服务获取才对。

但是问题来了，我们以前没有学过从一个服务到另外一个服务的远程调用。下面就来分析一下，如何进行远程调用。

远程调用方式分析：

我们的user服务通过@GetMapping(“/user/{id}”)对外暴露了一个restful的接口，只要我们在浏览器里面输入对应的地址，就可以拿到用户信息。我们的order订单服务如果也能像浏览器一样发起一个http的请求，用户服务也应该返回一个对应的信息给我们。这时候，订单模块再结合本地数据库查询出来的订单信息，就组合出了最终的目标了。

所以我们的问题就变成了如何在Java代码当中发起HTTP请求，如果能发起HTTP请求，就可以调用其他服务的restful接口了。

Spring它提供了一个工具叫做RestTemplate ，这个工具就是Spring提供给我们来发HTTP请求的。我们要使用这个工具，就要先在配置类里面注册，而启动类就是一个配置类。所以我们可以在order-service的OrderApplication中通过@Bean注解注册RestTemplate。

package com.haiexijun.order;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@MapperScan("com.haiexijun.order.mapper")
@SpringBootApplication
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }
    /**
     * 创建RestTemplate，并注入Spring容器
     * @return
     */
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

完成了这一步以后，我们接下来就可以利用它来发HTTP请求了。

所以我们下面要对订单的查询业务进行修改：

package com.haiexijun.order.service;
import com.haiexijun.order.mapper.OrderMapper;
import com.haiexijun.order.pojo.Order;
import com.haiexijun.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
@Service
public class OrderService {
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private RestTemplate restTemplate;
    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        // 2.利用RestTemplate发起HTTP请求，查询用户
        String url="http://localhost:8081/user/"+order.getUserId();
        User user= restTemplate.getForObject(url, User.class);
        // 3.封装user 到 order里面去
        order.setUser(user);
        // 4.返回
        return order;
    }
}

我们重启项目后，下面来运行两条查询订单试试：

到这里，我们就实现了，跨服务的远程调用。

4.服务的提供者与消费者

这一节又是讲解概念的一节，会了解什么是服务的提供者与消费者。

服务提供者：一次业务中，被其他微服务调用的服务就称之为服务的提供者。（提供接口给其他微服务）

服务消费者：一次业务中，调用其他微服务的服务就称之为服务的消费者。（调用其他微服务提供的接口）

我们上一节的案例中，user-service是服务提供者提供者，而order-service是服务消费者。

现在就会引发出一个问题了，现在服务A调用了服务B，而服务B调用了服务C，那服务B是什么角色呢？这时，比相对与A而言是提供者，而相对于C而言是消费者。所以一个服务既可以是提供者，又可以是消费者。

三. Eureka注册中心

在这一节里，我们会聊一聊之前案例里面存在的一些问题，以及Eureka如何解决这些问题，然后会介绍Eureka具体如何去使用。

1.Eureka原理分析

先来回顾一下之前的案例，在之前的案例当中，我们有一个订单服务和用户服务。订单服务需要远程调用我们的用户服务，它采用的方式是发起一次HTTP请求。不过在我们的代码当中，我们是将user-service的IP和端口硬编码在代码当中的。

但这样的写法是存在一定的问题的。比如说我们开发的时候，我们会分开发环境、测试环境和生产环境等等等。每一次环境的变更，可能服务的地址也会发生改变。如果你采用硬编码的方式写死了，难道每一次都要重新修改代码然后编译打包吗？而且，为了应对更高的并发，我们的user服务可能会部署成多实例，形成一个集群，端口和地址可能就不一样了。这时候，我们到底改写谁的地址呢？如果选择其中一个实例，那其他几个的意义岂不是就没有了吗？

所以这里一定不能采用硬编码的方式。那问题也来了，如果我不做硬编码，那这三个服务的地址我该如何去获取呢？而且万一以后又有第四台和第五台呢？如果拿到了他们的地址，我该如何挑选其中一台去使用呢？如果你挑中了一台，你怎么知道这台现在依然是健康的呢？万一它挂了呢？是不是一堆的问题啊？

但是啊，我们的 Eureka是可以解决这些问题的！

Eureka的作用：

在Eureka的结构当中，它分成了2个概念（角色），第一个角色是eureka-server 注册中心，它的作用是记录和管理这些微服务。而第二个角色是我们的服务提供者和服务消费者，但不管是提供者还是消费者，都是微服务，我们把它叫做eureka-client 客户端。

我们的user-service和order-service在启动的时候会做一件事情，它会把自己的信息注册给eureka。注意：是每开一个服务启动时都会注册。eureka会把你的服务信息给记录下来。

那么全都记下来了，所有的服务信息都在注册中心里面了。如果这个时候我们有一个服务想要消费，它不需要自己去记录信息，直接找eureka就好了。如果eureka找到发现有，而且还有3个呢，就会把信息给服务消费者。

服务消费者拿到了服务提供者的信息，发现有三个，这个时候就会用到我们以前学过的负载均衡的知识点，从这三个里面挑一个出来。

那可能会想了，那你调用的这一个会不会是挂了的啊？这肯定不会，因为我们的服务每隔30秒都会向eureka发一次心跳续约，来确认自己的状态。如果哪一天，它不跳了。eureka就会把那个服务移除，服务消费者自然也不会得到挂掉的那个服务。

2.搭建eureka服务

我们来做三件事情，第一就是搭建eureka注册中心，第二步我们会完成服务的注册，把所有的服务都注册到eureka，第三步我们会去做服务发现，会让order-service取拉去服务列表，得到user-service的所有实例，利用负载均衡去挑一个。下面我们就来一步一步完成：

搭建EurekaServer 注册中心

（1）eureka的搭建需要创建一个独立的微服务，所以等一会儿我们会在Spring Cloud父项目下创建一个新的项目（new一个maven的Module），这个子项目名叫eureka-server，然后子项目会引入下面的依赖：

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>

（2）创建启动类，添加@EnableEurekaServer注解

package com.haiexijun.eureka;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class,args);
    }
}

（3）在application.yml配置文件中添加如下的配置（这里最好复制，不然容易出错)：

server:
  port: 10086  # 服务端口
spring:
  application:
    name: eureka-server # 服务的名称
eureka:
  client:
    service-url:  # eureka的地址信息，如果是eureka集群的话，用逗号隔开
      defaultZone: http://127.0.0.1:10086/eureka

下面就可以运行起来了。

dea的功能很强大，我们点击之后会跳转到Eureka的界面,如下图所示：

这个界面的Instances currently registered with Eureka就是注册到Eureka中的实例的列表。上面我们看见了，eureka也注册了自己的实例。

3.服务注册

服务注册只要经过以下两个步骤就够了：

（1）在user-service的pom文件中，引入下面的eureka-client依赖：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

（2）编写user-service的application.yml文件，内容如下：

server:
  port: 8081
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/cloud_user?useSSL=false
    username: root
    password: zc20020106
    driver-class-name: com.mysql.cj.jdbc.Driver
  application: #服务的名称
    name: userservice
mybatis:
  type-aliases-package: com.haiexijun.user.pojo
  configuration:
    map-underscore-to-camel-case: true
logging:
  level:
    com.haiexijun: debug
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS
eureka:
  client:
    service-url:  # eureka的地址
      defaultZone: http://127.0.0.1:10086/eureka

Spring Cloud知识点全总结（二）

3.微服务远程调用

4.服务的提供者与消费者

三. Eureka注册中心

1.Eureka原理分析

2.搭建eureka服务

3.服务注册

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

Spring Cloud知识点全总结（二）

3.微服务远程调用

4.服务的提供者与消费者

三. Eureka注册中心

1.Eureka原理分析

2.搭建eureka服务

3.服务注册

热门文章

最新文章

相关课程

相关电子书

相关实验场景