【springcloud学习笔记】Eureka服务治理demo

超、凢脫俗 2023-01-04 13:12 174阅读 0赞

一、描述

> Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用Spring Boot的开发风格做到一键启动和部署。Spring Cloud并没有重复制造轮子，它只是将各家公司开发的比较成熟、经得起实际考验的服务框架组合起来，通过Spring Boot风格进行再封装屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。

**1. Eureka是什么？**

Spring Cloud Eureka 是 Spring Cloud Netflix 微服务套件的一部分，基于 Netflix Eureka 做了二次封装，主要负责实现微服务架构中的服务治理功能。

**2. 与dubbo的对比**

阿里开源的 Dubbo 框架就是针对服务治理的，可以采用redis和zookeeper，一般采用zookeeper做注册中心。  
zookeeper 满足CAP定理中的CP,而eureka满足AP。

CAP 定理，即 C 为数据一致性；A 为服务可用性；P 为服务对网络分区故障的容错性。这三个特性在任何分布式系统中都不能同时满足，最多同时满足两个。

二、环境

idea+jdk15

三、实现步骤

1.  创建spring cloud 工程  
    (1)创建eureka-server工程

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0_size_16_color_FFFFFF_t_70_pic_center]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0_size_16_color_FFFFFF_t_70_pic_center 1]  
采用idea自带的spring cloud discovery。如果你想自己创建，可以参考此文章（但不推荐，容易因为版本问题出错。）[Maven创建eureka][Maven_eureka]

进行配置

resource中application.properties

# 注册中心的名称
    spring.application.name=eureka-server
    # 注册中心的端口
    server.port=8761
    # 由于该应用为注册中心, 所以设置为false, 代表不向注册中心注册自己
    eureka.client.register-with-eureka=false
    # 由于注册中心的职责就是维护服务实例, 它并不需要去检索服务, 所以也设置为 false
    eureka.client.fetch-registry=false

启动类

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

启动效果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0_size_16_color_FFFFFF_t_70_pic_center 2]

2.创建client和customer 生产者和消费者

（1）client 生产者 ，和server类似，创建时选择client;

配置如下  
resource中application.properties

# 生产者
    spring.application.name=eureka-client-user-service
    # 启动端口
    server.port=8081
    eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
    # 采用IP注册
    eureka.instance.preferIpAddress=true
    # 定义实例ID格式
    eureka.instance.instance-id=${ spring.application.name}:${ spring.cloud.client.ip-address}:${ server.port}

启动类

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

写个控制类检验

package com.example.controller;
    
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    @Controller
    public class UserController { 
        @GetMapping("/user/hello")
        @ResponseBody
        public String hello(){ return "hello";}
    }

（2）消费者，创建和client一致，resouces的端口修改一下（改为8082）

测试：

配置类

package com.example.config;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class BeanConfiguration { 
        @Bean
        public RestTemplate getRestTemplate(){ return  new RestTemplate();}
    
    }

控制类  
通过控制访问8081的对应内容

package com.example.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class CustomController { 
        @Autowired
        private RestTemplate restTemplate;
    
        @GetMapping("/custom/callHello")
        public String callHello(){ return restTemplate.getForObject("http://localhost:8081/user/hello",String.class);}
    }

然后进行此URL（http://localhost:8082/custom/callHello）访问暴露的URL。

另外，直接将其暴露，公网就可访问注册中心，很不安全，可以使用spring security进行安全加密。

github地址：https://github.com/lyf712/spring-cloud-demo

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0_size_16_color_FFFFFF_t_70_pic_center]: /images/20221119/3b03211259b74cbfa937cdbbc6aae177.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0_size_16_color_FFFFFF_t_70_pic_center 1]: https://img-blog.csdnimg.cn/20210109231250935.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0,size_16,color_FFFFFF,t_70#pic_center
[Maven_eureka]: http://c.biancheng.net/view/5320.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0_size_16_color_FFFFFF_t_70_pic_center 2]: https://img-blog.csdnimg.cn/20210109231833655.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjU0OTc0,size_16,color_FFFFFF,t_70#pic_center