загрузить значения маршрутов netflix zuul из базы данных - PullRequest
Новая
       30

загрузить значения маршрутов netflix zuul из базы данных

0 голосов
/ 28 июня 2018

Я изучал технологию API-шлюзов netflix zuul. Я разобрался со всеми вещами на месте и смог направить свой apis с помощью zuul URL прокси. Ниже мой код:

Основной класс 

package com.example.springbootzuulgatwayproxy;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
import org.springframework.context.annotation.Bean;

import com.example.springbootzuulgatwayproxy.filters.ErrorFilter;
import com.example.springbootzuulgatwayproxy.filters.PostFilter;
import com.example.springbootzuulgatwayproxy.filters.PreFilter;
import com.example.springbootzuulgatwayproxy.filters.RouteFilter;

@SpringBootApplication
@EnableZuulProxy
public class SpringBootZuulgatwayproxyApplication {

    public static void main(String[] args) {

        SpringApplication.run(SpringBootZuulgatwayproxyApplication.class, args);
    }

    @Bean
    public PreFilter preFilter() {
        return new PreFilter();
    }
    @Bean
    public PostFilter postFilter() {
        return new PostFilter();
    }
    @Bean
    public ErrorFilter errorFilter() {
        return new ErrorFilter();
    }
    @Bean
    public RouteFilter routeFilter() {
        return new RouteFilter();
    }
}

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.0</modelVersion>

    <groupId>com.example</groupId>
    <artifactId>spring-boot-zuulgatwayproxy</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>spring-boot-zuulgatwayproxy</name>
    <description>Demo project for Spring Boot</description>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.4.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>
        <spring-cloud.version>Dalston.SR2</spring-cloud.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-actuator</artifactId> 
            </dependency> -->


        <dependency>
            <groupId>commons-configuration</groupId>
            <artifactId>commons-configuration</artifactId>
            <version>1.9</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zuul</artifactId>
        </dependency>






        <!-- <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-rest</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>${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>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.3</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>


</project>

application.properties 

zuul.routes.employee.url=http://localhost:8090
zuul.routes.employee2.url=http://localhost:8090
server.port=8080

и затем есть 4 класса фильтров (Pre, Route, Post и Error), все расширяющие класс ZuulFilter.

все работает нормально. но теперь требуется, чтобы все поля zuul.routes.[entity].url в файле application.properties были загружены из базы данных вместе со значениями url. Как я могу достичь этого требования. Пожалуйста посоветуй. Я попытался предварительно заполнить / обновить файл application.properties с похожими ключами. Был в состоянии обновить / записать файл application.properties, но реальных эффектов не происходит во время выполнения. Что я должен сделать для того, чтобы установить ключи маршрута, определенные в файле свойств, для динамической загрузки из базы данных mysql.

1 Ответ

0 голосов
/ 28 июня 2018

Обновление маршрутов в application.properties не приводит к автоматической перезагрузке компонента ZuulProperties. Независимо от того, где хранятся маршруты, вам потребуется компонент, подобный следующему:

@Primary @Bean(name = "zuulConfigProperties") @RefreshScope @ConfigurationProperties("zuul") public ZuulProperties zuulProperties() { ... }

ОБНОВЛЕНИЕ для включения конфигурации маршрутов: 

zuul:
  ignoredServices: "*"
  routes:
    zuulDemo1:
      path: /zuul2/**
      serviceId: demo-zuul-api1
# stripPrefix set to true if context path is set to /
      stripPrefix: true

Это описано в блоге, который я написал, Маршрутизация запросов и динамическое обновление маршрутов с использованием Spring Cloud Zuul Server , хотя он не хранит маршруты в БД, но в файле с поддержкой Bitbucket у него есть WebHook, который отправляет запрос POST на сервер Zuul, который затем публикует сообщение для брокера (RabbitMQ) для подписчиков, чтобы получить набор изменений.

...