淺談SpringCloud實現(xiàn)簡單的微服務架構

更新時間：2018年01月10日 14:25:01 作者：lynnlovemin

Spring Cloud是一系列框架的有序集合，本文就使用SpringCloud實現(xiàn)一套簡單的微服務架構，具有一定的參考價值，感興趣的小伙伴們可以參考一下

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的開發(fā)便利性巧妙地簡化了分布式系統(tǒng)基礎設施的開發(fā)，如服務發(fā)現(xiàn)注冊、配置中心、消息總線、負載均衡、斷路器、數(shù)據(jù)監(jiān)控等，都可以用Spring Boot的開發(fā)風格做到一鍵啟動和部署。Spring并沒有重復制造輪子，它只是將目前各家公司開發(fā)的比較成熟、經(jīng)得起實際考驗的服務框架組合起來，通過Spring Boot風格進行再封裝屏蔽掉了復雜的配置和實現(xiàn)原理，最終給開發(fā)者留出了一套簡單易懂、易部署和易維護的分布式系統(tǒng)開發(fā)工具包。

接下來我們就使用SpringCloud實現(xiàn)一套簡單的微服務架構。

以下所有代碼都已開源到github上了，地址：https://github.com/lynnlovemin/softservice

Eureka(服務注冊與發(fā)現(xiàn))

首先引入相關的依賴包

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.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.cloud</groupId>
      <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-eureka-server</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
  </dependencies>

  <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>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

  <repositories>
    <repository>
      <id>spring-milestones</id>
      <name>Spring Milestones</name>
      <url>https://repo.spring.io/milestone</url>
      <snapshots>
        <enabled>false</enabled>
      </snapshots>
    </repository>
  </repositories>

配置application.yml

server:
 port: 8761
eureka:
 instance:
  hostname: localhost
 client:
  registerWithEureka: false
  fetchRegistry: false
  serviceUrl:
   defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

創(chuàng)建啟動類Application

@EnableEurekaServer
@SpringBootApplication
public class Application {

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

運行main方法，瀏覽器訪問：http://localhost:8761，我們就能在瀏覽器看到如下界面：

說明eureka啟動成功。

接下來，我們實現(xiàn)負債均衡、斷路器、網(wǎng)關、客戶端，所有的服務都應該注冊到eureka中，并且訪問eureka就能看到所有注冊的服務

client(客戶端)

pom.xml

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.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.cloud</groupId>
      <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
  </dependencies>

  <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>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

  <repositories>
    <repository>
      <id>spring-milestones</id>
      <name>Spring Milestones</name>
      <url>https://repo.spring.io/milestone</url>
      <snapshots>
        <enabled>false</enabled>
      </snapshots>
    </repository>
  </repositories>

application.yml

eureka:
 client:
  serviceUrl:
   defaultZone: http://localhost:8761/eureka/ #這里注冊到eureka中
server:
 port: 8763
spring:
 application:
  name: service-hi

Application類

@SpringBootApplication
@EnableEurekaClient
@RestController
public class Application {

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

  @Value("${server.port}")
  String port;
  //這里我們提供一個接口
  @RequestMapping("/hi")
  public String home(@RequestParam String name) {
    return "hi "+name+",i am from port:" +port;
  }
}

Feign(負債均衡、斷路器)

pom.xml

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.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.cloud</groupId>
      <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-feign</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
  </dependencies>

  <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>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

  <repositories>
    <repository>
      <id>spring-milestones</id>
      <name>Spring Milestones</name>
      <url>https://repo.spring.io/milestone</url>
      <snapshots>
        <enabled>false</enabled>
      </snapshots>
    </repository>
  </repositories>

application.yml

eureka:
 client:
  serviceUrl:
   defaultZone: http://localhost:8761/eureka/
server:
 port: 8765
spring:
 application:
  name: service-feign
feign:
 hystrix:
  enabled: true

Application類

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
@EnableHystrixDashboard
public class Application {

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

然后再提供一個service，他的作用就是做負債均衡和斷路器功能

@FeignClient(value = "service-hi",fallback = SchedualServiceHiHystric.class)
public interface SchedualServiceHi {
  @RequestMapping(value = "/hi",method = RequestMethod.GET)
  String sayHiFromClientOne(@RequestParam(value = "name") String name);
}

@Component
public class SchedualServiceHiHystric implements SchedualServiceHi {
  @Override
  public String sayHiFromClientOne(String name) {
    return "sorry "+name;
  }
}

FeignClient我們指定之前創(chuàng)建client時指定的name:service-hi,fallback指定服務不可用時的返回數(shù)據(jù)，這樣我們啟動多個client時就可以看到http請求時會交替訪問不同的feign端口，當停掉clien時再訪問接口會返回錯誤信息。

zuul(服務網(wǎng)關)

在一般情況下，我們不會直接暴露客戶端給外部，而是通過服務網(wǎng)關來轉發(fā)，內(nèi)部服務都是在局域網(wǎng)內(nèi)通信，外部訪問不了，通過服務網(wǎng)關，我們還可以統(tǒng)一做接口的安全性校驗，統(tǒng)一攔截，請看代碼：

pom.xml

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.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.cloud</groupId>
      <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-zuul</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
  </dependencies>

  <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>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

  <repositories>
    <repository>
      <id>spring-milestones</id>
      <name>Spring Milestones</name>
      <url>https://repo.spring.io/milestone</url>
      <snapshots>
        <enabled>false</enabled>
      </snapshots>
    </repository>

application.yml

eureka:
 client:
  serviceUrl:
   defaultZone: http://localhost:8761/eureka/
server:
 port: 8080
spring:
 application:
  name: service-zuul
zuul:
 routes:
  api-b:
   path: /api/**
   serviceId: service-feign #凡是以api開始的請求都訪問service-feign服務

Application類

@EnableZuulProxy
@EnableEurekaClient
@SpringBootApplication
public class Application {

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

啟動Application，訪問：http://localhost:8080/api/hi，就能訪問到之前我們定義的接口，接下來我們做接口的攔截：

/**
 * filterType：返回一個字符串代表過濾器的類型，在zuul中定義了四種不同生命周期的過濾器類型，具體如下：
 pre：路由之前
 routing：路由之時
 post： 路由之后
 error：發(fā)送錯誤調(diào)用
 filterOrder：過濾的順序
 shouldFilter：這里可以寫邏輯判斷，是否要過濾，本文true,永遠過濾。
 run：過濾器的具體邏輯?？捎煤軓碗s，包括查sql，nosql去判斷該請求到底有沒有權限訪問。
 */
@Component
public class MyFilter extends ZuulFilter{

  private static Logger log = LoggerFactory.getLogger(MyFilter.class);
  @Override
  public String filterType() {
    return "pre";
  }

  @Override
  public int filterOrder() {
    return 0;
  }

  @Override
  public boolean shouldFilter() {
    return true;
  }

  @Override
  public Object run() {
    RequestContext ctx = RequestContext.getCurrentContext();
    HttpServletRequest request = ctx.getRequest();
    log.info(String.format("%s >>> %s", request.getMethod(), request.getRequestURL().toString()));
    Object accessToken = request.getParameter("token");
    if(accessToken == null) {
      log.warn("token is empty");
      ctx.setSendZuulResponse(false);
      ctx.setResponseStatusCode(401);
      try {
        ctx.getResponse().getWriter().write("token is empty");
      }catch (Exception e){}

      return null;
    }
    log.info("ok");
    return null;
  }
}

這樣我們在調(diào)用接口前會先執(zhí)行MyFilter類中的run方法，在這個方法里可以做一系列安全驗證，比如token。

好了，一個簡單的微服務架構就已經(jīng)搭建完成了。

以上所有代碼都已開源到github上了，地址：https://github.com/lynnlovemin/softservice

以上所述是小編給大家介紹的SpringCloud實現(xiàn)簡單的微服務架構，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復

您可能感興趣的文章:

JavaWeb項目Servlet無法訪問問題解決
這篇文章主要介紹了JavaWeb項目Servlet無法訪問問題解決,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2019-11-11
Java中的內(nèi)部類使用詳情
說起內(nèi)部類這個詞，想必很多人都不陌生，但是又會覺得不熟悉。原因是平時編寫代碼時可能用到的場景不多，用得最多的是在有事件監(jiān)聽的情況下，并且即使用到也很少去總結內(nèi)部類的用法。今天我們就來一探究竟
2022-03-03
SpringBoot3集成Quartz的示例代碼
Quartz由Java編寫的功能豐富的開源作業(yè)調(diào)度框架,可以集成到幾乎任何Java應用程序中,并且能夠創(chuàng)建多個作業(yè)調(diào)度,在實際的業(yè)務中,有很多場景依賴定時任務,比如常見的：訂單超時處理,業(yè)務識別和預警通知等,本文介紹了SpringBoot3如何集成Quartz
2023-08-08
詳解java中面向對象設計模式類與類的關系
這篇文章主要介紹了java面向對象設計模式中類與類之間的關系，下面小編和大家一起來學習一下吧
2019-05-05
java實現(xiàn)滑動驗證解鎖
這篇文章主要為大家詳細介紹了java實現(xiàn)滑動驗證解鎖，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2020-07-07
java反射_改變private中的變量及方法的簡單實例
下面小編就為大家?guī)硪黄猨ava反射_改變private中的變量及方法的簡單實例。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2016-06-06
Java創(chuàng)建和啟動線程的兩種方式實例分析
這篇文章主要介紹了Java創(chuàng)建和啟動線程的兩種方式,結合實例形式分析了java多線程創(chuàng)建、使用相關操作技巧與注意事項,需要的朋友可以參考下
2019-09-09
SpringBoot實現(xiàn)版本升級到2.7.18
這篇文章主要介紹了SpringBoot實現(xiàn)版本升級到2.7.18全過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2024-08-08
JAVA之讀取properties時路徑的注意問題
這篇文章主要介紹了JAVA之讀取properties時路徑的注意問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2023-08-08
springboot的LogbackLoggingSystem配置加載流程解析
這篇文章主要介紹了springboot的LogbackLoggingSystem配置加載流程源碼分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
2023-11-11