|
|
@@ -1,107 +1,106 @@
|
|
|
-package cn.com.qmth.examcloud.task.starter;
|
|
|
-
|
|
|
-import org.slf4j.MDC;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.boot.SpringApplication;
|
|
|
-import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
|
|
-import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|
|
-import org.springframework.boot.autoconfigure.domain.EntityScan;
|
|
|
-import org.springframework.boot.autoconfigure.web.MultipartAutoConfiguration;
|
|
|
-import org.springframework.cloud.client.loadbalancer.LoadBalanced;
|
|
|
-import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
|
|
|
-import org.springframework.context.annotation.Bean;
|
|
|
-import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
|
|
|
-import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
|
|
|
-import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|
|
-import org.springframework.data.redis.core.RedisTemplate;
|
|
|
-import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
|
|
|
-import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|
|
-import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
-import org.springframework.scheduling.quartz.SchedulerFactoryBean;
|
|
|
-import org.springframework.web.client.RestTemplate;
|
|
|
-import org.springframework.web.multipart.MultipartResolver;
|
|
|
-import org.springframework.web.multipart.commons.CommonsMultipartResolver;
|
|
|
-
|
|
|
-import com.fasterxml.jackson.annotation.JsonAutoDetect;
|
|
|
-import com.fasterxml.jackson.annotation.PropertyAccessor;
|
|
|
-import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
-
|
|
|
-import cn.com.qmth.examcloud.commons.base.logging.ExamCloudLog;
|
|
|
-import cn.com.qmth.examcloud.commons.base.logging.ExamCloudLogFactory;
|
|
|
-import cn.com.qmth.examcloud.commons.base.logging.SLF4JImpl;
|
|
|
-import cn.com.qmth.examcloud.commons.web.redis.RedisClient;
|
|
|
-import cn.com.qmth.examcloud.commons.web.redis.RedisClientImpl;
|
|
|
-import cn.com.qmth.examcloud.commons.web.support.CustomResponseErrorHandler;
|
|
|
-import cn.com.qmth.examcloud.commons.web.support.SpringContextHolder;
|
|
|
-import cn.com.qmth.examcloud.task.starter.config.JobsStartup;
|
|
|
-
|
|
|
-@SpringBootApplication(scanBasePackages = {"cn.com.qmth"})
|
|
|
-@EnableJpaRepositories(basePackages = {"cn.com.qmth"})
|
|
|
-@EntityScan(basePackages = {"cn.com.qmth"})
|
|
|
-@EnableJpaAuditing
|
|
|
-@EnableEurekaClient
|
|
|
-@EnableScheduling
|
|
|
-@EnableAutoConfiguration(exclude = {MultipartAutoConfiguration.class})
|
|
|
-public class TaskApp {
|
|
|
-
|
|
|
- private static final ExamCloudLog LOG = ExamCloudLogFactory.getLog(TaskApp.class);
|
|
|
-
|
|
|
- public static void main(String[] args) throws Exception {
|
|
|
- if (LOG instanceof SLF4JImpl) {
|
|
|
- MDC.put("TRACE_ID", Thread.currentThread().getName());
|
|
|
- }
|
|
|
-
|
|
|
- SpringApplication application = new SpringApplication(TaskApp.class);
|
|
|
- application.run(args);
|
|
|
-
|
|
|
- JobsStartup jobsStartup = SpringContextHolder.getBean(JobsStartup.class);
|
|
|
- jobsStartup.start();
|
|
|
- }
|
|
|
-
|
|
|
- @Bean
|
|
|
- @LoadBalanced
|
|
|
- public RestTemplate restTemplate() {
|
|
|
- RestTemplate restTemplate = new RestTemplate();
|
|
|
- restTemplate.setErrorHandler(new CustomResponseErrorHandler());
|
|
|
- return restTemplate;
|
|
|
- }
|
|
|
-
|
|
|
- @Bean
|
|
|
- public RedisTemplate<String, Object> redisTemplate(
|
|
|
- RedisConnectionFactory redisConnectionFactory) {
|
|
|
- RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
|
|
|
- redisTemplate.setConnectionFactory(redisConnectionFactory);
|
|
|
- Jackson2JsonRedisSerializer<?> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(
|
|
|
- Object.class);
|
|
|
- ObjectMapper objectMapper = new ObjectMapper();
|
|
|
- objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
|
|
- objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
|
|
|
- jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
|
|
|
- redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
|
|
|
- redisTemplate.setKeySerializer(new StringRedisSerializer());
|
|
|
- redisTemplate.afterPropertiesSet();
|
|
|
- return redisTemplate;
|
|
|
- }
|
|
|
-
|
|
|
- @Bean
|
|
|
- @Autowired
|
|
|
- public RedisClient redisClient(RedisTemplate<String, Object> redisTemplate) {
|
|
|
- return new RedisClientImpl(redisTemplate);
|
|
|
- }
|
|
|
-
|
|
|
- @Bean(name = "schedulerFactoryBean")
|
|
|
- public SchedulerFactoryBean schedulerFactory() {
|
|
|
- return new SchedulerFactoryBean();
|
|
|
- }
|
|
|
-
|
|
|
- @Bean(name = "multipartResolver")
|
|
|
- public MultipartResolver multipartResolver() {
|
|
|
- CommonsMultipartResolver resolver = new CommonsMultipartResolver();
|
|
|
- resolver.setDefaultEncoding("UTF-8");
|
|
|
- resolver.setResolveLazily(true);
|
|
|
- resolver.setMaxInMemorySize(2);
|
|
|
- resolver.setMaxUploadSize(200 * 1024 * 1024);
|
|
|
- return resolver;
|
|
|
- }
|
|
|
-
|
|
|
-}
|
|
|
+package cn.com.qmth.examcloud.task.starter;
|
|
|
+
|
|
|
+import org.slf4j.MDC;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
|
|
+import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|
|
+import org.springframework.boot.autoconfigure.domain.EntityScan;
|
|
|
+import org.springframework.boot.autoconfigure.web.MultipartAutoConfiguration;
|
|
|
+import org.springframework.cloud.client.loadbalancer.LoadBalanced;
|
|
|
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
|
|
|
+import org.springframework.context.annotation.Bean;
|
|
|
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
|
|
|
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
|
|
|
+import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|
|
+import org.springframework.data.redis.core.RedisTemplate;
|
|
|
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
|
|
|
+import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|
|
+import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
+import org.springframework.scheduling.quartz.SchedulerFactoryBean;
|
|
|
+import org.springframework.web.client.RestTemplate;
|
|
|
+import org.springframework.web.multipart.MultipartResolver;
|
|
|
+import org.springframework.web.multipart.commons.CommonsMultipartResolver;
|
|
|
+
|
|
|
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
|
|
|
+import com.fasterxml.jackson.annotation.PropertyAccessor;
|
|
|
+import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
+
|
|
|
+import cn.com.qmth.examcloud.commons.base.logging.ExamCloudLog;
|
|
|
+import cn.com.qmth.examcloud.commons.base.logging.ExamCloudLogFactory;
|
|
|
+import cn.com.qmth.examcloud.commons.base.logging.SLF4JImpl;
|
|
|
+import cn.com.qmth.examcloud.commons.web.boot.ExamCloudApp;
|
|
|
+import cn.com.qmth.examcloud.commons.web.redis.RedisClient;
|
|
|
+import cn.com.qmth.examcloud.commons.web.redis.RedisClientImpl;
|
|
|
+import cn.com.qmth.examcloud.commons.web.support.CustomResponseErrorHandler;
|
|
|
+import cn.com.qmth.examcloud.commons.web.support.SpringContextHolder;
|
|
|
+import cn.com.qmth.examcloud.task.starter.config.JobsStartup;
|
|
|
+
|
|
|
+@SpringBootApplication(scanBasePackages = {"cn.com.qmth"})
|
|
|
+@EnableJpaRepositories(basePackages = {"cn.com.qmth"})
|
|
|
+@EntityScan(basePackages = {"cn.com.qmth"})
|
|
|
+@EnableJpaAuditing
|
|
|
+@EnableEurekaClient
|
|
|
+@EnableScheduling
|
|
|
+@EnableAutoConfiguration(exclude = {MultipartAutoConfiguration.class})
|
|
|
+public class TaskApp {
|
|
|
+
|
|
|
+ private static final ExamCloudLog LOG = ExamCloudLogFactory.getLog(TaskApp.class);
|
|
|
+
|
|
|
+ public static void main(String[] args) throws Exception {
|
|
|
+ if (LOG instanceof SLF4JImpl) {
|
|
|
+ MDC.put("TRACE_ID", Thread.currentThread().getName());
|
|
|
+ }
|
|
|
+
|
|
|
+ ExamCloudApp.run(TaskApp.class, "task", args);
|
|
|
+
|
|
|
+ JobsStartup jobsStartup = SpringContextHolder.getBean(JobsStartup.class);
|
|
|
+ jobsStartup.start();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean
|
|
|
+ @LoadBalanced
|
|
|
+ public RestTemplate restTemplate() {
|
|
|
+ RestTemplate restTemplate = new RestTemplate();
|
|
|
+ restTemplate.setErrorHandler(new CustomResponseErrorHandler());
|
|
|
+ return restTemplate;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean
|
|
|
+ public RedisTemplate<String, Object> redisTemplate(
|
|
|
+ RedisConnectionFactory redisConnectionFactory) {
|
|
|
+ RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
|
|
|
+ redisTemplate.setConnectionFactory(redisConnectionFactory);
|
|
|
+ Jackson2JsonRedisSerializer<?> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(
|
|
|
+ Object.class);
|
|
|
+ ObjectMapper objectMapper = new ObjectMapper();
|
|
|
+ objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
|
|
|
+ objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
|
|
|
+ jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
|
|
|
+ redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
|
|
|
+ redisTemplate.setKeySerializer(new StringRedisSerializer());
|
|
|
+ redisTemplate.afterPropertiesSet();
|
|
|
+ return redisTemplate;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean
|
|
|
+ @Autowired
|
|
|
+ public RedisClient redisClient(RedisTemplate<String, Object> redisTemplate) {
|
|
|
+ return new RedisClientImpl(redisTemplate);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean(name = "schedulerFactoryBean")
|
|
|
+ public SchedulerFactoryBean schedulerFactory() {
|
|
|
+ return new SchedulerFactoryBean();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean(name = "multipartResolver")
|
|
|
+ public MultipartResolver multipartResolver() {
|
|
|
+ CommonsMultipartResolver resolver = new CommonsMultipartResolver();
|
|
|
+ resolver.setDefaultEncoding("UTF-8");
|
|
|
+ resolver.setResolveLazily(true);
|
|
|
+ resolver.setMaxInMemorySize(2);
|
|
|
+ resolver.setMaxUploadSize(200 * 1024 * 1024);
|
|
|
+ return resolver;
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
WANG