1.SpringCloud简介
SpringCloud集成了很多组件,包括:
- Eureka: 服务治理,服务注册/发现
- Zuul: 网关组件,提供智能路由,访问过滤功能 (集成了ribbon、hystrix)
- Ribbon:客户端负载均衡的服务调用组件(客户端负载)
- Fegin: 服务之间的调用组件 (集成了ribbon、hystrix)
- Hystrix: 容错管理组件
2.Eureka注册中心
- Eureka:就是服务注册中心(可以是一个集群),对外暴露自己的地址
- 提供者:启动后向Eureka注册自己信息(地址,提供什么服务)
- 消费者:向Eureka订阅服务,Eureka会将对应服务的所有提供者地址列表发送给消费者,并且定期更新
- 心跳(续约):提供者定期通过http方式向Eureka刷新自己的状态
2.1.搭建注册中心EurekaServer
导入依赖:
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.6.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Finchley.RC2</spring-cloud.version>
</properties>
<!--注册中心的依赖-->
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
<!-- SpringCloud的依赖 统一管理版本号-->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
编写application.yml配置文件
server:
port: 8081 # 端口
spring:
application:
name: eureka-server # 应用名称,会在Eureka中显示
eureka:
client:
service-url: # EurekaServer的地址,现在是自己的地址,如果是集群,需要加上其它Server的地址。
defaultZone: http://127.0.0.1:${server.port}/eureka
在引导类上加注解:
@SpringBootApplication
@EnableEurekaServer // 声明当前springboot应用是一个eureka服务中心
public class ItcastEurekaApplication {
public static void main(String[] args) {
SpringApplication.run(ItcastEurekaApplication.class, args);
}
}
直接启动,访问http:localhost:8081即可访问到
2.2.将其他服务注册到Eureka中
service-provide
- 在pom.xml中,添加springcloud的相关依赖。
- 在application.yml中,添加springcloud的相关配置。
- 在引导类上添加注解,把服务注入到eureka注册中心。
参照service-eureka的pom.xml中加入Eureka的客户端,载导入其他与数据库相关的依赖等
<!-- Eureka客户端 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
application.yml:
erver:
port: 8082
spring:
datasource:
url: jdbc:mysql://localhost:3306/li
username: root
password: root
driverClassName: com.mysql.jdbc.Driver
application:
name: service-provider # 应用名称,注册到eureka后的服务名称
mybatis:
type-aliases-package: com.li.service.pojo
eureka:
client:
service-url: # EurekaServer地址
defaultZone: http://127.0.0.1:8081/eureka
在引导类上加上注解
@SpringBootApplication
@EnableDiscoveryClient
public class ItcastServiceProviderApplication {
public static void main(String[] args) {
SpringApplication.run(ItcastServiceApplication.class, args);
}
}
启动后在注册中心中就可以看到此服务,可以再写一个服务的消费方的服务,也注册到Eureka中,通过feign来远程调用;
service-customer
1.加入Feign依赖
<!--引入Feign组件依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2.引导类加上注解
@SpringBootApplication
@EnableDiscoveryClient //启动客户端
@EnableFeignClients //启用Feign组件代替RestTemplate远程调用 :其中包含熔断和负载均衡
public class ServiceConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceConsumerApplication.class,args);
}
}
3.创建接口
/**
* fallback = UserClientFallback.class : 熔断
*/
@FeignClient(value = "service-provide") //声明接口为feign客户端接口,并指明调用的微服务名(id)
public interface UserClient {
@GetMapping("user/{id}")
public User queryUserById(@PathVariable("id") Integer id);
}
4.创建controller
@Controller
@RequestMapping("consumer/user")
public class UserController {
@Autowired
private UserClient userClient;
@GetMapping
@ResponseBody
public String queryUserById(@RequestParam("id") Integer id) {
return this.userClient.queryUserById(id).toString();
}
}
3.服务提供方
服务续约
在注册服务完成以后,服务提供者会维持一个心跳(定时向EurekaServer发起Rest请求),告诉EurekaServer:“我还活着”。这个我们称为服务的续约(renew);
eureka:
instance:
lease-expiration-duration-in-seconds: 10 # 10秒即过期
lease-renewal-interval-in-seconds: 5 # 5秒一次心跳
- lease-expiration-duration-in-seconds: 服务续约(renew)的间隔,默认为30秒
- lease-expiration-duration-in-seconds:服务失效时间,默认值90秒
默认情况下每个30秒服务会向注册中心发送一次心跳,证明自己还活着。如果超过90秒没有发送心跳,则会在服务列表里移除
4.服务消费方
eureka:
client:
service-url:
registry-fetch-interval-seconds: 5 #拉取服务的间隔时间
5.失效剔除和自我保护
失效剔除
有时服务挂掉过着关掉,Eureka Server会将这些服务从列表中剔除:
自我保护
在当某些服务挂掉之后,Eureka会将这写服务保护一段时间,不被直接剔除
eureka:
server:
enable-self-preservation: false # 关闭自我保护模式(缺省为打开)
eviction-interval-timer-in-ms: 1000 # 扫描失效服务的间隔时间(缺省为60*1000ms)