From f6bea9b21fc5a80cdaadc88bb5c39d165d591d8c Mon Sep 17 00:00:00 2001 From: wyl <959814898@qq.com> Date: Sun, 30 Apr 2023 18:45:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E6=95=B4=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../client/core/properties/client/FastDFSClient.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/module/aivfo-dfs-client-spring-boot/aivfo-dfs-client-spring-boot-core/src/main/java/com/aivfo/dfs/client/core/properties/client/FastDFSClient.java b/module/aivfo-dfs-client-spring-boot/aivfo-dfs-client-spring-boot-core/src/main/java/com/aivfo/dfs/client/core/properties/client/FastDFSClient.java index 96068a8..69347d9 100644 --- a/module/aivfo-dfs-client-spring-boot/aivfo-dfs-client-spring-boot-core/src/main/java/com/aivfo/dfs/client/core/properties/client/FastDFSClient.java +++ b/module/aivfo-dfs-client-spring-boot/aivfo-dfs-client-spring-boot-core/src/main/java/com/aivfo/dfs/client/core/properties/client/FastDFSClient.java @@ -1,9 +1,9 @@ package com.aivfo.dfs.client.core.properties.client; import com.aivfo.dfs.client.core.properties.FastDFSProperties; +import csource.fastdfs.*; +import csource.fastdfs.pool.Connection; import lombok.extern.slf4j.Slf4j; -import org.csource.fastdfs.*; -import org.csource.fastdfs.pool.Connection; import java.io.IOException; import java.util.Map; @@ -34,7 +34,7 @@ public class FastDFSClient implements Client { * @return org.csource.fastdfs.StorageClient * @Date 2023/4/28 * @Author wangyl - * @see org.csource.fastdfs.StorageClient#releaseConnection(Connection, boolean) + * @see csource.fastdfs.StorageClient#releaseConnection(Connection, boolean) * 对象都是非线程安全的 所以每次调用的时候都需要初始化 storageServer 这个对象源码在每次操作后都会被设置为null */ private StorageClient getStorageClient() throws IOException { @@ -42,6 +42,7 @@ public class FastDFSClient implements Client { TrackerServer trackerServer = tracker.getTrackerServer(); StorageServer storageServer = null; StorageClient storageClient = new StorageClient(trackerServer, storageServer); + return storageClient; } @Override @@ -65,8 +66,9 @@ public class FastDFSClient implements Client { } private String updateFile() throws IOException { + //TODO 处理上传文件最底层接口 StorageClient storageClient = getStorageClient(); - storageClient.upload_file() + return ""; } }