From 80a512d460dc3ad5cfced73afaebbfe09bb91aba Mon Sep 17 00:00:00 2001
From: ke <893754509@qq.com>
Date: Wed, 27 Nov 2024 17:29:16 +0800
Subject: [PATCH] 白蚁新模块。图片上传接口。更新11-27 17:00
---
skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java | 36 ++++++++++++++++++++++++------------
1 files changed, 24 insertions(+), 12 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java b/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java
index a25a5d4..e3ebda8 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java
@@ -78,9 +78,12 @@
protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest fullRequest) throws Exception {
+ System.err.println("fullRequest:::"+fullRequest);
boolean isRequestValid = isValidHttpRequest(ctx, fullRequest);
if (!isRequestValid) {
log.warn("Discard invalid request.");
+
+ //HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.BAD_REQUEST, "验证失败");
return;
}
@@ -92,9 +95,9 @@
// file.write(ByteBufUtil.getBytes(fullRequest.content()));
// file.close();
- String fileName = this.parseFileName(fullRequest);
+ //String fileName = this.parseFileName(fullRequest);
-
+ String fileName = System.currentTimeMillis() + ".jpg";
ByteArrayInputStream stream = new ByteArrayInputStream(ByteBufUtil.getBytes(fullRequest.content()));
MockMultipartFile multipartFile
@@ -191,21 +194,30 @@
try {
URI uri = UriUtils.getURI(request);
log.info(uri.getPath());
-
- // 密码校验
- boolean authFlag = auth(ctx, uri);
- if (!authFlag) {
- // 校验不通过
+ // authorization效验
+ String authorization = request.headers().get("Authorization");
+ if(!this.nettyHttpConfig.getAuthorization().equals(authorization)) {
+ log.warn("Authorization校验失败！！");
+ // 校验不通过
HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.UNAUTHORIZED, HttpResponseStatus.UNAUTHORIZED.toString());
// 校验不通过
return false;
- }
+ }
+
+ // 密码校验
+// boolean authFlag = auth(ctx, uri);
+// if (!authFlag) {
+// // 校验不通过
+// HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.UNAUTHORIZED, HttpResponseStatus.UNAUTHORIZED.toString());
+// // 校验不通过
+// return false;
+// }
// uri 路径校验
- if (!uri.getPath().startsWith(UPLOAD_FILE_URL)) {
- HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.BAD_REQUEST,"the url must starts with /postfile");
- return false;
- }
+// if (!uri.getPath().startsWith(UPLOAD_FILE_URL)) {
+// HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.BAD_REQUEST,"the url must starts with /postfile");
+// return false;
+// }
return true;
} catch (Exception exception) {
--
Gitblit v1.9.3