【问题标题】:Trying to get Spring/Consul/Vault to work together试图让 Spring/Consul/Vault 一起工作
【发布时间】:2018-11-30 04:14:24
【问题描述】:

我正在尝试做一些我认为很简单的事情。我想用Consul 进行配置,Vault 用于机密。

我正在寻找一个像这样的简单应用程序,它允许我从 Consul 获取配置和服务,以及从 Vault 获取秘密。

在我的示例中,Consul 和 Vault 是连接的,我可以在 Consul 服务和键值存储中看到 Vault。

在 Postman 中,我可以直接查询 Vault 并在 {{vault_url}}/v1/secret/interservice-bus/data-categorizer 中查看我的数据

现在我在测试应用中看不到 Consul 或 Vault 值。

我的 application.yml 很简单

spring:
  profiles:
    active: dev
  main:
    banner-mode: "CONSOLE"
  application:
    name: test-consul

logging:
  level:
    org: INFO

bootstrap.yml 是我进行大部分配置的地方。其中一些是重复的,因为如果缺少不同的部分,Spring 会抱怨。我不知道为什么。

spring:
    profiles: 
        active: vault, dev
    cloud:
        consul:
            host: 127.0.0.1
            port: 8500
            config:
                enabled: true  
            discovery:
                prefer-ip-address: true
        config:
            discovery:
                enabled: true
                service-id: vault 
            server:
                vault:
                    host: localhost
                    port: 8200
                    scheme: http
                    authentication: TOKEN
                    token: 00000000-0000-0000-0000-000000000000
        vault:            
            host: localhost
            port: 8200
            scheme: http
            connection-timeout: 5000
            read-timeout: 15000
            authentication: TOKEN
            config:
                order: -10
            token: 00000000-0000-0000-0000-000000000000
            discovery:
                enabled: true
                service-id: vault

上面的令牌被遮盖了,但确实与保管库的根令牌匹配。

这是我的 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.0</modelVersion>

    <groupId>edu.dkist</groupId>
    <artifactId>test-consul</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>test-consul</name>
    <description>Small test to see if consul can work with vault</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.8.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.SR4</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-config</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>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-all</artifactId>
        </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>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-consul-dependencies</artifactId>
                <version>1.2.1.RELEASE</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>

这是我正在尝试运行的简单应用程序

package com.example.demo;

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableAutoConfiguration
@RefreshScope
@SpringBootApplication
@EnableDiscoveryClient
public class DemoApplication {
    @Autowired
    org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient;

    @Value("${test}")
    private String testString;


    @Value("${interservice-bus.data-categorizer.username}") 
    private String user;

    @Value("${interservice-bus.data-categorizer.password}")
    private String password;


    @PostConstruct
    public void setRabbitMQLocation() {
            if (discoveryClient == null) {
            System.out.println("******************************ERROR: Discovery Client is null******************************");
            return;
        }
            System.out.println("****************************** Discovery Client is ACTIVE ******************************");

        org.springframework.cloud.client.ServiceInstance serviceInstance =
                discoveryClient.getInstances("interservice-bus")
                        .stream()
                        .findFirst()
                        .orElseThrow(() -> new RuntimeException("ERROR: " + "interservice-bus" + " not found"));
        System.out.println("****************************** ISB is " + serviceInstance.getHost() + ":" + serviceInstance.getPort() + " ******************************");
    }

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

它没有找到“测试”。我正在尝试从 Vault 中提取用户名和密码,并从 Consul 进行测试。

我来了

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2018-06-20 16:30:33.580 ERROR 92722 --- [           main] o.s.boot.SpringApplication               : Application run failed

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'scopedTarget.demoApplication': Injection of autowired dependencies failed; nested exception is java.lang.IllegalArgumentException: Could not resolve placeholder 'test' in value "${test}"

我正在寻找一个像这样的简单应用程序,它允许我从 Consul 获取配置和服务,以及从 Vault 获取秘密。

通过在网上搜索和查看示例,我不清楚是否还需要引入 Vault 依赖项,或者我是否从 Consul 获取所有内容(因此不需要 Vault 依赖项)。

【问题讨论】:

    标签: spring spring-cloud-consul spring-cloud-vault-config


    【解决方案1】:

    要从 Vault 获取配置,您需要将 Spring Cloud Vault 添加到您的 pom。

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

    使用 Spring Cloud Dalston.SR4(您在 pom 中使用)您将收到 Spring Cloud Vault 1.0.2。因此请注意,此版本的内容比新版本少(例如,您不能使用发现功能)。如果您想使用它,请考虑至少使用 Spring Cloud Vault 1.1.1.RELEASE 附带的 Edgware.SR4。您可以随时在此处查看版本信息:https://github.com/spring-projects/spring-cloud/wiki#release-notes。无论如何,它仍然可以工作,但是您需要对其进行配置。 你的bootstrap.yml 应该是这样的。

    spring:
      application:
        name: test-consul
      profiles:
        active: dev
      vault:
        fail-fast: true
        host: localhost
        port: 8200
        scheme: http
        authentication: TOKEN
        config:
          order: -10 # not sure that you need this, didn't investigate
        token: <your_token>
    

    Spring Cloud Vault 将使用 Vault HTTP API 根据您的应用程序名称和配置文件在 Vault 中搜索配置。所以你需要根据下一个模式来存储信息。 (请参阅Spring Cloud Vault 1.0.2 的文档)

    /secret/{application}/{profile}
    /secret/{application}
    /secret/{default-context}/{profile}
    /secret/{default-context}
    

    例子:

    vault write secret/test-consul/dev username=test_user
    

    在这种情况下,在应用程序启动期间,Spring Cloud Vault 将从secret/test-consul/dev 获取属性并从中创建属性源。要获取此测试属性的值,您应该只使用键。示例:

    @Value("${username}")
    private String user;  // will be resolved to "test_user"
    

    从 Consul KV 存储中获取属性是类似的。 bootstrap.yml 文件是:

    spring:
      profiles:
        active: dev
      application:
        name: test-consul
      cloud:
        consul:
          host: localhost
          port: 8500
          config:
            enabled: true
    

    Spring Cloud Consul 将使用下一个模式(全部)使用 HTTP API 从 Consul 获取键值。见documentation for Spring Cloud Consul 1.2.1 (it comes with Dalston.SR4):

    config/testApp,dev/
    config/testApp/
    config/application,dev/
    config/application/
    

    因此您需要相应地保存数据。我从 Consul GUI 中通过在 KV 存储中创建文件夹来完成此操作,使用控制台它应该看起来类似于:

    consul kv put config/test-consul/test testvalue
    

    通过使用 HTTP API 获取数据,Spring Cloud Consul 将根据存储在那里的属性创建一个属性源,您将能够使用它来获取它

    @Value("${test}")
    private String testString; // will be resolved to "testvalue"
    

    您可以组合 2 个配置并同时使用 Spring Cloud Consul 和 Vault。在这个演示中我根本没有使用application.yml。

    希望这篇长文对你有所帮助:)

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2017-09-18
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2017-12-22
      • 2019-07-23
      • 2018-01-11
      相关资源
      最近更新 更多