SpringCloud入门-Eureka高可用Ribbon负载均衡环境搭建模拟微服务场景学习笔记和总结

Eureka 应用场景
【SpringCloud入门-Eureka高可用Ribbon负载均衡环境搭建模拟微服务场景】在SOA(面向服务)的架构中，随着服务提供者和消费者的不断增加，注册中心(Eureka)就产生了，它充当一个中介的角色，收取服务提供者注册的信息，包括地址和服务的功能，等待消费者的定期信息拉取，从而使消费者高效地调用服务完成任务。
架构图

文章图片

Eureka：就是服务注册中心（一般为集群），对外暴露自己的地址，
提供者：启动后向Eureka注册自己信息（地址，提供什么服务）
消费者：向Eureka订阅服务，Eureka会将对应服务的所有提供者地址列表发送给消费者，并且定期更新
心跳(续约)：提供者定期通过http方式向Eureka发送请求并刷新自己的状态

环境搭建 1.添加依赖（需要先搭建一个基本的SpringBoot工程）

org.springframework.cloud spring-cloud-starter-netflix-eureka-server

2.application.yml 配置

server: port: 10086 # 端口 spring: application:#在Eureka中显示的应用名称 name: eureka-server eureka: client: service-url: # EurekaServer的地址，现在是自己的地址，如果是集群，需要加上其它Server的地址。 defaultZone: http://127.0.0.1:${server.port}/eureka

3.修改引导类,添加注解

@SpringBootApplication @EnableEurekaServer // 声明当前springboot应用是一个eureka服务中心 public class ItcastEurekaApplication { public static void main(String[] args) { SpringApplication.run(ItcastEurekaApplication.class, args); } }

成功访问到Eureka并发现一个已经注册的服务(Eureka-server本身)

SpringCloud入门-Eureka高可用Ribbon负载均衡环境搭建模拟微服务场景

文章图片

模拟SOA架构中的消费者和服务提供者模拟场景:

服务提供者:service-provider(根据id查询用户)
消费者:service-consumer
注册中心:eureka-server

服务提供者:service-provider

@RestController @RequestMapping("/user") public class UserController {@Autowired private UserService userService; //模拟查询用户功能为服务 @GetMapping("{id}") public User Hello(@PathVariable("id") String id){ return userService.findById(id); }}

application.yml

server: port: 8082 spring: application:#指定注册到注册中心的应用名称 name: service-provider datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql:///wxkaoqin username: root password: 123456 mybatis: type-aliases-package: cn.nn.pojo eureka: client: service-url:#eureka客户端配置指定注册中心地址 defaultZone: http://127.0.0.1:10086/eureka instance:#在联网环境下防止获取实例地址为公网或内网IP prefer-ip-address: true ip-address: 127.0.0.1

消费者:service-consumer

@SpringBootApplication @EnableDiscoveryClient //开启客户端的检测 public class ConsumeApplication {@Bean //配置restTemplate模板到ioc容器中 public RestTemplate restTemplate(){ returnnew RestTemplate(); } public static void main(String[] args) { SpringApplication.run(ConsumeApplication.class); } }@Autowired privateRestTemplate restTemplate; @Autowired private DiscoveryClient discoveryClient; @GetMapping("{id}") public User findById(@PathVariable("id") String id){ List instances = discoveryClient.getInstances("service-provider"); //因为没有负载均衡，所以只有一个实例,直接拿到该实例 ServiceInstance serviceInstance = instances.get(0); //拼接出服务提供方注册的地址 String url = "http://"+serviceInstance.getHost()+":"+serviceInstance.getPort()+"/user/"+id; User user = restTemplate.getForObject(url, User.class); System.out.println(user); return user; }

application.yml

server: port: 8089 spring: application: #指定注册到注册中心的应用名称 name: service-consumer eureka: client: service-url:#eureka客户端配置指定注册中心地址 defaultZone: http://127.0.0.1:10086/eureka

重启服务后

文章图片

访问服务

文章图片

Eureka 高可用环境这里我们复制一个之前搭建的Eureka

文章图片

1.修改之前搭建Eureka的application.yml文件

server: port: 10086 spring: application: name: eureka-server eureka: client: service-url:# defaultZone: http://127.0.0.1:10087/eureka #我们准备使用10086和10087配置两台主机的高可用 #所以此处应填写另外一个主机的地址，才能完成两 #台主机的相互注册，相互注册后才能实现高可用环境

2.开启服务器

文章图片

3.再次修改Eureka的application.yml文件，实现更换端口和两台服务器相互注册

server: port: 10087 #10087端口 spring: application: name: eureka-server eureka: client: service-url: #第一步搭建的Eureka地址 defaultZone: http://127.0.0.1:10086/eureka

4.开启第二台服务器

文章图片

进入Eureka UI界面验证

文章图片

此时消费者和服务提供者application的yml文件中的Eureka服务端地址配置应该写成集群的形式

server: port: 8089 spring: application: name: service-consumer eureka: client: service-url: defaultZone: http://127.0.0.1:10086/eureka,http://127.0.0.1:10087/eureka

Ribbon负载均衡这里我们复制一个服务提供者的服务器

文章图片

在创建RestTemplate模板的方法上添加@LoadBalanced注解，因为Eureka集成了LoadBalance所以不需要导入额外的maven坐标。

@SpringBootApplication @EnableDiscoveryClient public class ConsumeApplication {@Bean @LoadBalanced public RestTemplate restTemplate(){ returnnew RestTemplate(); } public static void main(String[] args) { SpringApplication.run(ConsumeApplication.class); } }

修改服务提供者方的application.yml文件

server://修改端口即可,我们准备使用8080和8082两个端口给两台负载均衡的服务器使用 port: 8080 spring: application: name: service-provider datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql:///wxkaoqin username: root password: 123456 mybatis: type-aliases-package: cn.nn.pojo eureka: client: service-url: defaultZone: http://127.0.0.1:10086/eureka,http://127.0.0.1:10087/eureka instance: prefer-ip-address: true ip-address: 127.0.0.1

开启服务器

文章图片

再次修改服务提供者方的application.yml文件,然后之前复制的第二台服务器

server://修改端口即可,我们准备使用8080和8082两个端口给两台负载均衡的服务器使用 port: 8082 spring: application: name: service-provider datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql:///wxkaoqin username: root password: 123456 mybatis: type-aliases-package: cn.nn.pojo eureka: client: service-url: defaultZone: http://127.0.0.1:10086/eureka,http://127.0.0.1:10087/eureka instance: prefer-ip-address: true ip-address: 127.0.0.1

开启服务器

文章图片

进入Eureka Ui界面验证

文章图片

开启消费者的服务器

文章图片

因为负载均衡后同一个服务有多个实例选择所以我们需要修改之前在ConsumerContrller中获取实例后的操作

@Autowired privateRestTemplate restTemplate; @Autowired private DiscoveryClient discoveryClient; @GetMapping("{id}") public User findById(@PathVariable("id") String id){ List instances = discoveryClient.getInstances("service-provider"); ServiceInstance serviceInstance = instances.get(0); //此处的service-provider在配置了负载均衡后，自动选择轮询的方式选择实例,无需自己拼接url String url = "http://service-provider/user/"+id; User user = restTemplate.getForObject(url3, User.class); System.out.println(user); return user; }

修改完成后重启服务，测试