parent
246bd7b84c
commit
d4a8f0f3e9
3 changed files with 35 additions and 137 deletions
@ -0,0 +1,35 @@ |
|||||||
|
## 文档说明 |
||||||
|
|
||||||
|
##### 资源接口 |
||||||
|
|
||||||
|
resourcesController 资源上传 uploadFile / 下载 deleteResource / 预览 readFile |
||||||
|
|
||||||
|
用minio 作为资源管理 |
||||||
|
|
||||||
|
minio 网址:http://39.106.16.162:9001/ |
||||||
|
用户名:minioadmin |
||||||
|
密码:minioadmin |
||||||
|
|
||||||
|
以日期分类 文件类型 文件名前10个(超出10)+yyyymmddhhmmss |
||||||
|
|
||||||
|
yml 配置 |
||||||
|
|
||||||
|
```java |
||||||
|
minio: |
||||||
|
endpoint: http://39.106.16.162:9090 #MinIO服务所在地址 |
||||||
|
bucketName: teaching # 存储桶名称 |
||||||
|
accessKey: minioadmin # 访问的key |
||||||
|
secretKey: minioadmin # 访问的秘钥 |
||||||
|
``` |
||||||
|
|
||||||
|
minioutils 工具类 |
||||||
|
|
||||||
|
> 逻辑就是,文件上传之后,存入图数据库,返回节点信息 , 删除文件 也得删除文件在图数据库的节点 |
||||||
|
|
||||||
|
##### 图数据库 |
||||||
|
|
||||||
|
http://39.106.16.162:7474/ |
||||||
|
|
||||||
|
用户名 neo4j |
||||||
|
|
||||||
|
密码123456 |
@ -1,101 +0,0 @@ |
|||||||
package com.teaching; |
|
||||||
|
|
||||||
import org.junit.jupiter.api.Test; |
|
||||||
import org.springframework.util.DigestUtils; |
|
||||||
|
|
||||||
import java.io.*; |
|
||||||
import java.util.Arrays; |
|
||||||
import java.util.Collections; |
|
||||||
import java.util.Comparator; |
|
||||||
import java.util.List; |
|
||||||
|
|
||||||
public class MinioTest { |
|
||||||
//分块测试
|
|
||||||
@Test |
|
||||||
public void testChunk() throws IOException { |
|
||||||
//源文件
|
|
||||||
File sourseFile = new File("D:/Users/Desktop/image/剪映/7.18/7月20.mp4"); |
|
||||||
//分块文件存储路径
|
|
||||||
String chunkFilePath = "D:/Users/Desktop/image/剪映/7.18/chunk/"; |
|
||||||
//分块文件大小
|
|
||||||
int chunkSize = 1024 * 1024 * 1; |
|
||||||
//分块文件个数
|
|
||||||
int chunkNum = (int) Math.ceil(sourseFile.length() * 1.0 / chunkSize); |
|
||||||
//使用流从源文件读数据,向分块文件中写数据
|
|
||||||
RandomAccessFile raf_r = new RandomAccessFile(sourseFile, "r"); |
|
||||||
//缓存区
|
|
||||||
byte[] bytes = new byte[1024]; |
|
||||||
for (int i = 0; i < chunkNum; i++) { |
|
||||||
File chunkFile = new File(chunkFilePath + i); |
|
||||||
//分块文件写入流
|
|
||||||
RandomAccessFile raf_rw = new RandomAccessFile(chunkFile, "rw"); |
|
||||||
int len = -1; |
|
||||||
while((len=raf_r.read(bytes)) != -1){ |
|
||||||
raf_rw.write(bytes, 0, len); |
|
||||||
if (chunkFile.length() >= chunkSize){ |
|
||||||
break; |
|
||||||
} |
|
||||||
} |
|
||||||
raf_rw.close(); |
|
||||||
} |
|
||||||
raf_r.close(); |
|
||||||
} |
|
||||||
|
|
||||||
//将分块进行合并
|
|
||||||
@Test |
|
||||||
public void testMerge() throws IOException { |
|
||||||
//块文件目录
|
|
||||||
File chunkFolder = new File("D:\\Users\\Desktop\\image\\剪映\\7.18\\chunk"); |
|
||||||
//源文件
|
|
||||||
File sourseFile = new File("D:/Users/Desktop/image/剪映/7.18/7月20.mp4"); |
|
||||||
//合并后的文件
|
|
||||||
File mergeFile = new File("D:/Users/Desktop/image/剪映/7.18/7月20_merge.mp4"); |
|
||||||
|
|
||||||
//取出所有分块文件
|
|
||||||
File[] files = chunkFolder.listFiles(); |
|
||||||
//将数组转成list
|
|
||||||
List<File> fileList = Arrays.asList(files); |
|
||||||
//对分块文件排序
|
|
||||||
Collections.sort(fileList, new Comparator<File>() { |
|
||||||
@Override |
|
||||||
public int compare(File o1, File o2) { |
|
||||||
return Integer.parseInt(o1.getName()) - Integer.parseInt(o2.getName()); //升序
|
|
||||||
} |
|
||||||
}); |
|
||||||
//向合并文件写的流
|
|
||||||
RandomAccessFile raf_rw = new RandomAccessFile(mergeFile, "rw"); |
|
||||||
//缓存区
|
|
||||||
byte[] bytes = new byte[1024]; |
|
||||||
//遍历分块文件,向合并的文件写
|
|
||||||
for (File file : fileList) { |
|
||||||
//读分块的流
|
|
||||||
RandomAccessFile raf_r = new RandomAccessFile(file, "r"); |
|
||||||
int len = -1; |
|
||||||
while((len = raf_r.read(bytes)) != -1){ |
|
||||||
raf_rw.write(bytes, 0, len); |
|
||||||
} |
|
||||||
raf_r.close(); |
|
||||||
} |
|
||||||
raf_rw.close(); |
|
||||||
//合并文件完成后对合并的文件校验
|
|
||||||
FileInputStream fileInputStream_merge = new FileInputStream(mergeFile); |
|
||||||
FileInputStream fileInputStream_source = new FileInputStream(sourseFile); |
|
||||||
String md5_merge = DigestUtils.md5DigestAsHex(fileInputStream_merge); |
|
||||||
String md5_source = DigestUtils.md5DigestAsHex(fileInputStream_source); |
|
||||||
if (md5_merge.equals(md5_source)){ |
|
||||||
System.out.println("文件合并成功!"); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
//将分块文件上传到minio
|
|
||||||
public void uploadChunk(){ |
|
||||||
|
|
||||||
} |
|
||||||
|
|
||||||
//调用minio接口合并分块
|
|
||||||
|
|
||||||
|
|
||||||
//批量清理分块文件
|
|
||||||
|
|
||||||
|
|
||||||
} |
|
@ -1,36 +0,0 @@ |
|||||||
package com.teaching; |
|
||||||
|
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j; |
|
||||||
import org.junit.jupiter.api.Test; |
|
||||||
import org.springframework.boot.test.context.SpringBootTest; |
|
||||||
|
|
||||||
import javax.annotation.Resource; |
|
||||||
|
|
||||||
@Slf4j |
|
||||||
@SpringBootTest |
|
||||||
public class test { |
|
||||||
|
|
||||||
|
|
||||||
@Test |
|
||||||
public void countknowledge(){ |
|
||||||
String userId = "2"; |
|
||||||
// System.out.println(knowledgeLearningCountService.list());
|
|
||||||
// List<KnowledgeLearningCount> list = knowledgeLearningCountService.query().eq("user_id", userId).list();
|
|
||||||
// HashSet<KnowledgeLearningCount> set = new HashSet<>(list);
|
|
||||||
// System.out.println(set.size());
|
|
||||||
// Long count = knowledgeLearningCountService.query().eq("user_id", userId).count();
|
|
||||||
// if (count == 0){
|
|
||||||
// KnowledgeLearningCount knowledgeLearningCount = new KnowledgeLearningCount();
|
|
||||||
// knowledgeLearningCount.setUserId(userId);
|
|
||||||
// knowledgeLearningCount.setNumber(1);
|
|
||||||
// knowledgeLearningCountService.save(knowledgeLearningCount);
|
|
||||||
// }else {
|
|
||||||
// //该用户学习知识点数+1
|
|
||||||
// boolean is = knowledgeLearningCountService.update()
|
|
||||||
// .setSql("number = "+set.size())
|
|
||||||
// .eq("user_id", userId).update();
|
|
||||||
// System.out.println(is);
|
|
||||||
// }
|
|
||||||
} |
|
||||||
} |
|
Loading…
Reference in new issue