【SpringCloud基础】快速入门

我就是我 2022-06-07 07:28 229阅读 0赞

# 前言 #

Github：[https://github.com/yihonglei/thinking-in-springcloud][https_github.com_yihonglei_thinking-in-springcloud]

Eureka注册中心：eureka-server

服务提供者（订单服务）：eureka-provider-order

服务消费者（用户服务）：eureka-consumer-user

# 一 服务治理 #

在传统项目中，我们可以通过配置完成服务间的调用。比如，A服务调用B服务完成业务操作，

无论是否采用负载均衡还是客户端负载，我们都需要手动维护服务列表。但是，随着业务的发展，

拆分的服务实例越来越多，服务配置越来越多，手动维护变得十分困难，看着都头大。

为了解决服务维护，产生大量服务治理框架和产品，比如Sprng Cloud，Dubbo等。

这些框架和产品的实现都是围绕注册中心与服务发现机制来完成对微服务应用实例的自动化管理。

服务治理主要有以下两个核心概念。

## 1、服务注册 ##

服务治理框架都会构建一个注册中心，用来供每个服务单元登记，每个服务向注册中心登记

自己提供的服务，主要包括服务的主机，端口，版本，通信协议等等信息，注册中心根据服务名

分类管理服务清单。

比如，提供A和B两个服务，A运行于192.168.200.12:8000、192.168.200.13:8000位置上，

B服务运行于192.168.200.14:8001、192.168.200.15:8001位置上。当这些服务启动并注册到注册中心后，

注册中心根据服务名维护服务清单，同时，服务注册中心以心跳方式去监测服务清单中的应用是否可用，

如果不可用，就会将其从服务清单中剔除，达到排除故障的效果。

## 2、服务发现 ##

在微服务中，服务间的调用跟传统的调用方式不一样，传统使用具体的地址访问，而在微服务中，

通过服务名发起请求调用实现。比如A服务调用B服务，B服务向注册中心发起咨询服务请求，将服务清单

返回给A服务，如果如上B有多个位置，A服务将会以某种轮询策略取出一个位置进行服务调用，

也就是使用某种客户端负载均衡算法达到轮询访问，减轻服务端压力。

# 二 Spring Cloud入门实例 #

以下实例项目jar包引用参考github项目。

## 1、Eureka注册中心搭建（eureka-server） ##

Spring Cloud Eureka是Spring Cloud Netfix微服务中的一部分，Spring团队基于Netfix Eureka

做二次封装，主要完成了微服务架构中的服务治理功能。Spring Cloud不仅可以使用Eureka做注册中心，

同时也可以使用Zookeeper做为注册中心。这里主要了解使用Eureka作为注册中心的应用。

Spring Cloud Eureka使用Netfix Eureka来实现服务注册与发现组件，主要包括服务端和客户端两部分。

1）Eureka服务端，也是我们常说的注册中心。与其它注册中心一样，均可支持高可用配置。

2）Eureka客户端，主要处理服务的注册和发现。客户端通过注解和参数配置的方式，

嵌入在客户端应用程序的代码中，在应用程序运行时，Eureka客户端向注册中心注册

自身提供的服务并周期性地发送心跳更新它的服务租约。同时，也可以从服务端查询

当前注册的服务信息并把它们缓存到本地并周期性地刷新服务状态。

**a、项目结构**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70][]

**b、application.properties**

配置文件。

# 服务名称和端口
    spring.application.name=eureka-server
    server.port=9000
    
    # 定义Instance ID 的hostname
    eureka.instance.hostname=localhost
    
    # 自我注册禁用（在默认情况下，服务注册中心也会将自己作为客户端来尝试注册它自己，设置为false）
    eureka.client.register-with-eureka=false
    
    # 是否检索服务（由于注册中心的职责就是维护服务实例，所以就不需要去检索服务，设置为false）
    eureka.client.fetch-registry=false
    
    # 日志文件
    # logging.file=${spring.application.name}.log
    
    # 是否开启注册中心自我保护机制(true开，false关，默认为开)
    eureka.server.enable-self-preservation=true

**c、EurekaServerApplication**

服务启动类。

package com.jpeony.eureka;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    /**
     * -- @SpringBootApplication 启动一个Spring Boot应用程序
     * -- @EnableEurekaServer 注解启动一个服务注册中心提供给其他应用进行会话
     *
     * @author yihonglei
     */
    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaServerApplication {
        public static void main(String[] args) {
            SpringApplication.run(EurekaServerApplication.class, args);
        }
    }

## 2、服务提供者（eureka-provider-order） ##

**a、项目结构**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 1][]

**b、application.properties**

配置文件。

# 注册到eureka服务端的微服务名称
    spring.application.name=eureka-provider-order
    
    # 服务提供端口
    server.port=8001
    # 注册到eureka服务端的地址
    eureka.client.service-url.defaultZone=http://localhost:9000/eureka/
    # 显示指定微服务的名称，默认ip:应用名称:端口(192.168.1.7:eureka-provider:8001)
    eureka.instance.instance-id=eureka-provider-order-8001
    eureka.instance.prefer-ip-address=true

**c、OrderController**

控制层。

package com.jpeony.controller;
    
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    /**
     * -- @RestController这个注解等价于spring mvc用法中的@Controller+@ResponseBody
     *
     * @author yihonglei
     */
    @RestController
    @RequestMapping("/order")
    public class OrderController {
    
        @RequestMapping(value = "/queryOrderInfo", method = {RequestMethod.GET, RequestMethod.POST})
        public String queryOrderInfo() {
    
            return "order-8001";
        }
    }

**d、EurekaOrderApplication**

启动类。

package com.jpeony;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * -- @SpringBootApplication 启动一个Spring Boot应用程序
     * -- @EnableDiscoveryClient 服务发现与注册，当应用启动时，将应用注册到配置的注册中心
     *
     * @author yihonglei
     */
    @EnableDiscoveryClient
    @SpringBootApplication
    public class EurekaOrderApplication {
        public static void main(String[] args) {
            SpringApplication.run(EurekaOrderApplication.class, args);
        }
    }

## 3、服务消费者（eureka-provider-user） ##

**a、项目结构**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 2][]

**b、application.properties**

# 注册到eureka服务端的微服务名称
    spring.application.name=eureka-consumer-user
    
    # 服务提供端口
    server.port=8002
    # 注册到eureka服务端的地址
    eureka.client.service-url.defaultZone=http://localhost:9000/eureka/
    # 显示指定微服务的名称，默认ip:应用名称:端口(192.168.1.7:eureka-provider:8002)
    eureka.instance.instance-id=eureka-consumer-user-8002
    eureka.instance.prefer-ip-address=true

**c、MainConfig**

RestTemplate配置。

package com.jpeony.config;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * RestTemplate创建
     *
     * @author yihonglei
     */
    @Configuration
    public class MainConfig {
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }

**d、UserController**

控制层。

package com.jpeony.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * -- @RestController这个注解等价于spring mvc用法中的@Controller+@ResponseBody
     *
     * @author yihonglei
     */
    @RestController
    @RequestMapping("/user")
    public class UserController {
    
        @Autowired
        private RestTemplate restTemplate;
    
        @RequestMapping(value = "/queryUserInfo", method = {RequestMethod.GET, RequestMethod.POST})
        public String queryUserInfo() {
            ResponseEntity<String> responseEntity =
                    restTemplate.getForEntity("http://EUREKA-PROVIDER-ORDER/order/queryOrderInfo", String.class);
    
            return responseEntity.getBody();
        }
    }

**e、EurekaUserApplication**

package com.jpeony;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * -- @SpringBootApplication 启动一个Spring Boot应用程序
     * -- @EnableDiscoveryClient 服务发现与注册，当应用启动时，将应用注册到配置的注册中心
     *
     * @author yihonglei
     */
    @EnableDiscoveryClient
    @SpringBootApplication
    public class EurekaUserApplication {
        public static void main(String[] args) {
            SpringApplication.run(EurekaUserApplication.class, args);
        }
    }

## 4、实例访问说明 ##

1）执行eureka-server项目的EurekaServerApplication，启动注册中心；

2）执行eureka-provider-order项目的EurekaOrderApplication，启动服务提供者；

3）执行eureka-consumer-user项目的EurekaUserApplication，启动服务消费者；

4）访问注册中心地址[http://localhost:9000/][http_localhost_9000]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 3][]

5）访问服务，[http://localhost:8002/user/queryUserInfo][http_localhost_8002_user_queryUserInfo]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 4][]

## 5、总结 ##

eureka-server提供注册中心，order是服务提供者，user是消费者，

user通过注册中心服务列表调用服务提供者，并返回响应结果。

[https_github.com_yihonglei_thinking-in-springcloud]: https://github.com/yihonglei/thinking-in-springcloud
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70]: /images/20220607/02d819e5157c4f4abe5502a11ef56355.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 1]: /images/20220607/9d486bf4de014f00a9b9d5d79dbe02eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 2]: /images/20220607/796542f3bc704a49bf08e73e8dd49989.png
[http_localhost_9000]: http://localhost:9000/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 3]: /images/20220607/81fa46e0cff74dfd8e6b78e684b9964a.png
[http_localhost_8002_user_queryUserInfo]: http://localhost:8002/user/queryUserInfo
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lobF9qeHk_size_16_color_FFFFFF_t_70 4]: /images/20220607/5bdc24c787524445b1176467963e25e1.png