简单Spring Cloud 微服务框架搭建

Posted 2020-11-22 salmonLeeson

微服务是现在比较流行的技术，对于程序猿而言，了解并搭建一个基本的微服务框架是很有必要滴。

微服务包含的内容非常多，一般小伙伴们可以根据自己的需求不断添加各种组件、框架。

一般情况下，基本的微服务框架包含：框架：注册中心、负载均衡、声明式服务(feign)、容错(hystrix)、网关(权限)gateway 和 配置(resource)

注册中心：现在比较常用的有eureka、nacos

负载均衡：包括feign、ribbon等技术，相关对比可以参考另一位老哥的博客：《负载均衡之feign与ribbon对比》

服务间调用：包括resttemplate、feign等等

熔断：hystrix

网关：gateway，（zuul已经逐渐被弃用）

配置中心：config server 、 config clent

本章主要采用 eureka+feign+hystrix+gateway+config 的组合搭建一个基础框架，环境采用idea。

注册中心 

首先新建一个spring工程，spring-boot版本可以选择， 2.1.9.RELEASE。

在新建的project上右键，新建module，选择Spring Initializr

 

下一步，设置对应的包名，artifact名称，这些可以根据自己的项目需要自己命名。

next，

 

 然后下一步，完成即可。这种方式是直接将Spring管网上对应的module下载到你的项目中，非常方便。

然后再application.yml文件中设置你对应的注册中心的端口，访问方式等信息。

server:
  port: 8761

eureka:
  instance:

    hostname: localhost
  client:
    #自己是注册中心，不需要注册自己
    registerWithEureka: false
    #自己是注册中心不需要发现服务
    fetchRegistry: false
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

在启动类中加入对应注解：

@SpringBootApplication
//声明自己是注册中心
@EnableEurekaServer
public class HsddEurekaApplication {

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

}

　　

 业务逻辑服务 

业务逻辑服务可以按功能或逻辑进行分类，分成多个微服务来提供，保证整体的可用性。

在project中新建一个目录，比如，service目录。将业务逻辑相关的微服务都放到这里面。

新建spring boot modul，同上面一样，不过可以不选spring cloud配置项。

 

 然后再main.java下面创建对应的各层目录，这里没啥好说的。

在application启动类中，我们需要添加对应注解，

package com.fencer.userdemo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableEurekaClient　　#注册到注册中心
@EnableFeignClients　　#服务间负载均衡与声名式服务
public class UserDemoApplication {

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

} 

在业务逻辑微服务中，需要配置application.yml，需要将你的服务注册到注册中心，才能被发现调用

#服务端口
server:
  port: 8762

spring:
  application:
    name: user-demo   #注册的服务名称
  profiles:
    active: dev
  devtools:
    restart:
      enabled: true
      trigger-file: devtools.tg

#注册中心地址
eureka:
  instance:
    prefer-ip-address: true
    instance-id: 127.0.0.1:${server.port}
    hostname: localhost
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
    register-with-eureka: true
    fetch-registry: true

　　

 服务间声明式调用及熔断

服务间声明式调用及熔断比较简单，

新建一个业务逻辑服务，在启动类中加入feign、hystrix相关注解

package com.fencer.orderdemo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients　　
@EnableHystrix  //熔断
public class OrderDemoApplication {

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

}

　　创建一个调用对象的接口，接口与服务提供方，方法名、参数完全一致

package com.fencer.orderdemo.service;

import com.fencer.orderdemo.fallback.MyFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * @author : 
 * @version V1.0
 * @Project: hsdd
 * @Package com.fencer.orderdemo.service
 * @Description: TODO
 * @date Date : 2019年10月23日 19:49
 */
@FeignClient(value = "user-demo", fallback = MyFallback.class)
public interface UserDemoFeignService {

    @RequestMapping(value = "/user/{id}", method = RequestMethod.GET)
    String getUser(@PathVariable("id") int id);

    @RequestMapping(value = "/hi", method = RequestMethod.GET)
    String home(@RequestParam String name);
}

　　添加统一降级处理方法，在服务提供方没有响应时进行处理。

package com.fencer.orderdemo.fallback;

import com.fencer.orderdemo.service.UserDemoFeignService;
import org.springframework.stereotype.Component;

/**
 * @author : 
 * @version V1.0
 * @Project: hsdd
 * @Package
 * @Description: TODO
 * @date Date : 2019年10月24日 10:46
 */
@Component
public class MyFallback implements UserDemoFeignService {

    //    添加服务降级处理方法
    @Override
    public String getUser(int id) {
        return "error getUser";
    }

    @Override
    public String home(String name) {
        return "error home Method";
    }
}

　　在application.yml中配置feign相关配置项

#服务启动端口号
server:
  port: 8763
#服务名称
spring:
  application:
    name: order-demo

#服务注册到eureka服务端地址
eureka:
  instance:
    prefer-ip-address: true
  #    instance-id: 127.0.0.1:${server.port}
  #    hostname: localhost
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
    register-with-eureka: true
    fetch-registry: true

feign:
  hystrix:
    enabled: true #允许开启hystrix功能
  compression:
    request:
      enabled: true #开启请求压缩
      mime-types: text/html,application/xml,application/json # 设置压缩的数据类型
      min-request-size: 2048 # 设置触发压缩的大小下限
    response:
      enabled: true #开启响应压缩
  client:
    config:
      default:
        connectTimeout: 10000   #连接超时时间(ms)
        readTimeout: 10000      # 通信超时时间(ms)

#ribbon:
#  ConnectTimeout: 5000 # 连接超时时间(ms)
#  ReadTimeout: 5000 # 通信超时时间(ms)
#  OkToRetryOnAllOperations: true # 是否对所有操作重试
#  MaxAutoRetriesNextServer: 1 # 同一服务不同实例的重试次数
#  MaxAutoRetries: 1 # 同一实例的重试次数

　

 网关gateway

新建一个网关服务

 

 在pom中需要加入对应依赖

<!-- 引入gateway网关依赖 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>

        <!--  添加eureka注册中心客户端依赖 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <!-- 添加熔断依赖 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

        <!-- 监控中心 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

　　网关的重点在yml配置文件中，

server:
  port: 8081

spring:
  application:
    name: hsdd-gateway
  cloud:
    gateway:
      discovery:
        locator:
          ##gateway开启服务注册和发现的功能
          enabled: true
          ##将请求路径上的服务名配置为小写
          lower-case-service-id: true

#eureka注册地址
eureka:
  instance:
    prefer-ip-address: true
    instance-id: 127.0.0.1:${server.port}
    hostname: localhost
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

logging:
  level:
    org.springframework.cloud.gateway: debug
    org.springframework.http.server.reactive: debug
    org.springframework.web.reactive: debug
    reactor.ipc.netty: debug

feign:
  hystrix:
    enabled: true

　　

spring:
  cloud:
    gateway:
      routes:
      - id: test
        uri: http://www.ityouknow.com/springcloud
        predicates:
        - Path=/user/**

　　以上两种方式都可以进行网关配置。第一种时自动发现注册服务，服务名为你自己命名的微服务名称

第二种，需要手动配置，在Path中配置上关键字，uri为对应的服务名