【第35回】AWS CloudFormationを用いた基盤自動化(15)SpringCloudAWSを利用したFrontend Webアプリケーションにおけるスタック情報の取得・設定¶

package org.debugroom.mynavi.sample.cloudformation.frontend.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;

@Configuration
public class RedisConfig {

    @Bean
    public RedisSerializer<Object> springSessionDefaultRedisSerializer() {
        return new GenericJackson2JsonRedisSerializer();
    }

}

package org.debugroom.mynavi.sample.cloudformation.frontend.config;

import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class S3Config {

    @Bean
    public AmazonS3 amazonS3(){
        return AmazonS3ClientBuilder.standard().build();
    }
}

package org.debugroom.mynavi.sample.cloudformation.frontend.config;

import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.sqs.AmazonSQSAsync;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.cloud.aws.context.config.annotation.EnableStackConfiguration;
import org.springframework.cloud.aws.messaging.core.QueueMessagingTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.session.data.redis.config.ConfigureRedisAction;
import org.springframework.web.client.RestOperations;

import org.debugroom.mynavi.sample.cloudformation.common.apinfra.cloud.aws.S3Info;
import org.debugroom.mynavi.sample.cloudformation.common.apinfra.cloud.aws.SQSInfo;
import org.debugroom.mynavi.sample.cloudformation.common.apinfra.cloud.aws.CloudFormationStackInfo;
import org.debugroom.mynavi.sample.cloudformation.common.apinfra.log.interceptor.MDCLoggingInterceptor;

@Profile("dev")                                                                              // …(A)
@EnableStackConfiguration(stackName = "mynavi-sample-infra-dev")                             // …(B)
@Configuration
public class DevConfig {

    private static final String BACKEND_SERVICE_DNS = "http://localhost:8080";               // …(C)
    private static final String S3_STACK_NAME = "S3DevStack";
    private static final String S3_BUCKET_EXPORT = "MynaviSampleS3Bucket-Dev";               // …(D)
    private static final String SQS_STACK_NAME = "SQSDevStack";
    private static final String SQS_QUEUE_EXPORT = "MynaviSampleSQS-Dev";
    private static final String SQS_ENDPOINT_EXPORT = "MynaviSampleSQS-Dev-ServiceEndpoint"; // …(E)
    private static final String SQS_REGION_EXPORT = "MynaviSampleSQS-Dev-Region";
    private static final String ELASTICACHE_STACK_NAME = "ElastiCacheDevStack";              // …(F)
    private static final String ELASTICACHE_ENDPOINT_EXPORT = "mynavi-sample-cloudformation-vpc-ElastiCacheRedisEndPoint-Dev";
    private static final String ELASTICACHE_PORT_EXPORT = "mynavi-sample-cloudformation-vpc-ElastiCacheRedisPort-Dev";

    @Bean
    public RestOperations restOperations(RestTemplateBuilder restTemplateBuilder){           // …(G)
        return restTemplateBuilder.rootUri(BACKEND_SERVICE_DNS)
          .interceptors(new MDCLoggingInterceptor()).build();
    }

    @Bean
    CloudFormationStackInfo cloudFormationStackInfo(){                                       // …(H)
        return new CloudFormationStackInfo();
    }

    @Bean
    S3Info s3Info(){                                                                         // …(I)
        return S3Info.builder()
          .bucketName(cloudFormationStackInfo()
                  .getExportValue(S3_STACK_NAME, S3_BUCKET_EXPORT))
          .build();
    }

    @Bean
    SQSInfo sqsInfo(){                                                                       // …(J)
        return SQSInfo.builder()
          .queueName(cloudFormationStackInfo().getExportValue(
                  SQS_STACK_NAME, SQS_QUEUE_EXPORT))
          .build();
    }

    @Autowired
    AmazonSQSAsync amazonSQSAsync;                                                           // …(K)

    @Bean
    public AwsClientBuilder.EndpointConfiguration endpointConfiguration(){                   // …(L)
        return new AwsClientBuilder.EndpointConfiguration(
          cloudFormationStackInfo().getExportValue(
                  SQS_STACK_NAME, SQS_ENDPOINT_EXPORT),
          cloudFormationStackInfo().getExportValue(
                  SQS_STACK_NAME, SQS_REGION_EXPORT));
    }

    @Bean
    public QueueMessagingTemplate queueMessagingTemplate(){                                  // …(M)
        return new QueueMessagingTemplate(amazonSQSAsync);
    }

    /*
     * ElasitiCache is not permitted public access, use local redis server except dev environment in vpc.
     */
    @Bean
    public ConfigureRedisAction configureRedisAction() {                                     // …(N)
        return ConfigureRedisAction.NO_OP;
    }

    @Bean
    public LettuceConnectionFactory lettuceConnectionFactory(){                              // …(O)
        return new LettuceConnectionFactory(
          cloudFormationStackInfo().getExportValue(
                  ELASTICACHE_STACK_NAME, ELASTICACHE_ENDPOINT_EXPORT),
              Integer.valueOf(cloudFormationStackInfo().getExportValue(
                  ELASTICACHE_STACK_NAME, ELASTICACHE_PORT_EXPORT)));
    }

}

package org.debugroom.mynavi.sample.cloudformation.frontend.config;

// omit

@Profile("staging")
@EnableStackConfiguration(stackName = "mynavi-sample-infra-staging")
@Configuration
public class StagingConfig {

    private static final String PROTOCOL = "http://";
    private static final String ALB_STACK_NAME = "ALBStagingStack";
    private static final String ALB_BACKEND_ALB_EXPORT_NAME = "mynavi-sample-cloudformation-vpc-BackendALBDNS-Staging";
    private static final String S3_STACK_NAME = "S3StagingStack";
    private static final String S3_BUCKET_EXPORT = "MynaviSampleS3Bucket-Staging";
    private static final String SQS_STACK_NAME = "SQSStagingStack";
    private static final String SQS_QUEUE_EXPORT = "MynaviSampleSQS-Staging";
    private static final String SQS_ENDPOINT_EXPORT = "MynaviSampleSQS-Staging-ServiceEndpoint";
    private static final String SQS_REGION_EXPORT = "MynaviSampleSQS-Staging-Region";
    private static final String ELASTICACHE_STACK_NAME = "ElastiCacheStagingStack";
    private static final String ELASTICACHE_ENDPOINT_EXPORT = "mynavi-sample-cloudformation-vpc-ElastiCacheRedisEndPoint-Staging";
    private static final String ELASTICACHE_PORT_EXPORT = "mynavi-sample-cloudformation-vpc-ElastiCacheRedisPort-Staging";

    @Bean
    CloudFormationStackInfo cloudFormationStackInfo(){
        return new CloudFormationStackInfo();
    }

    @Bean
    public RestOperations restOperations(RestTemplateBuilder restTemplateBuilder){
        return restTemplateBuilder.rootUri(PROTOCOL + cloudFormationStackInfo().getExportValue(
           ALB_STACK_NAME , ALB_BACKEND_ALB_EXPORT_NAME))
             .interceptors(new MDCLoggingInterceptor()).build();
    }

    @Bean
    S3Info s3Info(){
        return S3Info.builder()
             .bucketName(cloudFormationStackInfo()
                     .getExportValue(S3_STACK_NAME, S3_BUCKET_EXPORT))
             .build();
    }

    @Bean
    SQSInfo sqsInfo(){
        return SQSInfo.builder()
             .queueName(cloudFormationStackInfo().getExportValue(
                     SQS_STACK_NAME, SQS_QUEUE_EXPORT))
             .build();
    }

    @Autowired
    AmazonSQSAsync amazonSQSAsync;

    @Bean
    public AwsClientBuilder.EndpointConfiguration endpointConfiguration(){
        return new AwsClientBuilder.EndpointConfiguration(
             cloudFormationStackInfo().getExportValue(
                     SQS_STACK_NAME, SQS_ENDPOINT_EXPORT),
             cloudFormationStackInfo().getExportValue(
                     SQS_STACK_NAME, SQS_REGION_EXPORT));
    }

    @Bean
    public QueueMessagingTemplate queueMessagingTemplate(){
        return new QueueMessagingTemplate(amazonSQSAsync);
    }

    @Bean
    public ConfigureRedisAction configureRedisAction() {
        return ConfigureRedisAction.NO_OP;
    }

    @Bean
    public LettuceConnectionFactory lettuceConnectionFactory(){
        return new LettuceConnectionFactory(
             cloudFormationStackInfo().getExportValue(
                     ELASTICACHE_STACK_NAME, ELASTICACHE_ENDPOINT_EXPORT),
             Integer.valueOf(cloudFormationStackInfo().getExportValue(
                     ELASTICACHE_STACK_NAME, ELASTICACHE_PORT_EXPORT)));
    }