笔者最近自己也在开始学习springcloud,对应springcloud这一块,也算是比较了解,今天谈谈springcloud中非常重要的一个知识点Eureka注册中心,注册中心非常核心的无非在于他的服务的注册与发现,还有治理。
服务的治理
在传统rpc远程调用中,服务与服务依赖关系,管理比较复杂,所以需要使用服务治理,管理服务与服务之间依赖关系,可以实现服务调用、负载均衡、容错等,实现服务发现与注册。
服务注册与发现
在服务的注册与发现中,有一个注册中心,当服务器启动的时候会把自己当前的服务器信息, 比如:服务器通讯地址等以别名的方式注册到注册中心上,另一方(消费者|提供者)以该别名的fshi去注册中心上获取到实际的服务器通讯地址,然后在本地实现RPC远程调用。
注:一个服务既可以是提供者,也可以是消费者
Eureka注册中心的搭建
引入对应的依赖
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
</parent>
<!-- 管理依赖 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.M7</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<!--SpringCloud eureka-server -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
<!-- 注意: 这里必须要添加, 否者各种依赖有问题 -->
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/libs-milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
添加application.yml文件
###服务端口号
server:
port: 8100
###eureka 基本信息配置
eureka:
instance:
###注册到eurekaip地址
hostname: 127.0.0.1
client:
serviceUrl:
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
###因为自己是为注册中心,不需要把自己当成一个服务注册自己
register-with-eureka: false
###因为自己是为注册中心,不需要检索服务
fetch-registry: false
添加启动类AppEureka.java
@EnableEurekaServer
@SpringBootApplication
public class AppEureka {
public static void main(String[] args) {
// 解释:@EnableEurekaServer作用:开启eurekaServer即开启注册中心服务
SpringApplication.run(AppEureka.class, args);
}
}
启动之后看到如下效果表示启动成功:
搭建服务的提供者
springcloud-provider
添加maven依赖信息
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
</parent>
<!-- 管理依赖 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.M7</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<!-- SpringBoot整合Web组件 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- SpringBoot整合eureka客户端 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
</dependencies>
<!-- 注意: 这里必须要添加, 否者各种依赖有问题 -->
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/libs-milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
添加application.yml配置文件
###服务启动端口号
server:
port: 8000
###服务名称(服务注册到eureka名称)
spring:
application:
name: app-provider-demo
###服务注册到eureka地址
eureka:
client:
service-url:
defaultZone: http://localhost:8100/eureka
###因为该应用为注册中心,不会注册自己
register-with-eureka: true
###是否需要从eureka上获取注册信息
fetch-registry: true
建立一个controller包providerController.java
@RestController
public class ProviderController {
@RequestMapping("/getProvider")
public String getProvider() {
return "我是Eureka服务的提供者";
}
}
编写启动类,启动提供者服务
@SpringBootApplication
@EnableEurekaClient
public class AppProvider {
public static void main(String[] args) {
SpringApplication.run(AppProvider .class, args);
}
}
启动Eureka,在服务列表中出现对应的服务别名表示注册到注册中心成功!
编写服务的消费者
添加对应的maven信息依赖
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
</parent>
<!-- 管理依赖 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.M7</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<!-- SpringBoot整合Web组件 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- SpringBoot整合eureka客户端 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
</dependencies>
<!-- 注意: 这里必须要添加, 否者各种依赖有问题 -->
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/libs-milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
添加application.yml配置文件
###服务启动端口号
server:
port: 8001
###服务名称(服务注册到eureka名称)
spring:
application:
name: app-itmayiedu-order
###服务注册到eureka地址
eureka:
client:
service-url:
defaultZone: http://localhost:8100/eureka
###因为该应用为注册中心,不会注册自己
register-with-eureka: true
###是否需要从eureka上获取注册信息
fetch-registry: true
编写控制器类ConsumerController.java,并使用rest方式进行服务的调用
@RestController
public class OrderController {
@Autowired
private RestTemplate restTemplate;
@RequestMapping("/getConsumer")
public String getConsumer() {
// consumer使用rpc 远程调用技术 调用 会员服务
String memberUrl = "http://app-provider-demo/getProvider";
String result = restTemplate.getForObject(memberUrl, String.class);
System.out.println("消费者服务调用提供者服务,result:" + result);
return result;
}
}
编写消费者启动类AppConsumer.java
@SpringBootApplication
@EnableEurekaClient
public class AppOrder {
public static void main(String[] args) {
SpringApplication.run(AppOrder.class, args);
}
// @LoadBalanced就能让这个RestTemplate在请求时拥有客户端负载均衡的能力
// 需要注意的是:使用rest方式调用服务我们需要在消费者的启动类中将模板注入到Spring容器中,让spring来进行统一管理
@Bean
@LoadBalanced
RestTemplate restTemplate() {
return new RestTemplate();
}
}
在浏览器输入消费者的ip地址//getConsumer,就完成了一个简单的消费者服务调用提供者服务啦。
编写不易,厚着脸皮让你们为我点个赞,你们愿意吗