SpringCloud學習(二)：微服務入門實戰項目搭建

 

一、開始使用Spring Cloud實戰微服務

1、SpringCloud是什么？

雲計算的解決方案？不是

SpringCloud是一個在SpringBoot的基礎上構建的一個快速構建分布式系統的工具集（全家桶）。

SpringCloud擁有SpringBoot的特點。

2、關於SpringCloud的版本？

　　大部分spring軟件的版本是以：主版本.次版本.增量版本.里程碑版本的形式命名。

Spring Cloud Angel SR6???

　　Angel是SpringCloud的一個大版本，Service Release6版本，標識一個bug修復的版本。

3、SpringCloud的特點？

　　1)、約定優於配置

　　2)、開箱即用、快速啟動

　　3)、適用於各種環境（PC Server、雲環境、Subtopic、容器Docker）

　　4)、輕量級的組件（如服務發現中整合的Eureka）

　　5)、組件支持很豐富、功能很齊全（如提供配置中心、注冊中心、智能路由…）

　　6)、選型中立（服務發現中使用Eureka、Zookeeper、Consul等都可以）

二、需要的技術儲備

　　1、java（scala、Groovy…均可）

　　2、構建工具

　　　　1)、Maven

　　　　2)、Gradle

　　　　　　將maven項目轉換成gradle項目：（在pom文件的上一級目錄執行如下命令，使用cmd操作）

　　　　　　gradle init --type pom

　　　　3)、SpringBoot：http://cnblogs.com/mmzs/category/1192166.html

三、使用的軟件版本

　　1、原則：使用最新的版本進行講解

　　2、JDK 1.8

　　3、Maven 3.3.9

　　4、IDE（Spring Tool Suite 3.8.2、IDEA、Eclipse）

　　5、Spring Boot

　　6、SpringCloud Camden SR1

建議：大家學習時，盡量使用相同的版本進行選擇，避免采坑

SpringCloud學習(二)：開始使用Spring Cloud實戰微服務

四、創建工程

1、創建調用關系的微服務

創建存在調用關系的微服務，調用關系如下

服務消費者：服務的調用方，調用別的微服務的微服務(即：依賴其他服務的服務)

服務提供者：服務的被調用方，提供API的微服務(即：為其他服務提供服務的服務)

2、編寫一個服務提供者

登陸：http://start.spring.io/

填寫信息：

(1)、將生成的maven工程導入eclipse

然后一次創建如下選中的類和配置文件。

(2)、data.sql和schema.sql

insert into user(id,username, name, age, balance) values(1,'liubei', '劉備', 20, 100.00);
insert into user(id,username, name, age, balance) values(2,'guanyu', '關羽', 20, 100.00);
insert into user(id,username, name, age, balance) values(3,'zhangfei', '張飛', 20, 100.00);
insert into user(id,username, name, age, balance) values(4,'machao', '馬超', 20, 100.00);

drop table user if exists;
create table user(
    id bigint generated by default as identity,
    username varchar(40),
    name varchar(20),
    age int(3),
    balance decimal(10,2), 
    primary key(id)
);

(3)、配置文件application.yml

server:
  # 服務器端口號
  port: 6900
spring:
  jpa:
    # 是否生成ddl語句
    generate-ddl: false
    # 是否打印sql語句
    show-sql: true
    hibernate:
      # 自動生成ddl，由於指定了具體的ddl，此處設置為none
      ddl-auto: none
  datasource:
    # 使用H2數據庫
    platform: h2
    # 指定生成數據庫的schema文件位置
    schema: classpath:schema.sql
    # 指定插入數據庫語句的腳本位置
    data: classpath:data.sql
    
# 配置日志打印信息    
logging:
  level:
    root: INFO
    org.hibernate: INFO
    org.hibernate.type.descriptor.sql.BasicBinder: TRACE
    org.hibernate.type.descriptor.sql.BasicExtractor: TRACE
    com.itmuch: DEBUG

(4)、創建UserController

package com.mmzs.cloud.controller;

import javax.annotation.Resource;
import javax.websocket.server.PathParam;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.mmzs.cloud.UserRepository;
import com.mmzs.cloud.entity.User;

/**
 * @author: mmzsit
 * @date:   2018年8月17日
 * @Description: 
 * 博客地址：https://www.cnblogs.com/mmzs/p/9282412.html
 * @version V1.0
*/
@RestController
public class UserController {
    
    @Resource
    private UserRepository userRepository;
    
    //第一種方式
    @GetMapping("/user/{id}")
    //第二種方式
    //@RequestMapping(value="/xxx",method=org.springframework.web.bind.annotation.RequestMethod.GET)
    //第一種和第二種方式其實是等效的
    public User findById(@PathVariable Long id){
        return this.userRepository.getOne(id);
    }
}

(5)、創建UserRepository

package com.mmzs.cloud;


import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

import com.mmzs.cloud.entity.User;

/**
 * @author: mmzsit
 * @date:   2018年8月17日
 * @Description: 
 * 博客地址：https://www.cnblogs.com/mmzs/p/9282412.html
 * @version V1.0
*/
@Repository
public interface UserRepository extends JpaRepository<User, Long>{

    /**
     * @Description: 
     * @param:  @param id
     * @param:  @return
     * @return: User
     * @throws
    */
//    User findOne(Long id);

    

}

(6)、創建實體類User

package com.mmzs.cloud.entity;

import java.math.BigDecimal;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;

/**
 * @author: mmzsit
 * @date:   2018年8月17日
 * @Description: 
 * 博客地址：https://www.cnblogs.com/mmzs/p/9282412.html
 * @version V1.0
*/
@Entity
@JsonIgnoreProperties(value = { "hibernateLazyInitializer", "handler" })
public class User {
    
    @SuppressWarnings("unused")
    private static final long serialVersionUID = 1L;
    
    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    private Long id;
    @Column
    private String username;
    @Column
    private String name;
    @Column
    private Short age;
    @Column
    private BigDecimal balance;
    
    public Long getId() {
        return id;
    }
    public String getUsername() {
        return username;
    }
    public String getName() {
        return name;
    }
    public Short getAge() {
        return age;
    }
    public BigDecimal getBalance() {
        return balance;
    }
    public void setId(Long id) {
        this.id = id;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public void setName(String name) {
        this.name = name;
    }
    public void setAge(Short age) {
        this.age = age;
    }
    public void setBalance(BigDecimal balance) {
        this.balance = balance;
    }
    
}

注：此處采用的是jpa，使用的是h2數據庫，如果訪問時出現實體類轉化json格式錯誤，則需要在實體類前面加上如下這句注釋：

@JsonIgnoreProperties(value = { "hibernateLazyInitializer", "handler" })

錯誤提示：disable SerializationFeature.FAIL_ON_EMPTY_BEANS

(7)、執行MicroserviceSimpleProviderUserApplication類，然后進行訪問測試

 

3、編寫一個服務消費者

登陸：http://start.spring.io/

填寫信息：

(1)、將生成的maven工程導入eclipse

然后一次創建如下選中的類和配置文件。

(2)、配置文件application.yml

server:
  port: 6901

(3)、創建GoodsController

package com.mmzs.cloud.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import com.mmzs.cloud.entity.User;

/**
 * @author: mmzsit
 * @date: 2018年8月17日
 * @Description: 博客地址：https://www.cnblogs.com/mmzs/p/9282412.html
 * @version V1.0
 */
@RestController
public class GoodsController {
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/goods/{id}")
    public User findById(@PathVariable Long id) {
        //采用了硬編碼注冊user服務
        return this.restTemplate.getForObject("http://localhost:6900/user/" + id, User.class);
    }
}

(4)、創建實體類User

package com.mmzs.cloud.entity;

import java.io.Serializable;
import java.math.BigDecimal;

/**
 * @author: mmzsit
 * @date:   2018年8月17日
 * @Description: 
 * 博客地址：https://www.cnblogs.com/mmzs/p/9282412.html
 * @version V1.0
*/

public class User implements Serializable{
    
    private static final long serialVersionUID = -7125209803403015533L;
    
    private Long id;
    private String username;
    private String name;
    private Short age;
    private BigDecimal balance;
    public Long getId() {
        return id;
    }
    public void setId(Long id) {
        this.id = id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Short getAge() {
        return age;
    }
    public void setAge(Short age) {
        this.age = age;
    }
    public BigDecimal getBalance() {
        return balance;
    }
    public void setBalance(BigDecimal balance) {
        this.balance = balance;
    }
    
}

(5)、在MicroserviceSimpleConsumerGoodsApplication類中注入Bean

 其中11-16行表示注入的Bean

package com.mmzs.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class MicroserviceSimpleConsumerGoodsApplication {
    
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
    //12、13、14、行相當於16行
    //private RestTemplate restTemplate = new RestTemplate();

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

(5)、執行MicroserviceSimpleConsumerGoodsApplication類，然后進行訪問測試

4、小小優化一下

主要優化的點是在GoodsController類中的硬編碼部分。簡單優化如下：

@RestController
public class GoodsController {
    @Autowired
    private RestTemplate restTemplate;

    //優化部分
    @Value("${user.userServicePath}")
    private String userServicePath; 
    
    //優化后此處的硬編碼字符串，修改為變量獲取
    @GetMapping("/goods/{id}")
    public User findById(@PathVariable Long id) {
        //采用了硬編碼注冊user服務
        return this.restTemplate.getForObject(this.userServicePath + id, User.class);
    }
}

這樣子的話，userServicePath的具體值需要通過配置文件application.yml來配置，故application.yml文件修改為：

server:
  port: 6901
# 優化部分
user:
  userServicePath: http://localhost:6900/user/

注： 其實這樣子的優化也不是很好，因為當微服務過多時，層層調用，需要修改的部分也會越來越多，不便於維護和修改。具體措施，詳見下回分解。

五、代碼下載

點擊這里跳轉

如果需要積分的話，其實大家沒必要消耗積分進行下載，按照文章內容一步一步來，絕對是可以完美測試成功的，動手過程，讓影響更加深刻，不是嗎?