编辑
2023-03-31
学习记录
00

先将字符串base64转为字节数组输入流,再转为输入流

java
public InputStream base64ToInputStream(String base64) { ByteArrayInputStream stream = null; try { byte[] bytes = Base64.getDecoder().decode(base64); stream = new ByteArrayInputStream(bytes); } catch (Exception e) { e.printStackTrace(); } return stream; }
编辑
2023-03-31
学习记录
00

提示

实现一个查询同时获取多个数据源内相关视图或者表里的信息

前提

新建一个maven model,配置基本项目内容

pom文件

xml
<dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-typehandlers-jsr310</artifactId> <version>1.0.2</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bootstrap</artifactId> </dependency> <dependency> <groupId>com.oracle</groupId> <artifactId>ojdbc6</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>5.7.1</scope> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> </dependency> <dependency> <groupId>com.baomidou</groupId> <artifactId>dynamic-datasource-spring-boot-starter</artifactId> <version>3.5.2</version> </dependency> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.5.2</version> </dependency>
编辑
2023-03-31
学习记录
00

HttpServletRequest简介

HttpServletRequest对象代表客户端的请求,当客户端通过HTTP协议访问服务器时,HTTP请求头中的所有信息都封装在这个对象中。

request常用的方法和操作:

1.获得客户端的信息

getRequestURL方法返回客户端发出请求时的完整URL。

getRequestURI方法返回请求行中的资源名部分,去掉主机名的部分。

getRemoteAddr方法返回发出请求的客户机的IP地址

getRemoteHost方法返回发出请求的客户机的完整主机名

getRemotePort方法返回客户机所使用的端口号

getLocalAddr方法返回WEB服务器的IP地址。

getLocalName方法返回WEB服务器的主机名

getMethod得到客户机请求方式,如GET,POST

2.获得请求头的一些方法

getHead(name)方法

getHeaders(String name)方法

getHeaderNames方法

3.获得请求参数,也就是客户端提交的数据的一些方法。

getParameter(name)方法

getParameterValues(String name)方法

getParameterNames方法

getParameterMap方法

编辑
2023-03-24
实用工具
00

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注册中心的界面

编辑
2023-03-23
实用工具
00

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; } }

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