微服务：Eureka原理实践：@EnableEurekaServer、@LoadBalanced
一、Eureka架构概述
Eureka架构中，有两类微服务角色：
- EurekaServer —— 服务端，注册中心。
-
- 记录服务；
- 心跳监控；
- EurekaClient —— 客户端。
-
- Provider：服务提供者。
-
- 注册自己的信息到EurekaServer；
- 每隔30秒向EurekaServer发送心跳请求；
- Consumer：服务消费者。
-
- 根据服务名称从EurekaServer拉取服务列表。
- 基于服务列表做负载均衡，选中一个微服务后发起远程调用。
Eureka的作用
- 服务消费者该如何获取服务提供者的具体信息？
-
- 服务提供者会在启动时向Erueka注册自己的信息。
- Erueka保存这些注册的信息。
- 服务消费者根据服务名称，向Erueka拉取服务提供者的信息。
- 如果有多个服务提供者，服务消费者该如何选择？
-
- 服务消费者利用负载均衡算法，从服务列表中挑选一个。
- 服务消费者如何感知服务提供者的健康状态？
-
- 服务提供者会每隔30秒向EurekaServer发送心跳请求，报告健康状态。
- Erueka会更新记录服务列表信息，心跳不正常会被剔除。
- Erueka更新服务列表后，服务消费者就可以拉取到最新的信息。
三、搭建EurekaServer（服务端）
1.创建项目，引入依赖
<dependencies>
<!--eureka服务端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
2.编写启动类
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@EnableEurekaServer//重点，开启Eureka服务。
@SpringBootApplication
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
}
3.添加配置信息
server:
port: 10086 # 服务端口
spring:
application:
name: eurekaserver # eureka的服务名称
eureka:
client:
service-url: # eureka的地址信息
defaultZone: http://127.0.0.1:10086/eureka
4.访问Eureka管理界面
四、搭建EurekaClient(客户端)
1.信息注册：Provider（服务提供者）
①引入依赖
<!--eureka客户端依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
②添加配置信息
spring:
application: #eureka客户端 —— 服务提供者Provider的服务名称
name: userservice
eureka:
client:
service-url: # eureka的地址信息
defaultZone: http://127.0.0.1:10086/eureka
2.信息注册：Consumer（服务消费者）
①引入依赖
<!--eureka客户端依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
②添加配置信息
spring:
application: #eureka客户端 —— 服务消费者Consumer的服务名称
name: orderservice
eureka:
client:
service-url: # eureka的地址信息
defaultZone: http://127.0.0.1:10086/eureka
五、Eureka服务拉取（服务发现）
服务拉取：基于服务名称，获取服务列表，然后对服务列表做负载均衡，挑选一个服务进行使用。
- 修改服务消费者（order-service）的业务层组件，即：远程调用功能的组件代码中，修改访问的url地址，使用服务名来代替ip、端口。
@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请求，查询用户
// 2.1.url路径
//String url = "http://localhost:8081/user/" + order.getUserId();
//使用服务提供者的服务名userservice代替ip、端口：
String url = "http://userservice/user/" + order.getUserId();
// 2.2.发送http请求，实现远程调用
User user = restTemplate.getForObject(url, User.class);
// 3.封装user到Order
order.setUser(user);
// 4.返回
return order;
}
}
重点在这里：
// 2.1.url路径
//String url = "http://localhost:8081/user/" + order.getUserId();
//使用服务提供者的服务名userservice代替ip、端口：
String url = "http://userservice/user/" + order.getUserId();
- 在服务消费者（order-service）的启动类OrderApplication中，为Spring容器中的RestTemplate实例使用负载均衡算法，即：添加注解
@LoadBalanced
@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
@EnableFeignClients(clients = UserClient.class,defaultConfiguration = DefaultFeignConfiguration.class)
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
/**
* 创建RestTemplate并注入Spring容器
*/
@Bean
@LoadBalanced//@LoadBalanced注解，实现负载均衡
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
- 完成上述两部，就能做到根据服务名称从EurekaServer拉取服务列表，并做负载均衡算法，从列表中挑选一个服务使用！
六、小结
@EnableEurekaServer—— 使用在SpringBoot工程启动类上，可开启Eureka服务。@LoadBalanced—— 使用在@Bean方法注入的RestTemplate实例上，用于实现负载均衡算法。