天天看点

SpringCloud基本原理及应用(一)

1.springcloud简介

主要提供了微服务开发所需的配置管理、服务发现、断路器、智能路由、微代理、控制总线、全局锁、决策竞选、分布式会话和集群状态管理等组件。 可以跟spring boot框架一起使用,会让你开发微服务架构的云服务非常好的方便。

2. Springcloud子项目包括

  • Spring Cloud Config:配置管理开发工具包,可以让你把配置放到远程服务器,目前支持本地存储、Git 以及Subversion。
  • Spring Cloud Bus :事件、消息总线,用于在集群(例如,配置变化事件)中传播状态变化,可与SpringCloud Config联合实现热部署。
  • Spring Cloud Netflix :针对多种Netflix组件提供的开发工具包,其中包括Eureka、Hystrix、Zuul、Archaius等。
  • Netflix Eureka :云端负载均衡,一个基于 REST 的服务,用于定位服务,以实现云端的负载均衡和中间层服务器的故障转移。作为服务注册中心对整个微服务架构起着最核心的整合作用 。
  • Netflix Hystrix :容错管理工具,旨在通过控制服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。
  • Netflix Zuul :边缘服务工具,是提供动态路由,监控,弹性,安全等的边缘服务。 提供架构的网关路由服务。
  • Netflix Archaius :配置管理API,包含一系列配置管理API,提供动态类型化属性、线程安全配置操作、轮询框架、回调机制等功能。
  • Spring Cloud for Cloud Foundry :通过Oauth2协议绑定服务到CloudFoundry,CloudFoundry是VMware推出的开源PaaS云平台。
  • Spring Cloud Sleuth :日志收集工具包,封装了Dapper,Zipkin和HTrace操作。
  • Spring Cloud Data Flow :大数据操作工具,通过命令行方式操作数据流。
  • Spring Cloud Security :安全工具包,为你的应用程序添加安全控制,主要是指OAuth2。
  • Spring Cloud Consul :封装了Consul操作,consul是一个服务发现与配置工具,与Docker容器可以无缝集成。
  • Spring Cloud Zookeeper :操作Zookeeper的工具包,用于使用zookeeper方式的服务注册和发现。
  • Spring Cloud Stream :数据流操作开发包,封装了与Redis,Rabbit、Kafka等发送接收消息。
  • Spring Cloud CLI :基于 Spring Boot CLI,可以让你以命令行方式快速建立云组件

3. SpringCloud优点

  1. 约定优于配置
  2. 开箱即用、快速启动
  3. 适用于各种环境
  4. 轻量级的组件
  5. 组件支持丰富,功能齐全

4.实现Eureka注册中心,服务提供者,服务消费者。

1. 实现Eureka注册中心

  • Eureka简介:是Spring Cloud Netflix的核心模块之一,用于云端服务发现,一个基于REST的服务,用于定位服务,以实现云端中间层服务发现和故障转移。
  • 实现步骤
    1. 创建一个maven项目(名称:springcloud-eureka),添加pom.xml文件依赖
<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.lwq</groupId>
  <artifactId>springcloud-eureka</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>springcloud-eureka</name>
  <url>http://maven.apache.org</url>

 <parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.2.RELEASE</version>
<relativePath />
</parent>
<!-- 项目属性配置信息 -->
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<!-- SpringCloud Eureka 注册中心依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
<!-- SpringBoot Test 测试框架 依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<!-- SpringCloud 所有子项目 版本集中管理.MS:统一所有SpringCloud依赖项目的版本 依赖-->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.RC1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<!-- SpringBoot 项目打jar包的Maven插件 -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
<!-- SpringBoot项目打包jar名称 -->
<finalName>eureka</finalName>
</build>
<!-- SpringCloud 官方远程仓库.MS:部分本地仓库和镜像仓库没有SpringCloud子项目依赖。 -->
<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>
           
  1. 配置application.properties文件或application.yml,如下代码application.properties文件内容:
server.port=8888
eureka.instance.hostname=localhost
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
           
  1. 创建SpringBoot入口函数,在项目入口函数上启用注册中心 @EnableEurekaServer
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication
@EnableEurekaServer
public class App 
{
    public static void main( String[] args )
    {
       SpringApplication.run(App.class, args);
    }
}
           
  1. 页面效果示意图
    SpringCloud基本原理及应用(一)

2. 服务提供者

  • provider作用及工作原理:提供所有控制器服务,并把服务注册到Eureka注册中心,供服务消费者订阅调用。在项目中配置Eureka注册中心地址,并把控制器层所有服务暴露给注册中心。
  • 实现步骤:
    1. 创建一个quickstart类型的Maven项目,并命名为springcloud-provider,添加pom.xml依赖:
<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.lwq</groupId>
  <artifactId>springcloud-provider</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>springcloud-provider</name>
  <url>http://maven.apache.org</url>

  <parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.2.RELEASE</version>
<relativePath />
</parent>
<!-- 项目属性配置信息 -->
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<!-- SpringCloud Eureka 客户端 依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
</dependencies>
<!-- SpringCloud 所有子项目 版本集中管理.MS:统一所有SpringCloud依赖项目的版本 依赖 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.RC1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<!-- SpringBoot 项目打jar包的Maven插件 -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
<!-- SpringBoot项目打包jar名称 -->
<finalName>provider</finalName>
</build>
<!-- SpringCloud 官方远程仓库.MS:部分本地仓库和镜像仓库没有SpringCloud子项目依赖。 -->
<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>
           
  1. 在项目配置文件application.properties中配置eureka
eureka.client.serviceUrl.defaultZone=http://localhost:8888/eureka/
server.port=8002
spring.application.name=service-provider
           
  1. 创建控制器服务
import java.util.ArrayList;
import java.util.List;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class UserController {
	@Value("${server.port}")
	private String serverPort;
	/**
	* 访问路径:http://localhost:8002/getFuture
	* @return
	*/
	@RequestMapping("/getFuture")
	public List<String> getFuture() {
	List<String> list = new ArrayList<>();
	list.add("不积跬步,无以至千里;");
	list.add("不积小流,无以成江海。");
	list.add("出自端口号:"+serverPort);
	return list;
	}
}
           
  1. 发布测试调用远程服务,在项目入口函数上启用注册中心 客户端@EnableEurekaClient
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
@EnableEurekaClient
@SpringBootApplication
public class App 
{
    public static void main( String[] args )
    {
    	 SpringApplication.run(App.class, args);
    }
}
           
  1. 页面效果图
    SpringCloud基本原理及应用(一)
  2. Eureka注册中心页面效果图
    SpringCloud基本原理及应用(一)

3.服务消费者

  • RestTemplate作用及工作原理:RestTemplate使用Http协议从Eureka注册中心订阅消费服务。在Spring容器中配置RestTemplate实例Bean,自动注入给service业务层,用来实现远程调用已经在Eureka注册中心注册过的健康服务。
  • 实现步骤:
  1. 创建一个quickstart类型的Maven项目,并命名为 springcloud-consumer-resttemplate,项目pom.xml信息如下
<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.lwq</groupId>
  <artifactId>springcloud-consumer-resttemplate</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>springcloud-consumer-resttemplate</name>
  <url>http://maven.apache.org</url>

  <properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<!-- SpringBoot 项目 统一 父依赖 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.2.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<!-- SpringCloud Eureka 客户端 依赖 -->
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
</dependencies>
<!-- SpringCloud 所有子项目 版本集中管理.MS:统一所有SpringCloud依赖项目的版本 依赖 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.RC1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<!-- SpringBoot 项目打jar包的Maven插件 -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
<!-- SpringBoot项目打包jar名称 -->
<finalName>resttemplate</finalName>
</build>
<!-- SpringCloud 官方远程仓库.MS:部分本地仓库和镜像仓库没有SpringCloud子项目依赖。 -->
<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>
           
  1. 在项目配置文件application.properties中配置eureka
eureka.client.serviceUrl.defaultZone=http://localhost:8888/eureka/
server.port=8001
spring.application.name=service-consumer
           
  1. 使用Spring注解式配置向Spring容器中加入RestTemplate对象
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
@Configuration
public class SpringConfig {
	@Bean
	@LoadBalanced
	public RestTemplate restTemplate() {
		return new RestTemplate();
	}
}
           
  1. 在service层自动注入RestTemplate对象调用eureka注册中心的远程服务
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class ConsumerService {
	@Autowired
	private RestTemplate restTemplate;
	public List<String> getProviderFuture() {
	return restTemplate.getForObject("http://service-provider/getFuture", List.class);
	}
}
           
  1. 编写控制器层调用上一步service层
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.lwq.springcloud_consumer_resttemplate.service.ConsumerService;
@RestController
public class CosumerController {
	@Autowired
	private ConsumerService consumerService;
	/**
	* 项目访问路径:http://localhost:8001/getProviderFuture
	* @return
	*/
	@RequestMapping("/getProviderFuture")
	public List<String> getProviderFuture(){
	return consumerService.getProviderFuture();
	}
}
           
  1. 发布测试调用远程服务
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
@EnableEurekaClient
@SpringBootApplication
public class App 
{
    public static void main( String[] args )
    {
       SpringApplication.run(App.class, args);
    }
}
           
  1. 页面效果图
    SpringCloud基本原理及应用(一)
    8. Eureka注册中心页面效果图
    SpringCloud基本原理及应用(一)

4.消费者Fegin

  • feign作用及工作原理:Feign使用Http协议从Eureka注册中心订阅消费服务。声明接口、抽象方法,分别使用@FeignClient、@RequestMapping注解远程服务名称,服务映射。启用@EnableFeignClients注解会扫描并生成接口的实现类bean,用来远程调用已经在Eureka注册中心注册过的健康服务
  • 实现步骤:
  1. 创建一个quickstart类型的Maven项目,并命名为springcloud-consumer-feign,

    项目pom.xml信息如下

<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.lwq</groupId>
  <artifactId>springcloud-consumer-feign</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>springcloud-consumer-feign</name>
  <url>http://maven.apache.org</url>

  <description>MS:SpringCloud Feign 消费者</description>
<!-- 项目属性配置信息 -->
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<!-- SpringBoot 项目 统一 父依赖 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.2.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<dependencies>
<!-- SpringCloud Eureka 客户端 依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<!-- SpringCloud Feign 依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
</dependencies>
<!-- SpringCloud 所有子项目 版本集中管理.MS:统一所有SpringCloud依赖项目的版本 依赖 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.RC1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<!-- SpringBoot 项目打jar包的Maven插件 -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
<!-- SpringBoot项目打包jar名称 -->
<finalName>feign</finalName>
</build>
<!-- SpringCloud 官方远程仓库.MS:部分本地仓库和镜像仓库没有SpringCloud子项目依赖。 -->
<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>
           
  1. 在项目配置文件application.properties中配置eureka
eureka.client.serviceUrl.defaultZone=http://localhost:8888/eureka/
server.port=8003
spring.application.name=service-consumer02
           
  1. 在service层编写接口、抽象方法,分别使用@FeignClient、@RequestMapping注解远程服务名称,服务映射。
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
@FeignClient("service-provider")
public interface ConsumerService {
@RequestMapping("/getFuture")
public List<String> getProviderFuture();
}
           
  1. 编写控制器层自动注入上一步的接口类型bean
import com.lwq.springcloud_consumer_feign.service.ConsumerService;
@RestController
public class ConsumerController {
	@Autowired
	private ConsumerService consumerService;
	/**
	* http://localhost:8003/getProviderFuture
	* @return
	*/
	@RequestMapping("/getProviderFuture")
	public List<String> getProviderFuture(){
		return consumerService.getProviderFuture();
	}
}
           
  1. 发布测试调用远程服务
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
@EnableFeignClients
@EnableEurekaClient
@SpringBootApplication
public class App 
{
    public static void main( String[] args )
    {
    	SpringApplication.run(App.class, args);

    }
}
           
  1. 页面效果图
    SpringCloud基本原理及应用(一)
  2. Eureka注册中心页面效果图
    SpringCloud基本原理及应用(一)

**总结:

最后值得一提的是SpringCloud相较于Dubbo来说更为全面,拥有服务治理,配置服务,网关路由,异常处理等,比Dubbo更全面,尤其是在结合SpringBoot框架时只需添加依赖,使用方便,简化配置文件。在集群中各功能组件协调工作时使用SpringCloud架构项目能承受更高并发量,具有更强大的容错高可用性。

项目代码下载地址链接: https://pan.baidu.com/s/1Z_mx6vpyOwtbmZisM8BB_Q 提取码: 79xs

继续阅读