一、spring cloud 微服务架构
二、一步一步 搭建spring cloud应用
service client
Service:提供服务的应用,端口是 808x的形式Client:调用服务的应用 端口是809x的形式整个程序以根据client端根据用户id调用服务端程序返回用户信息做示例。
- 1、两个单体spring boot应用调用本节讲的比较简单,分别新建两个普通的spring boot 应用,不使用任何spring cloud相关的东西,service 端提供一个restful接口服务,client端通过RestTemplate来进行调用首先只需要创建两个单独的Spring boot应用,服务端的端口为8081,客户端的端口是8071,然后在客户端用RestTemplate 调用即可,服务端的代码不贴了,就是用spring initializr 创建的一个普通的spring boot web项目,主要是说一下客户端的调用。
配置RestTemplate
@Configuration
public class ConfigurationBean {
private SimpleClientHttpRequestFactory getHttpRequestFactory(){
SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
factory.setConnectTimeout(10000);
factory.setReadTimeout(10000);
return factory;
调用方式
@RestController
@RequestMapping("/client/user")
public class UserApi {
@Autowired
private RestTemplate restTemplate;
@RequestMapping("/{id}")
public String getUser(@PathVariable("id") String id){
String forObject = restTemplate.getForObject("http://localhost:8081/user/1", String.class);
return forObject;
}
}
分别启动service和client,通过调用访问http://localhost:8080/client/user/1,返回服务端数据,当然restTemplate还有很多其他的方法可用,自己在实际使用的时候可以去探究。
- 2、以上就完成了两个微服务间通信,客户端调用服务端的接口,功能完毕,但是这指定不是我们想要的姿势,我们在客户端,使用restTemplate写死了服务端的地址。在实际的生产环境中,我们的服务端不可能只有一台,我们的服务端也不可能只有一台机器。我们将面临以下问题:
- 横向扩展服务
- 服务端和客户端机器上下线
为了解决不想写死服务端的地址,并且能动态的切换对服务端机器的调用的问题,引入注册中心的概念,说起来注册中心,我们通常会想起来zookeeper,但是spring cloud中并没有采用zookeeper,而是采用了Eureka,zookeeper和Eureka对于保证CAP定理中的方式不同,zookeeper比较注重CP(一致性,分区耐受性),而对于Eureka来说重点保证AP(一致性和分区耐受性)。注册中心有了,那客户端的请求是如何分发到相应某一台服务器上呢,也许我们用过nginx,nginx通过配置服务器的权重, ip hash或者随机以及轮训这些策略进行分配服务器,对于spring cloud 来说,干这个活的是Ribbon。接下来就通过改造第一步的项目来让它支持以上这些需求。首先需要搭建一个EurekaServer,也就是注册中心,和zookeeper是一个需要安装的软件不同,Eureka是一个内置在spring boot start中的一个应用程序,我们只需要引入spring-boot-start-eureka,然后启动项目即可。在这之前说一下EurekaServer和我们应用程序的关系。
EurekaServer 作为注册中心,接收服务端的注册一级客户端对服务端服务列表的请求, Eureka Client内嵌到应用程序中,用于注册服务或者获取服务。
搭建EurekaServer
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.wtf.cloud</groupId>
<artifactId>eureka-server</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>eureka-server</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.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.M8</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
<version>1.4.3.RELEASE</version>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-parent</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
</project>
main文件
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaServerApplication.class, args);
}
}
配置文件 application.yml
server:
port: 8888
spring:
application:
name: eureka-server
eureka:
client:
register-with-eureka: false
fetch-registry: false
serviceUrl:
defaultZone: http://localhost:8888/eureka/
应用的端口为8888
应用名称:eureka-server然后是配置eureka的相关东西在默认设置下,改服务注册中心也会将自己组委客户端来尝试注册它自己,所以我们需要禁止它的客户端行为
eureka.client.register-with-eureka=false
由于该应用属于注册中心,所以设置为false,代表不像注册中心注册自己
eureka.client.fetch-registry=false
由于注册中心的职责是维护服务实例,它并不需要去检索服务,所以也设置为false。更多配置可以参照EurekaInstanceConfigBean 和EurekaClientConfigBean
启动服务访问http://localhost:8888/ 可以看到如下界面: