現(xiàn)狀

• 請求經(jīng)過zuul，反向代理到內(nèi)部其他子服務(wù) [需要網(wǎng)關(guān)后臺配置子服務(wù)IP]
• 內(nèi)部服務(wù)調(diào)用dubbo；內(nèi)部框架新項(xiàng)目已經(jīng)全部遷移到spring-boot

現(xiàn)狀.png

• 服務(wù)配置ip，一兩臺服務(wù)沒問題，40臺怎么辦？引入注冊中心

遷移思路

• 首先引進(jìn) Eureka，作為注冊中心
• 網(wǎng)關(guān)轉(zhuǎn)發(fā)集成 Eureka (解決配置ip問題)
• 對于內(nèi)部dubbo調(diào)用，可以嘗試在提供一套spring cloud api
• 嘗試所有的服務(wù)都使用jar包啟動
• 所有都http，方便測試

最小spring cloud

image.png

Eureka部署

• 線上需要部署三臺或者兩臺，集群部署

遷移步驟

首先解決網(wǎng)關(guān)Eureka集成問題

• 動態(tài)添加新服務(wù)（還是走網(wǎng)關(guān)后臺）【不用再配置IP】
• 灰度策略修改，使用Eureka

 DynamicServerListLoadBalancer
 

統(tǒng)一ribbon復(fù)雜均衡灰度功能

• 統(tǒng)一ribbon負(fù)載規(guī)則和策略
• 結(jié)合eureka的metamap使用灰度，流量切換等功能
• 思路參考：
  http://blog.springcloud.cn/sc/sc-ribbon-demoted/
  http://blog.maxplus1.com/2017/06/08/Spring%20Cloud%E6%90%AD%E5%BB%BA%E5%88%86%E5%B8%83%E5%BC%8F%E6%9C%8D%E5%8A%A1%E6%B2%BB%E7%90%86%E6%9E%B6%E6%9E%84/

首先規(guī)范eureka的metamap所需要的信息

• eureka http rest api
  https://github.com/Netflix/eureka/wiki/Eureka-REST-operations

遷移

• 在工程中創(chuàng)建一個新的模塊upms-cloud-api
• upms-cloud-api引用原來給dubbo服務(wù)的upms-api

image.png

• 配置eureka

*這樣就只需要添加一套api的接口，dto和其他的都不用改變

• 接口的寫法如下

/**
 * @date: 17/10/24
 */
@FeignClient("upms-service")
@RequestMapping("/upms/skillGroup")
public interface SkillGroupApi {


  /**
   * 獲取員工所屬技能組
   *
   * @param jobNo 員工工號
   * @return
   */
  @GetMapping("/getListByJobNo")
  GrootResult<List<SkillGroupInfoDto>> getListByJobNo(@RequestParam("jobNo") String jobNo);

}

• 關(guān)于微服務(wù)命名的規(guī)范：業(yè)務(wù)服務(wù)都有 xxx-upms-service 命名 xxx最好是業(yè)務(wù)組
• 消費(fèi)方調(diào)用這個接口的時候 引入jar包

      <dependency>
            <groupId>com.yyfq.groot.upms</groupId>
            <artifactId>upms-cloud-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

• 同時配置Feign

@EnableFeignClients(
    basePackageClasses = SkillGroupApi.class
)
@Configurable
public class ApiConfig {

}

• 消費(fèi)方調(diào)用 例子

/**
 * @date: 17/10/24
 */
@Api(tags = "test", description = "測試")
@RestController
@RequestMapping("/test")
public class TestController extends AbstractController {

 // 注入 SkillGroupApi 即可
  @Autowired
  private SkillGroupApi skillGroupApi;


  @ApiOperation("獲取技能組")
  @GetMapping("skillGroup")
  public List<SkillGroupInfoDto> skillGroup(String jobNo) {

    GrootResult<List<SkillGroupInfoDto>> result = skillGroupApi.getListByJobNo(jobNo);

    return result.getResult();
  }
}

服務(wù)調(diào)用規(guī)范

• 是否需要安裝業(yè)務(wù)組，每個組同zuul提供唯一的對外接口
• 組內(nèi)服務(wù)的內(nèi)部調(diào)用使用feign
• 組內(nèi)服務(wù)是否需要分層，下層服務(wù)不能調(diào)用上層服務(wù)
• 通過擴(kuò)展ribbon使用metadata，控制服務(wù)調(diào)用

集成分布式追蹤

• 使用zipkin
• 部署zipkin server

<dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-server</artifactId>
        </dependency>

        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-autoconfigure-ui</artifactId>
        </dependency>

@SpringBootApplication
@EnableZipkinServer
public class ZipkinApplication {

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

• 訪問：http://localhost:9970/