Eureka简介🥧

在微服务架构中往往会有一个注册中心，每个微服务都会向注册中心去注册自己的地址及端口信息，注册中心维护着服务名称与服务实例的对应关系。每个微服务都会定时从注册中心获取服务列表，同时汇报自己的运行情况，这样当有的服务需要调用其他服务时，就可以从自己获取到的服务列表中获取实例地址进行调用，Eureka实现了这套服务注册与发现机制。

搭建Eureka注册中心

• 创建SpringBoot模块勾选Spring cloud discovery - euraka server
• 手动在pom添加

xml
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

在启动类上添加@EnableEurekaServer注解来启用Euerka注册中心功能

java
@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {

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

}

在配置文件application.yml中添加Eureka注册中心的配置

yaml

server:
  port: 8001 #指定运行端口
spring:
  application:
    name: eureka-server #指定服务名称
eureka:
  instance:
    hostname: localhost #指定主机地址
  client:
    fetch-registry: false #指定是否要从注册中心获取服务（注册中心不需要开启）
    register-with-eureka: false #指定是否要注册到注册中心（注册中心不需要开启）
  server:
    enable-self-preservation: false #关闭保护模式

运行完成后访问地址http://localhost:8001/可以看到Eureka注册中心的界面

Spring定时自动任务

启动类添加注解

java
@EnableScheduling

创建定时任务类

java
@Component
public class AutoSubmitJob {
@Value("${job.submit.enabled}")
  private boolean enabled;
  
//@Scheduled(cron = "0 0 1 * * ? ")
@Scheduled(cron = "${job.submit.cron}")
public void execute() {
        if (enabled) {
          //具体业务
        }
        logger.info("自动任务开关为关闭状态--------任务结束");
    }
}

在线cron表达式 每天凌晨一点开始启动

Spring异步任务

启动类添加开启异步任务注解

java
@EnableAsync

在方法上添加异步注解

java
// @Async("scheduleTaskExecutor")
@Async

创建异步线程池

java

@Configuration
public class PoolConfig {
    @Bean("scheduleTaskExecutor")
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置核心线程数
        executor.setCorePoolSize(10);
        // 设置最大线程数
        executor.setMaxPoolSize(15);
        // 设置队列容量
        executor.setQueueCapacity(20);
        // 设置线程活跃时间（秒）
        executor.setKeepAliveSeconds(60);
        // 设置默认线程名称
        executor.setThreadNamePrefix("zszxz-");
        // 设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 等待所有任务结束后再关闭线程池
        executor.setWaitForTasksToCompleteOnShutdown(true);
        return executor;
    }
}

异步注解可以和定时任务一起使用，变成定时异步任务

java

import java.sql.Clob;
 
import javax.sql.rowset.serial.SerialClob;
 
 
    /**
     * Clob 转 String
     */
    public static String getString(Clob c) {
        try {
            return c.getSubString(1, (int) c.length());
        } catch (Exception e) {
            return null;
        }
    }
 
    /**
     * String 转 Clob
     */
    public static Clob getClob(String s) {
        try {
            return new SerialClob(s.toCharArray());
        } catch (Exception e) {
            return null;
        }
    }

1.转成json

因为业务需要，得把list存储进数据库，所以首先需要设置oracle字段的为大文本类型，由于我们转成json存储，所以我们需要使用clob类型，这个类型存储文本类型的，blob存储二进制类型

实体类设置为String类型

java
@ApiModelProperty(value = "excel标题")
    private String excelHeadList;

mappper.xml设置对照属性

xml
 <result column="EXCEL_HEAD_LIST" property="excelHeadList" jdbcType="CLOB"  javaType="String" />

使用fastJson工具包

java
 entity.setExcelHeadList(JSON.toJSONString(headList));

2.json转成List

java
List<List<String>> headList =JSON.parseObject(entity.getExcelHeadList(),List.class);

前提

使用List<Map<String,Object>> 接收从数据库查询到的结果，不能进行order by 排序，但是返回的list的顺序要和数据库视图里的字段顺序一致

java
List<Map<String, Object>> dataMaplist=recReportPerformanceExamMapper.getdataMaplist(request);

由于hashMap是要计算hash值，所以每次添加的位置会不同，不是按照顺序来的 这时我们可以换成LinkedHashMap就可以解决问题

java
List<LinkedHashMap<String, Object>> dataMaplist=recReportPerformanceExamMapper.getdataMaplist(request);