spring Gateway 和注册中心整合环境搭建1

本博客主要是搭建一个gateway的demo，记录了自己踩过的各种坑
项目目录：

注册中心如下

网关后端访问的应用

网关

我们首先来看注册中心的代码

pom.xml

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.</modelVersion>

  <groupId>com.tuling.cloud</groupId>

  <artifactId>microservice-eureka-server</artifactId>

  <version>0.0.-SNAPSHOT</version>

  <packaging>jar</packaging>

  <!-- 引入spring boot的依赖 -->

  <parent>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-parent</artifactId>

    <version>1.5..RELEASE</version>

  </parent>

  <properties>

    <project.build.sourceEncoding>UTF-</project.build.sourceEncoding>

    <java.version>1.8</java.version>

  </properties>

  <dependencies>

    <dependency>

      <groupId>org.springframework.cloud</groupId>

      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>

    </dependency>

        <!-- spring boot admin监控客户端依赖 -->

    <dependency>

      <groupId>de.codecentric</groupId>

      <artifactId>spring-boot-admin-starter-client</artifactId>

      <version>1.5.</version>

    </dependency>

  </dependencies>

  <!-- 引入spring cloud的依赖 -->

  <dependencyManagement>

    <dependencies>

      <dependency>

        <groupId>org.springframework.cloud</groupId>

        <artifactId>spring-cloud-dependencies</artifactId>

        <version>Edgware.RELEASE</version>

        <type>pom</type>

        <scope>import</scope>

      </dependency>

    </dependencies>

  </dependencyManagement>

  <!-- 添加spring-boot的maven插件 -->

  <build>

    <plugins>

      <plugin>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-maven-plugin</artifactId>

      </plugin>

    </plugins>

  </build>

</project>

EurekaApplication

package com.tuling.cloud.study;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**

 * 使用Eureka做服务发现.

 */

@SpringBootApplication

@EnableEurekaServer

public class EurekaApplication {

  public static void main(String[] args) {

    SpringApplication.run(EurekaApplication.class, args);

  }

}

application.yml

server:

  port:                     # 指定该Eureka实例的端口

eureka:

  client:

    registerWithEureka: false

    fetchRegistry: false

    serviceUrl:

      defaultZone: http://localhost:8761/eureka/

# 参考文档：http://projects.spring.io/spring-cloud/docs/1.0.3/spring-cloud.html#_standalone_mode

# 参考文档：http://my.oschina.net/buwei/blog/618756

接下来我们来看后端应用

pom文件

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.</modelVersion>

  <groupId>com.tuling.cloud</groupId>

  <artifactId>microservice-provider-user</artifactId>

  <version>0.0.-SNAPSHOT</version>

  <packaging>jar</packaging>

  <!-- 引入spring boot的依赖 -->

  <parent>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-parent</artifactId>

    <version>1.5..RELEASE</version>

  </parent>

  <properties>

    <project.build.sourceEncoding>UTF-</project.build.sourceEncoding>

    <java.version>1.8</java.version>

  </properties>

  <dependencies>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-web</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-data-jpa</artifactId>

    </dependency>

    <dependency>

      <groupId>com.h2database</groupId>

      <artifactId>h2</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-netflix-eureka-client</artifactId>

    </dependency>

  </dependencies>

  <!-- 引入spring cloud的依赖 -->

  <dependencyManagement>

    <dependencies>

      <dependency>

        <groupId>org.springframework.cloud</groupId>

        <artifactId>spring-cloud-dependencies</artifactId>

        <version>Edgware.RELEASE</version>

        <type>pom</type>

        <scope>import</scope>

      </dependency>

    </dependencies>

  </dependencyManagement>

  <!-- 添加spring-boot的maven插件 -->

  <build>

    <plugins>

      <plugin>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-maven-plugin</artifactId>

      </plugin>

    </plugins>

  </build>

</project>

schema.sql

drop table user if exists;

create table user (id bigint generated by default as identity, username varchar(), name varchar(), age int(), balance decimal(,), primary key (id));

data.sql

insert into user (id, username, name, age, balance) values (, 'account1', '张三', , 100.00);

insert into user (id, username, name, age, balance) values (, 'account2', '李四', , 180.00);

insert into user (id, username, name, age, balance) values (, 'account3', '王五', , 280.00);

application.yml

server:

  port:

spring:

  application:

    name: microservice-provider-user

  jpa:

    generate-ddl: false

    show-sql: true

    hibernate:

      ddl-auto: none

  datasource:                           # 指定数据源

    platform: h2                        # 指定数据源类型

    schema: classpath:schema.sql        # 指定h2数据库的建表脚本

    data: classpath:data.sql            # 指定h2数据库的数据脚本

logging:                                # 配置日志级别，让hibernate打印出执行的SQL

  level:

    root: INFO

    org.hibernate: INFO

    org.hibernate.type.descriptor.sql.BasicBinder: TRACE

    org.hibernate.type.descriptor.sql.BasicExtractor: TRACE

eureka:

  client:

    serviceUrl:

      defaultZone: http://localhost:8761/eureka/

  instance:

    prefer-ip-address: true

UserRepository采用jpa的方式来访问

package com.tuling.cloud.study.repository;

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

import org.springframework.stereotype.Repository;

import com.tuling.cloud.study.entity.User;

@Repository

public interface UserRepository extends JpaRepository<User, Long> {

}

User

package com.tuling.cloud.study.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;

@Entity

public class User {

  @Id

  @GeneratedValue(strategy = GenerationType.AUTO)

  private Long id;

  @Column

  private String username;

  @Column

  private String name;

  @Column

  private Integer age;

  @Column

  private BigDecimal balance;

  public Long getId() {

    return this.id;

  }

  public void setId(Long id) {

    this.id = id;

  }

  public String getUsername() {

    return this.username;

  }

  public void setUsername(String username) {

    this.username = username;

  }

  public String getName() {

    return this.name;

  }

  public void setName(String name) {

    this.name = name;

  }

  public Integer getAge() {

    return this.age;

  }

  public void setAge(Integer age) {

    this.age = age;

  }

  public BigDecimal getBalance() {

    return this.balance;

  }

  public void setBalance(BigDecimal balance) {

    this.balance = balance;

  }

}

UserController

package com.tuling.cloud.study.controller;

import java.util.Random;

import org.apache.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.cloud.client.serviceregistry.Registration;

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.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import com.tuling.cloud.study.entity.User;

import com.tuling.cloud.study.repository.UserRepository;

@RestController

public class UserController {

  private final Logger logger = Logger.getLogger(getClass());

  @Autowired

  private UserRepository userRepository;

  @Autowired

  private Registration registration;

  @GetMapping("/{id}")

  public User findById(@PathVariable Long id) throws Exception {

      logger.info("用户中心接口：查询用户"+ id +"信息");

      Thread.sleep();

      User findOne = userRepository.findOne(id);

      System.out.println("usernana is :"+findOne.getName());

      return findOne;

  }

  @GetMapping("/getIpAndPort")

  public String findById() {

      return registration.getHost() + ":" + registration.getPort();

  }

  @RequestMapping(value = "/aa", method = RequestMethod.GET)

  public String  aa(){

      return "aaaaaaa";

  }

}

ProviderUserApplication

package com.tuling.cloud.study;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@EnableDiscoveryClient

@SpringBootApplication

public class ProviderUserApplication {

  public static void main(String[] args) {

    SpringApplication.run(ProviderUserApplication.class, args);

  }

}

应用启动之后，我们可以通过下面的地址来访问

接下来网关的搭建，网关我们使用最新springboot 2.2.1版本

pom

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.</modelVersion>

    <groupId>com.weiyuan</groupId>

    <artifactId>com.weiyuan.gateway</artifactId>

    <version>0.0.-SNAPSHOT</version>

    <!--父工程 -->

    <parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>2.2..RELEASE</version>

    </parent>

    <properties>

        <project.build.sourceEncoding>UTF-</project.build.sourceEncoding>

        <project.reporting.outputEncoding>UTF-</project.reporting.outputEncoding>

        <java.version>1.8</java.version>

        <spring-cloud.version>Hoxton.RELEASE</spring-cloud.version>

    </properties>

    <dependencies>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-actuator</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-starter-gateway</artifactId>

        </dependency>

        <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-devtools</artifactId>

            <scope>runtime</scope>

        </dependency>

        <dependency>

            <groupId>org.projectlombok</groupId>

            <artifactId>lombok</artifactId>

            <optional>true</optional>

        </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>${spring-cloud.version}</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>

</project>

这里需要特别的是：

注意此处不可添加spring-boot-starter-web的依赖，否则会报错。gateway是用过webflux实现，和spring MVC有冲突(因此项目中包含shiro框架，不能包含HttpServletRequest,HttpServletResponse等)，如果想要使用shiro，建议将shiro单独作为一个项目，整合eurake充当服务提供者，gateway项目中在自定义的filter中调用shiro服务，即根据cookie的值来判断该强求是否能通过验证。

其实现依赖Netty与WebFlux，不是传统的Servlet编程模型，学习成本高
不能将其部署在Tomcat、 Jetty等Servlet容器里，只能打成jar包执行
需要Spring Boot 2.0及以上的版本，才支持

application.yml

spring:

  application:

    name: gateway-service

  cloud:        # spring cloud gateway 路由配置方式

    gateway:

      discovery:  #是否与服务发现组件进行结合，通过 serviceId(必须设置成大写) 转发到具体的服务实例。默认为false，设为true便开启通过服务中心的自动根据 serviceId 创建路由的功能。

        locator:

          enabled: true     #路由访问方式：http://Gateway_HOST:Gateway_PORT/大写的serviceId/**，其中微服务应用名默认大写访问。

      routes:

      - id:                      #网关路由到网易官网

        uri: http://www.163.com/

        predicates:

          - Path=//**

      - id: ORDER-SERVICE           #网关路由到订单服务order-service

        uri: lb://microservice-provider-user   #lb开头是使用到了eurake，ws是用到了websocket

        predicates:

          - Path=/sc/**

        filters: # 过滤器,请求在传递过程中可以通过过滤器对其进行一定的修改

          - StripPrefix=1 # 转发之前去掉1层路径

server:

  port: 5001

logging:

  level:

    org.springframework.cloud.gateway: trace

    org.springframework.http.server.reactive: debug

    org.springframework.web.reactive: debug

    reactor.ipc.netty: debug

eureka:

  client:

    service-url:

      defaultZone: http://localhost:8761/eureka/

feign:

  hystrix:

    enabled: true

uri: lb://microservice-provider-user 这里microservice-provider-user是我们后端访问的应用在注册中心上的名字，必须是大写，

predicates:
- Path=/sc/**

表示访问的时候我们访问的路径上需要添加一个前缀sc，如果访问的路径不是以http://localhost:5001/sc/*开头的路径，就会被网关拒绝

filters: # 过滤器,请求在传递过程中可以通过过滤器对其进行一定的修改
- StripPrefix=1 # 转发之前去掉1层路径

表示在路由转发之前要去掉1层路径

如访问http://localhost:5001/sc/a/1开头的路径，经过filter之后会转发到/a/1这个后端微服务的路径，将第一层/sc给去掉

ApiGatewayApplication

package com.itheima;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication

@EnableDiscoveryClient

public class ApiGatewayApplication {

    public static void main(String[] args) {

        SpringApplication.run(ApiGatewayApplication.class);

    }

}

接下来我们启动网关：http://localhost:5001/sc/2就可以转发后端的应用了

巴特西

spring Gateway 和注册中心整合环境搭建1

最新文章

热门文章