微服务架构(分布式架构技术)
核心思想将一个单体应用拆分成多个小应用,小应用可以独立部署,可以通过HTTP协议进行调用。按资源和业务处理原则进行分解。
包含服务开发(SpringBoot)和服务管理(SpringCloud)两方面。
优点:
- 便于系统分工、技术选型
- 便于分布式部署,提升处理效率
- 便于系统扩展、维护
缺点:
- 开发调试复杂(服务间调用、事务完整性)
- 服务管理复杂
- 环境运维复杂
Springcloud作用
SpringCloud是针对服务管理推出的一套解决方案。主要包含以下功能模块:
1.Eureka服务注册和查找
2.服务间调用RestTemplate\Feign接口
3.使用Ribbon实现服务负载均衡+集群
4.Hystrix容错机制,动态智能管理机制,防止服务雪崩
5.Zuul网关提供外界访问控制
6.统一配置Config,消息传递Bus
SpringBoot是在Spring基础上的一种封装,SpringBoot主要是用于开发小应用服务,SpringCloud是针对这些服务管理。
Eureka服务注册和查找
Eureka是一个服务注册和查找中心,它是Netflix公司开源组件。 Eureka分为客户端和服务端,服务端有一个服务注册列表,列表会定时更新。
微服务注册
1.搭建eureka服务中心
- 导入spring-cloud-starter-netflix-eureka-server、spring-boot-starter-parent、spring-cloud-dependencies
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version>
</parent>
<dependencyManagement>
<dependencies>
<!-- spring-cloud-parent -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>
spring-cloud-starter-netflix-eureka-server
</artifactId>
</dependency>
</dependencies>
- 在application.properties配置eureka参数
server.port=3333
#当前项目是否参与注册(正常都参与true)
eureka.client.registerWithEureka=false
#是否从服务器抓取注册列表信息(正常都参与true)
eureka.client.fetchRegistry=false
#服务注册和查找的定位URL地址(注册者和消费者都需要访问)
eureka.client.serviceUrl.defaultZone=http://localhost:3333/eureka
- 定义启动类@SpringBoot Application、@EnableEurekaServer
@SpringBootApplication//启动Boot应用
@EnableEurekaServer//启动Eureka服务端
public class EurekaRunBoot {
public static void main(String[] args) {
SpringApplication.run(EurekaRunBoot.class, args);
}}
- 定义Eureka服务列表显示格式
默认情况下,客户端使用“机器名:服务名:端口号”信息注册,如果需要使用IP地址,可以通过在EurekaClient端通过下面参数指定
eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}
- 为Eureka中心添加登录验证
追加spring-cloud-starter-security启动器,然后通过下面参数指定账号和密码
spring.security.user.name=root
spring.security.user.password=123
提示:服务注册受security权限限制无法注册,需要做一下改动
首先修改EurekaClient端配置参数
eureka.client.serviceUrl.defaultZone=http://root:123@localhost:3333/eureka
然后修改EurekaServer端启动类,追加下面代码
@EnableWebSecurity
static class WebSecurityConfig extends WebSecurityConfigurerAdapter {
@Override
protected void configure(HttpSecurity http) throws Exception {
http.csrf().ignoringAntMatchers("/eureka/**");
super.configure(http);
}
}
- Eureka集群同步
Eureka可以实现集群化,不同Eureka注册的服务实现同步,需要在Eureka之间追加其他Eureka的注册地址。例如下面格式
eureka.client.serviceUrl.defaultZone=http://localhost:3333/eureka,http://localhost:4444/eureka
2.服务注册Eureka
Eureka只能管理Restful服务,不能管理带JSP、Thymeleaf等应用。
引入spring-cloud-starter-netflix-eureka-client、spring-boot-starter-parent、spring-cloud-dependencies
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version>
</parent>
<dependencyManagement>
<dependencies>
<!-- spring-cloud-parent -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>
spring-cloud-starter-netflix-eureka-client
</artifactId>
</dependency>
</dependencies>
提示:parent需要在其他工程中单独追加,不能依赖过来。
- 在application.properties定义参数
注册服务名
spring.application.name=ydma-course
#eureka地址
eureka.client.serviceUrl.defaultZone=http://localhost:3333/eureka
在启动类前追加@EnableDiscoveryClient//加强型@EnableEurekaClient
3.Ribbon负载均衡调用
Ribbon是一个负载均衡组件,自带很多分配策略IRule规则,默认采用轮询策略。
- 在pom.xml追加spring-cloud-starter-netflix-ribbon定义
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
- 在RestTemplate创建代码部分添加@LoadBalanced启用Ribbon
@Bean
@LoadBalanced//启用ribbon负载均衡
public RestTemplate restTemplate() {
return new RestTemplate();
}
- 调用时使用Eureka注册的应用名做URL调用
String url = "http://YDMA-COURSE/course/direction?size=3&directionId="+d.getId();
YdmaResult courseResult = restTemplate.getForObject(url, YdmaResult.class);
- 默认是轮训负载策略,可以进行修改
@Bean
public IRule rule() {
return new RandomRule();
}
- 通过配置修改负载策略(第二种方法修改配置properties)
注册服务名.ribbon.NFLoadBalancerClassName=配置ILoadBalancer的实现类
注册服务名.ribbon.NFLoadBalancerRuleClassName=配置IRule的实现类
注册服务名.ribbon.NFLoadBalancerPingClassName=配置IPing的实现类
注册服务名.ribbon.NFWSServerListClassName=配置ServerList的实现类
注册服务名.ribbon.NIWSServerListFilterClassName=配置ServerListFilter的实现类
4.Feign组件调用服务
- 在pom.xml添加spring-cloud-starter-openfeign包
- 在启动类前添加@EnableFeignClients//启用Feign
- 定义Feign接口,接口方法参考Controller定义即可,参数用@RequestParam(创建一个Fegin接口)
@FeignClient(name="YDMA-COURSE")//对应注册的服务名
public interface CourseFeignRemote {
@GetMapping("/course/direction")
public YdmaResult loadDirectionCourse(
@RequestParam(value="size",required=false,defaultValue="3") int size,
@RequestParam("directionId") int directionId);
}
- 在业务组件直接注入Feign接口对象使用
@Autowired
private CourseFeignRemote courseRemote;
YdmaResult courseResult = courseRemote.loadDirectionCourse(3, d.getId());
提示:通过Feign接口调用服务,Ribbon负载均衡组件自动作用到Feign接口对象上。(RestTemplate还需要自己额外进行负载均衡)