Spring Cloud入门介绍-Eureka注册中心说明

左手的ㄟ右手 2022-12-23 09:35 122阅读 0赞

# Spring Cloud介绍 #

*  （1）Spring cloud 是什么?  
    微服务是一种架构方式，最终肯定需要技术架构去实施。  
    微服务的实现方式很多，但是最火的莫过于Spring Cloud了  
    `Spring Cloud是一种最火的微服务实现方式`  
    Spring Cloud是Spring旗下的项目之一  
    官网地址：http://projects.spring.io/spring-cloud/
 *  （2）Spring cloud为什么火?  
    》后台硬 spring全家桶  
    》技术强 spring团队  
    》使用方便 springboot

# Spring Cloud架构 #

*  （1）Spring Cloud 版本  
    1.0.0 整数编号  
    它的版本命名比较特殊，是以A到Z的为首字母的一些单词  
    （其实是伦敦地铁站的名字）组成
 *  （2）Spring cloud 架构是怎样的?  
    Eureka：注册中心 美\[juˈriːkə\]  
    Zuul 或者 Gateway：服务网关  
    Ribbon： 负 载 均 衡 美\[ˈrɪbən\]  
    Feign：服务调用 美\[feɪn\]  
    Hystrix或Resilience4j：熔断器 美\[hɪst’rɪks\] 美\[rɪˈzɪliəns\]  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 1]

# 开发微服务的三个要素 #

》dubbo发布的服务，有三个要素  
一是提供者  
二是消费者  
三是注册中心  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 2]  
》springcloud 发布的服务，有三个要素  
一是提供者  
二是消费者  
三是注册中心

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 3]

# 创建微服务工程 #

*  （1）创建工程规划  
    创建微服务父工程xxx-parent  
    用户服务工程demo01\_provider\_user\_8001  
    服务消费工程demo02\_consumer\_user\_81
 *  （2）步骤  
    》1 父工程xxx-parent  
    添加spring boot父坐标和管理其它组件的依赖  
    》2 用户服务工程demo01\_provider\_user\_8001  
    整合mybatis查询数据库中用户数据；提供查询用户服务  
    》3 服务消费工程demo02\_consumer\_user\_81  
    利用查询用户服务获取用户数据并输出到浏览器

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 4]

# 搭建配置服务(provider)工程 #

*  （1）demo01\_provider\_user\_8001  
    可以访问http://localhost:8001/user/8输出用户数据
 *  （2）实现步骤  
    》1. 添加启动器依赖（web）  
    》2. 修改配置文件中的参数

## application.properties ##

# service name
    spring.application.name=demo01_provider_user_8001
    # server port
    server.port=8001

》3. 编写测试代码（UserController）；

## UserController ##

@RestController
    @RequestMapping("/users")
    public class UserController { 
        @RequestMapping(path = "/{id}",method = { RequestMethod.GET})
        public Object  get(@PathVariable long id){ 
            //模拟一条数据
            User user = new User();
            user.setId(id);
            user.setUsername("jack"+id);
            user.setPassword("123456");
            return user;//RestController将user转成json
        }
    }

》4. 测试  
使用postman  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 5]

# 搭建配置消费(consumer)工程 #

*  （1）访问http://localhost:81/consumer/1 使用RestTemplate获取http://localhost:8001/user/1的数据
 *  （2）实现步骤  
    》1. 添加启动器依赖；  
    》2. 创建启动引导类（注册RestTemplate）和配置文件；

## application.properties ##

spring.application.name=demo02_consumer_user_81
    server.port=81

》3. 编写测试代码

## CosumerController ##

@RestController
    @RequestMapping("/consumer")
    public class CustomerController { 
        @Autowired
        RestTemplate rt;//当前是使用RestTemplate调用demo01的数据
    
        //需要在启动类创建当前对象
        //然后由Autowired去获取
        @RequestMapping(path = "/{id}", method = RequestMethod.GET)
        public Object get(@PathVariable long id) { 
            //消费工程，只是调用其他服务来获得想要的数据
            String url = "http://localhost:8001/users/11";//参1 地址
            String json = rt.getForObject(url, String.class);//参2：数据要转换成什么类型
            return json;
        }
    }

（ConsumerController中使用restTemplate访问服务获取数据）

@SpringBootApplication
    public class Demo02ConsumerUser81Application { 
    
        public static void main(String[] args) { 
            SpringApplication.run(Demo02ConsumerUser81Application.class, args);
        }
    
        @Bean
        public RestTemplate getRt() { 
            RestTemplate rt = new RestTemplate();
            return rt;
        }
    }

》4. 测试  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 6]

# Eureka注册中心说明 #

*  （1）Eureka是什么?  
    SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。
 *  （2）Eureka有什么功能 ?  
    主要功能是  
    》进行服务管理  
    》定期检查服务状态  
    》返回服务地址列表。  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 7]

# 搭建eureka-server工程 #

*  （1）Eureka是服务注册中心，只做服务注册；  
    demo03\_eureka\_server\_10086  
    自身并不提供服务也不消费服务。  
    可以搭建web工程使用Eureka，可以使用Spring Boot方式搭建。
 *  （2）搭建步骤：

1.  创建工程；
2.  添加启动器依赖；
3.  修改配置文件（端口，应用名称…）；
4.  编写启动引导类（添加Eureka的服务注解）和配置文件；
5.  启动测试

## pom.xml ##

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

阿里云目前还没有更新，所以需要保留官网的仓库地址

<repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/milestone</url>
            </repository>
        </repositories>

## application.properties ##

spring.application.name=demo03_register_center_eureka_10086
    server.port=10086
    #  eureka 服务地址，如果是集群的话；需要指定其它集群eureka地址
    eureka.client.service-url.defaultZone=http://localhost:10086/eureka
    # 不注册自己
    eureka.client.register-with-eureka=false
    # 不拉取服务
    eureka.client.fetch-registry=false

## 启用 ##

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

# pom.xml的抽取 #

*  （1）使用画图，把pom.xml复制到一起
 *  （2）然后找出相同的配置，剪切到pom.xml
 *  （3）再复制到工程中

## 父 pom.xml ##

<packaging>pom</packaging>
        <modules>
            <module>demo01_provider_user_8001</module>
            <module>demo02_consumer_user_81</module>
            <module>demo03_register_center_eureka_10086</module>
        </modules>
    
        <properties>
            <java.version>1.8</java.version>
            <spring-cloud.version>2020.0.0-M5</spring-cloud.version>
        </properties>
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>1.18.16</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/milestone</url>
            </repository>
        </repositories>

## 子pom.xml ##

<parent>
            <groupId>com.wzx</groupId>
            <artifactId>micro_service_spring_cloud_parent</artifactId>
            <version>1.0-SNAPSHOT</version>
        </parent>

## provider与consumer ##

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

## server ##

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

# 服务注册与发现 #

*  （1）将服务注册到eureka并在消费端中可以根据服务名称调用
 *  （2）provider服务注册
 *  （3）consumer服务发现  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 8]

# provider注册 #

*  （1）服务注册  
    在服务提供工程上添加Eureka客户端依赖；自动将服务注册到EurekaServer服务地址列表  
    》1 添加依赖；  
    》2 修改配置文件；设置Eureka 服务地址  
    》3 改造启动引导类；添加开启Eureka客户端发现的注解；

## pom.xml ##

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

## applicaton.properties ##

# register address
    eureka.client.service-url.defaultZone=http://127.0.0.1:10086/eureka

## main ##

@SpringBootApplication
    @EnableEurekaClient
    public class Demo01ProviderUser8001Application

# consumer查询 #

*  （1）服务发现  
    在服务消费工程上添加Eureka客户端依赖；可以使用工具类根据服务名称获取对应的服务地址列表  
    》1 添加依赖；  
    》2 修改配置文件；设置Eureka 服务地址；  
    》3 改造启动引导类；添加开启Eureka客户端发现的注解；  
    》4 改造处理器类ConsumerController，可以使用工具类DiscoveryClient根据服务名称获取对应服务地址列表。

## pom.xml ##

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

## application.properties ##

# query address
    eureka.client.service-url.defaultZone=http://127.0.0.1:10086/eureka

## main ##

@SpringBootApplication
    @EnableEurekaClient
    public class Demo02ConsumerUser81Application

# DiscoveryClient 对象 #

*  （1）DiscoveryClient 获取注册中心provider的信息  
    》Host  
    》port  
    代码编写  
    ConsumerController

@Autowired
       DiscoveryClient discoveryClient;
       //需要在启动类创建当前对象
       //然后由Autowired去获取
       @RequestMapping(path = "/{id}", method = RequestMethod.GET)
       public Object get(@PathVariable long id) { 
    
           //获取 provider ip与端口
           List<ServiceInstance> list = discoveryClient.getInstances("demo01_provider_user_8001");//服务id
           //表示运行中的服务对象
           ServiceInstance serviceInstance = list.get(0);
           String host = serviceInstance.getHost();
           int port = serviceInstance.getPort();
           log.info("host "+host);
           log.info("port "+port);
           //消费工程，只是调用其他服务来获得想要的数据
           String url = "http://"+host+":"+port+"/users/11";//参1 地址
           //String url = "http://localhost:8001/users/11";//参1 地址
           String json = rt.getForObject(url, String.class);//参2：数据要转换成什么类型
           return json;
       }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/85c051c870c94bb3b5f7eda1f8d00cd9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/83429051cf9b4dbbb5b8dafaf089d100.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/06e0a1392e324c63a90ad57485b3e4f8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/6e4652293bdf45ae98691efa808e12ec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221120/7ff770a711194183a78f0b28fdf46355.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221120/048e0bad114c48e6a8a0d38248a96488.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221120/da29474fa7384739b09166df949b21a2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221120/c3d2a2f4e4e646328ba3d3253e411a81.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM2MjEzOTg_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20221120/fabc3de008d34867bb5161cf02ffe087.png