#!/usr/bin/env bash./gradlew clean bootRun

└── order-backend    ├── gradle // 文件夹，用于放置所有Gradle配置    ├── src // 文件夹，Java源代码    ├── idea.sh //生成IntelliJ工程    ├── local-build.sh // 提交之前的本地构建    └── run.sh // 本地运行

├── gradle│   ├── checkstyle│   │   ├── checkstyle.gradle│   │   └── checkstyle.xml

├── order│   ├── OrderApplicationService.java│   ├── OrderController.java│   ├── OrderNotFoundException.java│   ├── OrderRepository.java│   ├── OrderService.java│   └── model│       ├── Order.java│       ├── OrderFactory.java│       ├── OrderId.java│       ├── OrderItem.java│       └── OrderStatus.java

└── product    ├── Product.java    ├── ProductApplicationService.java    ├── ProductController.java    ├── ProductId.java    └── ProductRepository.java

└── common    ├── configuration    ├── exception    ├── loggin    └── utils

sourceSets {    componentTest {        compileClasspath += sourceSets.main.output + sourceSets.test.output        runtimeClasspath += sourceSets.main.output + sourceSets.test.output    }
    apiTest {        compileClasspath += sourceSets.main.output + sourceSets.test.output        runtimeClasspath += sourceSets.main.output + sourceSets.test.output    }}

apply plugin: 'docker-compose'
dockerCompose {    useComposeFiles = ['docker/mysql/docker-compose.yml']}
bootRun.dependsOn composeUpcomponentTest.dependsOn composeUpapiTest.dependsOn composeUp

 protected void doFilterInternal(HttpServletRequest request,HttpServletResponse response,FilterChain filterChain)            throws ServletException, IOException {    //request id in header may come from Gateway, eg. Nginx    String headerRequestId = request.getHeader(HEADER_X_REQUEST_ID);    MDC.put(REQUEST_ID, isNullOrEmpty(headerRequestId) ? newUuid() : headerRequestId);    try {        filterChain.doFilter(request, response);    } finally {        clearMdc();    }    }

<appender name="REDIS" class="com.cwbase.logback.RedisAppender">    <tags>ecommerce-order-backend-${ACTIVE_PROFILE}</tags>    <host>elk.yourdomain.com</host>    <port>6379</port>    <password>whatever</password>    <key>ecommerce-ordder-log</key>    <mdc>true</mdc>    <type>redis</type></appender>

public abstract class AppException extends RuntimeException {    private final ErrorCode code;    private final Map<String, Object> data = newHashMap();}

public class OrderNotFoundException extends AppException {    public OrderNotFoundException(OrderId orderId) {        super(ErrorCode.ORDER_NOT_FOUND, ImmutableMap.of("orderId", orderId.toString()));    }}

public final class ErrorDetail {    private final ErrorCode code;    private final int status;    private final String message;    private final String path;    private final Instant timestamp;    private final Map<String, Object> data = newHashMap();}

{  requestId: "d008ef46bb4f4cf19c9081ad50df33bd",  error: {    code: "ORDER_NOT_FOUND",    status: 404,    message: "没有找到订单",    path: "/order",    timestamp: 1555031270087,    data: {      orderId: "123456789"    }  }}

@Configuration@EnableAsync@EnableSchedulingpublic class SchedulingConfiguration implements SchedulingConfigurer {
    @Override    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {        taskRegistrar.setScheduler(newScheduledThreadPool(10));    }
    @Bean(destroyMethod = "shutdown")    @Primary    public TaskExecutor taskExecutor() {        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();        executor.setCorePoolSize(2);        executor.setMaxPoolSize(5);        executor.setQueueCapacity(10);        executor.setTaskDecorator(new LogbackMdcTaskDecorator());        executor.initialize();        return executor;    }
}

@Configuration@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")public class DistributedLockConfiguration {
    @Bean    public LockProvider lockProvider(DataSource dataSource) {        return new JdbcTemplateLockProvider(dataSource);    }
    @Bean    public DistributedLockExecutor distributedLockExecutor(LockProvider lockProvider) {        return new DistributedLockExecutor(lockProvider);    }
}

 @Scheduled(cron = "0 0/1 * * * ?")    @SchedulerLock(name = "scheduledTask", lockAtMostFor = THIRTY_MIN, lockAtLeastFor = ONE_MIN)    public void run() {        logger.info("Run scheduled task.");    }为了支持代码直接调用分布式锁，基于Shedlock的LockProvider创建DistributedLockExecutor：
public class DistributedLockExecutor {    private final LockProvider lockProvider;
    public DistributedLockExecutor(LockProvider lockProvider) {        this.lockProvider = lockProvider;    }
    public <T> T executeWithLock(Supplier<T> supplier, LockConfiguration configuration) {        Optional<SimpleLock> lock = lockProvider.lock(configuration);        if (!lock.isPresent()) {            throw new LockAlreadyOccupiedException(configuration.getName());        }
        try {            return supplier.get();        } finally {            lock.get().unlock();        }    }
}

   public String doBusiness() {        return distributedLockExecutor.executeWithLock(() -> "Hello World.",                new LockConfiguration("key", Instant.now().plusSeconds(60)));    }

./run.sh

{  requestId: "698c8d29add54e24a3d435e2c749ea00",  buildNumber: "unknown",  buildTime: "unknown",  deployTime: "2019-04-11T13:05:46.901+08:00[Asia/Shanghai]",  gitRevision: "unknown",  gitBranch: "unknown",  environment: "[local]"}

@Configuration@EnableSwagger2@Profile(value = {"local", "dev"})public class SwaggerConfiguration {
    @Bean    public Docket api() {        return new Docket(SWAGGER_2)                .select()                .apis(basePackage("com.ecommerce.order"))                .paths(any())                .build();    }}

resources/├── db│   └── migration│       ├── V1__init.sql│       └── V2__create_product_table.sql

@Configurationpublic class CorsConfiguration {    @Bean    public WebMvcConfigurer corsConfigurer() {        return new WebMvcConfigurer() {            @Override            public void addCorsMappings(CorsRegistry registry) {                registry.addMapping("/**");            }        };    }}

@EnableWebSecuritypublic class WebSecurityConfig extends WebSecurityConfigurerAdapter {
    @Override    protected void configure(HttpSecurity http) throws Exception {        http            // by default uses a Bean by the name of corsConfigurationSource            .cors().and()            ...    }
    @Bean    CorsConfigurationSource corsConfigurationSource() {        CorsConfiguration configuration = new CorsConfiguration();        configuration.setAllowedOrigins(Arrays.asList("https://example.com"));        configuration.setAllowedMethods(Arrays.asList("GET","POST"));        UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();        source.registerCorsConfiguration("/**", configuration);        return source;    }}