目录
1.引言:如果一个父项目中有多个子项目,但是这些子项目如何如何相互调用彼此的业务呢?
2.什么是注册中心
3.CAP理论
4.EureKa
5.服务注册
6.服务发现
7.负载均衡
1.引言:如果一个父项目中有多个子项目,但是这些子项目如何如何相互调用彼此的业务呢?
思路:order-service服务向product-service服务发送个http请求,把结果和自己的服务结果融合在一起,一起返回给调用者。
实现:采用Spring提供的RestTemplate,其实实现htpp请求的方式有很多参考Java 实现 HTTP 请求的 4 种方式,最后一种用起来真优雅 - 知乎
1.定义个RestTemplate
@Configuration
public class BeanConfig {
@Bean
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
2.修改Service层的调用代码
在调用order-service的服务时同时在order-service服务中向prodyct-servicehttp请求。
将product-service的返回结果融入到orderr-service中。
@Service
public class OrderService {
@Autowired
private OrderMapper orderMapper;
@Resource
private RestTemplate restTemplate;
public OrderInfo selectOrderById(Integer orderId) {
OrderInfo orderInfo = orderMapper.selectOrderById(orderId);
String url = "http://127.0.0.1:9090/product/" + orderInfo.getProductId();
ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);
orderInfo.setProductInfo(productInfo);
return orderInfo;
}
}
3.验证结果
这种方式成功了,但是麻烦的是如果换成别的服务那么就要重新写url,这是我们不希望的。
2.什么是注册中心
注册中心就像这个查号台,当一个服务调用另一个服务时,直接通过查号台(注册中心)去调用,避免频繁更改url。
当服务变更时向注册中心报道,注册中心记录应用和ip的关系。
调用方调用时,先去注册中心获取ip,再去调用。
注册中心:维护一个服务列表,哪些服务上线,哪些服务下线,哪些服务更改ip,这些信息会更新到这个注册中心上。客户端拿到这个服务列表直接进行调用就好啦。
注册中心三个重要角色
服务提供者:在业务中,被其他服务调用的服务,也就是提供接口给其他服务调用。
服务消费者:在业务中,调用其他业务的服务,调用其他接口。
服务注册中心:用来保存Server节点的注册信息。服务提供者要定期向注册中心发送心跳,否则注册中心就长时间检查不到服务提供者的存活状态就会删除这个实例。通过服务注册中心,服务消费者很容易调用提供者提供的接口。
3.CAP理论
1.一致性:指的是强一致性,同一时间具有相同的数据。
2.可用性:保证每个请求都有响应,但不保证响应正确。
3.分区容错性:出现网络分层,系统依然能提供对外服务。
解释:服务注册像是一个全国连锁的企业一样
1.对客户的官方应答都是一致的,不存在偏差
2.当一个政策修改时,相关的距离交换的信息还没有开的及传送,此时客户端访问总部和访问偏远部得到的相应不一致。
3.网络分层类似于企业休假,但是有的部门仍然值班,所以系统依然对外服务。
CAP理论表明:分布式系统不能同时保持数据一致性,服务可用性和分区容错性。只能兼容其中两个。
4.EureKa
一个服务发现框架,用于服务注册,管理,负载均衡和服务故障转移。
1.创建eureka服务类:
2.加上pom配置文件
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
3.完善启动类,添加注解
@EnableEurekaServer能够让SpringBoot类作为Eureka Server运行实现服务注册和服务发现功能。
4.编写配置文件
# eureka的yml配置
server:
port: 10010
spring:
application:
name: eureka-server
eureka:
instance:
hostname: localhost #表示启动的ip地址,这是当前主机
client:
fetch-registry: false # 表⽰是否从Eureka Server获取注册信息,默认为true.因为这是⼀个单点的Eureka Server,不需要同步其他的Eureka Server节点的数据,这⾥设置为false
register-with-eureka: false #表⽰是否将⾃⼰注册到Eureka Server,默认为true.由于当前应⽤就是Eureka Server,故⽽设置为false.
service-url:
#设置与Eureka Server的地址,查询服务和注册服务都需要依赖这个地址.
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
5.启动eureka-service的启动类,显示如下页面代表配置成功
5.服务注册
1.在要服务注册的子项目的pom加入eureka客户端依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
2.在子项目的yml文件中加入添加服务名称和eureka地址。。
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10010/eureka/
运行要注册的项目的启动类 和 eureka项目的启动类,在网页访问eureka的地址
有了画红框的标识,标识服务注册成功。
6.服务发现
服务注册已经搞好了,接下来是服务发现,修改order-service,从eureka-service拉取product-service的服务信息,实现服务发现。
服务注册和服务发现 都封装在eureka-client依赖中,所以服务发现也要引入这个依赖。
1.在order-service的配置文件中加入eureka的地址,和服务注册一样
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10010/eureka/
2.pom中加入eureka-client依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
3.修改远程调用的代码
在服务发现之前远程调用都是直接输入要调用服务的地址这样非常麻烦容易出错,效率不高,接下来只需要调用eureka即可。
4.启动eureka,order,product
服务注册和服务发现成功。
7.负载均衡
就是对不同的机器有不同的流量分配。
当我们同一个服务在Eureka中注册了几个分身,那么如何才能平衡这个分身的流量均衡呢?
方案一:
我们可以在调用服务的order-service中采用轮询定义些变量去依次访问每个服务。
AtomincInteger是线程安全的,再定义一个List表来储存每个服务。此后只需要轮流遍历表中的服务就可以达到目的。
方案二:
在客户端添加一个LoadBalance注解
此后SpringCloud会自动为分身服务分配流量,SpringCloud默认的也是轮询的方式。
但是也可以使用自定义负载均衡,首先实现一个负载均衡的类。
这个类需要满足两个条件:1.不⽤ @Configuration 注释 2.在组件扫描范围内
所以必须要使用@LoadBalancerClient或@LoadBalancerClients注解来包含扫描范围。
因为我们这个理只有一个服务提供者,所以使用@LoadBalancerClient。
这样便实现了自定义负载均衡器。