初識SpringCloud微服務

時間 2019-11-11

標籤 springcloud 微服简体版

原文原文鏈接

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

微服務的實現方式不少，可是最火的莫過於Spring Cloud了。爲何？mysql

後臺硬：做爲Spring家族的一員，有整個Spring全家桶靠山，背景十分強大。程序員
技術強：Spring做爲Java領域的前輩，能夠說是功力深厚。有強力的技術團隊支撐，通常人還真比不了web
羣衆基礎好：能夠說大多數程序員的成長都伴隨着Spring框架，試問：如今有幾家公司開發不用Spring？SpringCloud與Spring的各個框架無縫整合，對你們來講一切都是熟悉的配方，熟悉的味道。spring
使用方便：相信你們都體會到了SpringBoot給咱們開發帶來的便利，而SpringCloud徹底支持SpringBoot的開發，用不多的配置就能完成微服務框架的搭建sql

一:簡介

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

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

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

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/> 
</parent>

<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：

<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>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<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);
}
}