1
2
3
4
5
6
7
连击 天
fork: star:
加载中
原
Flink-mysql源-esSink
1实体对象 package com.shi.mysqlEsTest; import java.io.Serializable; import java.util.Arrays; import java.util.Date; import java.util.List; /** * 电站信息ES对象 * * @author shiy...
原
Flink-kafka源-esSink
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven....
原
用户线程和守护线程
package com.shi.juc.thread; /** * @author shiye * @create 2022-07-08 11:46 */ public class MyThread1 { public static void main(String[] args) throws InterruptedException { T......
原
从远程阿里云上根据路径下载文件，并且重名文文件
/** * 下载文件 * * @param id * @return * @throws Exception */ @GetMapping(value = "/downloadFile") @ApiOperation("下载文件") public ResponseEntity......
原
使用注解的方式+AOP校验签名
1.定义注解 @CheckSign ： package com.un.framework.aspectj.lang.openapi; import java.lang.annotation.*; /** * 校验签名 * * @author shiye */ @Target({ElementType.PARAMETER, Eleme...
原
Redis实现分布式锁
1.自己实现 private static String REDIS_LOCK = "redis_lock"; @Autowired private RedissonClient redission; /** * 自定redisLock实现分布式锁， * 使用 RedisTemplat......
原
手写AQS-非公平锁
1. Unsafe工具类 package com.shi.flink.unsafeTest; import sun.misc.Unsafe; import java.lang.reflect.Field; /** * @author shiye * @create 2021-03-30 17:03 */ public class UnsafeU...
原
LockSupport 详解
package com.shi.flink.juc; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.LockSupport; import java.util.concurrent.locks.ReentrantLock; /** * @author ...
原
由布隆过滤器和布谷鸟过滤器引发得感想
public static void main(String[] args) { int total = 100000000; System.out.println("当前最大可用内存多少M : "+Runtime.getRuntime().maxMemory()/1024/1024); System.out.prin......
原
对文件操作得一些总结
1.读取txt文件，然后从数据库从查询数据，并且写到txt文件中 public void getPhonehId() { List list = new LinkedList<>(); //1读取数据库中得图片 try { ......
没有更多内容
加载失败，请刷新页面
删除文章
文章删除后无法恢复，确定删除此文章吗？
删除动弹
动弹删除后，数据将无法恢复
评论删除后，数据将无法恢复