码迷,mamicode.com
首页 > 编程语言 > 详细

简单Spring Cloud 微服务框架搭建

时间:2019-11-18 12:43:53      阅读:87      评论:0      收藏:0      [点我收藏+]

标签:dep   ogg   www   artifact   end   types   ribbon   关键字   blank   

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

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

一般情况下,基本的微服务框架包含:框架:注册中心、负载均衡、声明式服务(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为对应的服务名

 

 

简单Spring Cloud 微服务框架搭建

标签:dep   ogg   www   artifact   end   types   ribbon   关键字   blank   

原文地址:https://www.cnblogs.com/salmonLeeson/p/11881093.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!