初識SpringCloud微服務

微服務是一種架構方式，最終肯定需要技術架構去實施。

微服務的實現方式很多，但是最火的莫過於Spring Cloud了。為什么？

• 后台硬：作為Spring家族的一員，有整個Spring全家桶靠山，背景十分強大。

• 技術強：Spring作為Java領域的前輩，可以說是功力深厚。有強力的技術團隊支撐，一般人還真比不了

• 群眾基礎好：可以說大多數程序員的成長都伴隨着Spring框架，試問：現在有幾家公司開發不用Spring？SpringCloud與Spring的各個框架無縫整合，對大家來說一切都是熟悉的配方，熟悉的味道。

• 使用方便：相信大家都體會到了SpringBoot給我們開發帶來的便利，而SpringCloud完全支持SpringBoot的開發，用很少的配置就能完成微服務框架的搭建

一:簡介

SpringCloud是Spring旗下的項目之一，官網地址：http://projects.spring.io/spring-cloud/

Spring最擅長的就是集成，把世界上最好的框架拿過來，集成到自己的項目中。

SpringCloud也是一樣，它將現在非常流行的一些技術整合到一起，實現了諸如：配置管理，服務發現，智能路由，負載均衡，熔斷器，控制總線，集群狀態等等功能。其主要涉及的組件包括：

netflix

• Eureka：注冊中心

• Zuul：服務網關

• Ribbon：負載均衡

• Feign：服務調用

• Hystix：熔斷器

以上只是其中一部分，架構圖：

二:微服務場景模擬

  首先，我們需要模擬一個服務調用的場景。方便后面學習微服務架構

 2.1.服務提供者

 我們新建一個項目，對外提供查詢用戶的服務。

 2.1.1.Spring腳手架創建工程

 借助於Spring提供的快速搭建工具：

 填寫項目信息：

 添加web依賴：

 

 添加mybatis依賴：

  填寫項目位置：

 生成的項目結構：

 依賴也已經全部自動引入：

<?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.leyou.demo</groupId>
<artifactId>user-service-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>user-service-demo</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.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>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>

 當然，因為要使用通用mapper，所以我們需要手動加一條依賴：

<dependency>
    <groupId>tk.mybatis</groupId>
    <artifactId>mapper-spring-boot-starter</artifactId>
    <version>2.0.2</version>
</dependency>

 非常快捷啊！

 2.1.2.編寫代碼

 添加一個對外查詢的接口：

@RestController
@RequestMapping("user")
public class UserController {
​
    @Autowired
    private UserService userService;
​
    @GetMapping("/{id}")
    public User queryById(@PathVariable("id") Long id) {
        return this.userService.queryById(id);
   }
}

 Service：

@Service
public class UserService {
​
    @Autowired
    private UserMapper userMapper;
​
    public User queryById(Long id) {
        return this.userMapper.selectByPrimaryKey(id);
   }
}

mapper:

@Mapper
public interface UserMapper extends tk.mybatis.mapper.common.Mapper<User>{
}

實體類：

@Table(name = "tb_user")
public class User implements Serializable {
​
    private static final long serialVersionUID = 1L;
​
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
​
    // 用戶名
    private String userName;
​
    // 密碼
    private String password;
​
    // 姓名
    private String name;
​
    // 年齡
    private Integer age;
​
    // 性別，1男性，2女性
    private Integer sex;
​
    // 出生日期
    private Date birthday;
​
    // 創建時間
    private Date created;
​
    // 更新時間
    private Date updated;
​
    // 備注
    private String note;
​
   // 。。。省略getters和setters
}
​

屬性文件,這里我們采用了yaml語法，而不是properties：

server:
 port: 8081
spring:
 datasource:
   url: jdbc:mysql://localhost:3306/mydb01
   username: root
   password: 123
   hikari:
     maximum-pool-size: 20
     minimum-idle: 10
mybatis:
 type-aliases-package: com.leyou.userservice.pojo

項目結構：

2.1.3.啟動並測試：

啟動項目，訪問接口：http://localhost:8081/user/7

2.2.服務調用者

2.2.1.創建工程

與上面類似，這里不再贅述，需要注意的是，我們調用user-service的功能，因此不需要mybatis相關依賴了。

pom：

<?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.leyou.demo</groupId>
<artifactId>user-consumer-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>user-consumer-demo</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.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>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 添加OkHttp支持 -->
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>3.9.0</version>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

2.2.2.編寫代碼

首先在啟動類中注冊RestTemplate：

@SpringBootApplication
public class UserConsumerDemoApplication {

@Bean
public RestTemplate restTemplate() {
// 這次我們使用了OkHttp客戶端,只需要注入工廠即可
return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
}

public static void main(String[] args) {
SpringApplication.run(UserConsumerDemoApplication.class, args);
}
}

然后編寫UserDao，注意，這里不是調用mapper查數據庫，而是通過RestTemplate遠程查詢user-service-demo中的接口：

@Component
public class UserDao {

@Autowired
private RestTemplate restTemplate;

public User queryUserById(Long id){
String url = "http://localhost:8081/user/" + id;
return this.restTemplate.getForObject(url, User.class);
}
}

然后編寫user-service，循環查詢UserDAO信息：

@Service
public class UserService {

@Autowired
private UserDao userDao;

public List<User> querUserByIds(List<Long> ids){
List<User> users = new ArrayList<>();
for (Long id : ids) {
User user = this.userDao.queryUserById(id);
users.add(user);
}
return users;
}
}

編寫controller：

@RestController
@RequestMapping("consume")
public class ConsumerController {

@Autowired
private UserService userService;

@GetMapping
public List<User> consume(@RequestParam("ids") List<Long> ids) {
return this.userService.queryUserByIds(ids);
}
}

2.2.3.啟動測試：

因為我們沒有配置端口，那么默認就是8080，我們訪問：http://localhost:8080/consume?ids=6,7,8

一個簡單的遠程服務調用案例就實現了。

簡單回顧一下，剛才我們寫了什么：

• use-service-demo：一個提供根據id查詢用戶的微服務

• consumer-demo：一個服務調用者，通過RestTemplate遠程調用user-service-demo

流程如下：

存在什么問題？

• 在consumer中，我們把url地址硬編碼到了代碼中，不方便后期維護

• consumer需要記憶user-service的地址，如果出現變更，可能得不到通知，地址將失效

• consumer不清楚user-service的狀態，服務宕機也不知道

• user-service只有1台服務，不具備高可用性

• 即便user-service形成集群，consumer還需自己實現負載均衡

其實上面說的問題，概括一下就是分布式服務必然要面臨的問題：

• 服務管理

  • 如何自動注冊和發現

  • 如何實現狀態監管

  • 如何實現動態路由

• 服務如何實現負載均衡--- (動態路由)

• 服務如何解決容災問題

• 服務如何實現統一配置

以上的問題，我們都將在Eureka注冊中心中得到答案。