一、提供者与消费者

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

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

比如我们刚刚的案例中，我们在order-service中调用user-service服务，所以order-service是服务消费者，user-service是服务提供者

注意！提供者和消费者角色是相对的

一个服务可能是提供者，也可能是消费者

二、Eureka注册中心

2.1 服务调用出现的问题

2.1.1 硬编码问题

我们在远程服务调用的时候将红框内的代码硬写在程序中，这样修改非常的不方便

为了应对更多的并发，我们的user服务可能会部署多实例，形成一个集群。

比如下图，我们如果还有8082，8083，那我们的硬编码就没有作用了，不知道改写谁的地址了，所以这里一定不能写成硬编码的形式。

2.1.2如果不是硬编码的形式，那这三个服务我们该怎么去获取呢？

Eureka、nacos均可以解决这个问题

2.1.3服务消费者该如何获取服务提供者的地址信息？

服务提供者启动时向eureka注册自己的信息

eureka保存这些信息

消费者根据服务名称向eureka拉去提供者信息

我们要做的就是根据服务名称向eureka拉去即可

2.1.4如果有多个服务提供者，消费者该如何选择呢？

服务消费者利用负载均衡算法，从服务列表中挑选一个

2.1.5消费者如何得知服务提供者的健康状态呢？

服务提供者会每隔30秒向Eureka Server发送心跳请求，报告健康状态

eureka会更新记录服务列表的信息，心跳不正常会被剔除

消费者就可以拉取到最新的信息

2.2 Eureka的作用

eureka-server服务端：注册中心，记录和管理这些微服务

eureka-client客户端：服务消费者、服务提供者都是微服务，所以都是客户端

对于服务提供者，每一个服务启动时都会把服务信息注册给eureka-server客户端，然后客户端会记录下来user-service名称及端口

如果这个时候有一个人想要消费，那不就不需要自己记录信息，直接在eureka-server中拉去想要的服务信息即可

但是对于上图拉去的信息而言，我们同样的东西有三种配置，我们需要挑一个，这就需要负载均衡的知识了，从三个中挑选一个（比如localhost:8081），之后在由order-service向user-service发起请求

其中我们也不用担心localhost:8081会挂掉，因为我们user-service服务每隔一段时间就会向注册中心发一次请求确认自己的状态，若一段时间没有发送请求，则注册中心就会把user-service剔除，order-service再次拉去时就不会拉取到他，所以不用担心负载均衡选取的地址失效问题

三、Eureka使用

下面进行Eureka使用的三步走：

搭建EurekaServer、将服务注册到Eureka中、

3.1 搭建EurekaServer

3.1.1 配置

新建maven工程，并添加maven坐标

注意，下面的操作都是在创建的maven工程中去实现

3.1.1.1maven坐标

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

这个地方没有指定版本，原因就是在父工程中将版本都管理好了，下图所示便是父工程中的版本管理，在下面的配置管理中，有大量的组件和版本信息，所以我们子工程引入的时候，无需引入任何版本

下面的图示可以更清楚的辨别子工程与父工程的关系

3.1.1.2 在启动类添加@EnableEurekaServer

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class,args);
    }
}

3.1.2编写配置文件

# 配置微服务名称
spring:
  application:
    name: eurekaserver


# eureka自己也是一个微服务，也需要一个名字
# eureka也会将自己注册到eureka上，
#   为了以后eureka集群之间通讯使用，若启动了多个eureka，他们会互相做注册，完成数据的交流
eureka:
  client:
#   eureka地址信息
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka

3.1.3 启动Eureka

直接启动main函数

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class,args);
    }
}

当我们启动之后，ctrl+单机方框内的端口号，直接打开页面，其中红框中的内容最为重要

“Instances currently registered with Eureka”翻译为“当前在Eureka上注册的实例”

那怎么理解这个实例呢？

一个服务每被部署一份，就叫做一个实例。

若部署十个user服务，那就会出现十个实例。

application：服务名称，我们在配置文件中进行配置的

Status：IP和服务端口（由于window的原因，这个地方显示的时计算机名），其中UP代表正常状态，DOWN代表服务挂掉

3.2 将user-service服务注册到eureka中（服务注册）

3.2.1 配置

3.2.1.1 maven坐标

我在导入坐标的时候出现了cannot reconnect ，翻译：不能连接我把idea重启了一下，解决了这个错误，我感觉我的idea有毛病

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

现在的依赖与eureka-server工程的依赖有所不同，这个是eureka的client端（客户端）

3.2.1.2 application.yml文件配置

下面除了微服务的名称与之前eureka-server工程不一样，其他配置和刚刚的是一个样子的

spring:
  application:
    name: userservice

eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka/

3.2.2 启动

启动下面的类即可

@MapperScan("cn.itcast.user.mapper")
@SpringBootApplication
public class UserApplication {
    public static void main(String[] args) {
        SpringApplication.run(UserApplication.class, args);
    }
}

观察下图，确实变成两个实例了

3.3 将order-service服务注册到eureka中（服务注册）

参照3.2 进行

3.4 实现某个服务多个实例

3.4.1 创建多个服务与实例

比如，我们可以将user-service多次启动，模拟实例部署，但为了避免端口冲突，需要修改端口设置：

“-D”代表着参数，“server.port=8082”是配置端口，这个端口覆盖了yaml文件中的配置的端口

之后点击“OK”

启动成功

查看

我们看到确实是两个，这就是服务的列表

服务注册总结

引入eureka-client依赖

在application.yml中配置eureka地址

3.5 服务发现（服务拉取）与负载均衡

依然是在order-service完成服务拉取

服务拉取是基于服务名称获取服务列表，然后再对服务列表做负载均衡

3.5.1 在order-service完成服务拉取

3.5.1.1 之前服务拉取代码

@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请求，获取用户
        //         get请求：getForObject(url路径,返回值类型)
        //                 我们下面的返回值类型不需要JSON，而是需要一个User对象的形式，所以写User.class
        //         post请求：postForObject()
        String url = "http://localhost:8081/user/" + order.getUserId();
        User user = restTemplate.getForObject(url, User.class);

        //3. 封装user到Order中
        order.setUser(user);
        // 4.返回
        return order;
    }
}

@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
public class OrderApplication {

    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }

    @Bean
    public RestTemplate restTemplate(){
        return  new RestTemplate();
    }

}

3.5.1.2 如今服务拉取代码

服务名称代替IP端口

修改OrderService的代码，修改访问的url路径，用服务名代替ip、端口：

String url = "http://userservice/user/" + order.getUserId();

@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请求，获取用户
        //         get请求：getForObject(url路径,返回值类型)
        //                 我们下面的返回值类型不需要JSON，而是需要一个User对象的形式，所以写User.class
        //         post请求：postForObject()
//        String url = "http://localhost:8081/user/" + order.getUserId();
        String url = "http://userservice/user/" + order.getUserId();
        User user = restTemplate.getForObject(url, User.class);

        //3. 封装user到Order中
        order.setUser(user);
        // 4.返回
        return order;
    }
}

在order-service项目的启动类OrderApplication中的RestTemplate添加负载均衡注解：

LoadBalanced就是负载均衡的意思

@Bean
@LoadBalanced
public RestTemplate restTemplate(){   
   return new RestTemplate();
}

3.5.2 发送请求获取数据

发送请求获取数据

端口8080、8081存在日志信息，而8082不存在日志信息

再次发送请求

端口8080、8082会有反应

Eureka注册中心快速入门

一、提供者与消费者

二、Eureka注册中心

2.1 服务调用出现的问题

2.1.1 硬编码问题

2.1.2如果不是硬编码的形式，那这三个服务我们该怎么去获取呢？

2.1.3服务消费者该如何获取服务提供者的地址信息？

2.1.4如果有多个服务提供者，消费者该如何选择呢？

2.1.5消费者如何得知服务提供者的健康状态呢？

2.2 Eureka的作用

三、Eureka使用

3.1 搭建EurekaServer

3.1.1 配置

3.1.1.1maven坐标

3.1.1.2 在启动类添加@EnableEurekaServer

3.1.2编写配置文件

3.1.3 启动Eureka

3.2 将user-service服务注册到eureka中（服务注册）

3.2.1 配置

3.2.1.1 maven坐标

3.2.1.2 application.yml文件配置

3.2.2 启动

3.3 将order-service服务注册到eureka中（服务注册）

3.4 实现某个服务多个实例

3.4.1 创建多个服务与实例

服务注册总结

3.5 服务发现（服务拉取）与负载均衡

3.5.1 在order-service完成服务拉取

3.5.1.1 之前服务拉取代码

3.5.1.2 如今服务拉取代码

3.5.2 发送请求获取数据

3.6 总结

相关推荐

我爱布朗熊的最新文章

随机推荐

回顶部

一、提供者与消费者

二、Eureka注册中心

2.1 服务调用出现的问题

2.1.1 硬编码问题

2.1.2如果不是硬编码的形式，那这三个服务我们该怎么去获取呢？

2.1.3服务消费者该如何获取服务提供者的地址信息？

2.1.4如果有多个服务提供者，消费者该如何选择呢？

2.1.5消费者如何得知服务提供者的健康状态呢？

2.2 Eureka的作用

三、Eureka使用

3.1 搭建EurekaServer

3.1.1 配置

3.1.1.1maven坐标

3.1.1.2 在启动类添加@EnableEurekaServer

3.1.2编写配置文件

3.1.3 启动Eureka

3.2 将user-service服务注册到eureka中 （服务注册）

3.2.1 配置

3.2.1.1 maven坐标

3.2.1.2 application.yml文件配置

3.2.2 启动

3.3 将order-service服务注册到eureka中（服务注册）

3.4 实现某个服务多个实例

3.4.1 创建多个服务与实例

服务注册总结

3.5 服务发现（服务拉取）与负载均衡

3.5.1 在order-service完成服务拉取

3.5.1.1 之前服务拉取代码

3.5.1.2 如今服务拉取代码

3.5.2 发送请求获取数据

3.6 总结

相关推荐

我爱布朗熊 的最新文章

随机推荐

回顶部

3.2 将user-service服务注册到eureka中（服务注册）

我爱布朗熊的最新文章