ClientApps/BasicDependVersion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除文件传输依赖

Browse Source
This commit is contained in:
hongawen
2025-06-16 14:43:32 +08:00
parent 1ff4977a3e
commit 2795f725da
2 changed files with 0 additions and 171 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
njcn-common/pom.xml
View File

@@ -130,13 +130,6 @@
<version>3.5.2</version> <version>3.5.2</version>
</dependency> </dependency>
<!--传输文件工具包-->
<dependency>
<groupId>eu.agno3.jcifs</groupId>
<artifactId>jcifs-ng</artifactId>
<version>2.1.9</version>
</dependency>
</dependencies> </dependencies>
</project> </project>

164
njcn-common/src/main/java/com/njcn/common/utils/file/FileTransferUtil.java
View File

@@ -1,164 +0,0 @@
package com.njcn.common.utils.file;
import jcifs.CIFSContext;
import jcifs.CIFSException;
import jcifs.context.SingletonContext;
import jcifs.smb.*;
import java.io.*;
import java.net.MalformedURLException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
/**
* @author hongawen
* @version 1.0
* @data 2025/6/16 14:28
* 用于向Windows服务器传输文件
*/
public class FileTransferUtil {
/**
* 向Windows服务器传输文件
* @param serverIP 服务器IP地址
* @param username 用户名
* @param password 密码
* @param localFilePath 本地文件路径
* @param remotePath 远程路径（例如：D:/folder/）
* @return 是否传输成功
*/
public static boolean transferFile(String serverIP, String username, String password,
String localFilePath, String remotePath) {
try {
// 构建远程文件URL
String remoteUrl = String.format("smb://%s/%s", serverIP, remotePath);
// 创建认证上下文
CIFSContext context = SingletonContext.getInstance()
.withCredentials(new NtlmPasswordAuthenticator(username, password));
// 获取远程目录
SmbFile remoteDir = new SmbFile(remoteUrl, context);
if (!remoteDir.exists()) {
remoteDir.mkdirs();
}
// 获取本地文件
Path localPath = Paths.get(localFilePath);
if (!Files.exists(localPath)) {
throw new FileNotFoundException("Local file not found: " + localFilePath);
}
// 构建远程文件路径
String fileName = localPath.getFileName().toString();
String remoteFilePath = remoteUrl + fileName;
SmbFile remoteFile = new SmbFile(remoteFilePath, context);
// 传输文件
try (InputStream in = Files.newInputStream(localPath);
OutputStream out = remoteFile.getOutputStream()) {
byte[] buffer = new byte[8192];
int len;
while ((len = in.read(buffer)) != -1) {
out.write(buffer, 0, len);
}
}
return true;
} catch (MalformedURLException e) {
System.err.println("Invalid URL: " + e.getMessage());
return false;
} catch (CIFSException e) {
System.err.println("CIFS error: " + e.getMessage());
return false;
} catch (IOException e) {
System.err.println("IO error: " + e.getMessage());
return false;
}
}
/**
* 向Windows服务器传输文件（带进度回调）
* @param serverIP 服务器IP地址
* @param username 用户名
* @param password 密码
* @param localFilePath 本地文件路径
* @param remotePath 远程路径
* @param progressCallback 进度回调接口
* @return 是否传输成功
*/
public static boolean transferFileWithProgress(String serverIP, String username, String password,
String localFilePath, String remotePath,
ProgressCallback progressCallback) {
try {
// 构建远程文件URL
String remoteUrl = String.format("smb://%s/%s", serverIP, remotePath);
// 创建认证上下文
CIFSContext context = SingletonContext.getInstance()
.withCredentials(new NtlmPasswordAuthenticator(username, password));
// 获取远程目录
SmbFile remoteDir = new SmbFile(remoteUrl, context);
if (!remoteDir.exists()) {
remoteDir.mkdirs();
}
// 获取本地文件
Path localPath = Paths.get(localFilePath);
if (!Files.exists(localPath)) {
throw new FileNotFoundException("Local file not found: " + localFilePath);
}
// 获取文件大小
long fileSize = Files.size(localPath);
// 构建远程文件路径
String fileName = localPath.getFileName().toString();
String remoteFilePath = remoteUrl + fileName;
SmbFile remoteFile = new SmbFile(remoteFilePath, context);
// 传输文件
try (InputStream in = Files.newInputStream(localPath);
OutputStream out = remoteFile.getOutputStream()) {
byte[] buffer = new byte[8192];
int len;
long transferred = 0;
while ((len = in.read(buffer)) != -1) {
out.write(buffer, 0, len);
transferred += len;
// 计算并回调进度
if (progressCallback != null) {
int progress = (int) ((transferred * 100) / fileSize);
progressCallback.onProgress(progress);
}
}
}
return true;
} catch (MalformedURLException e) {
System.err.println("Invalid URL: " + e.getMessage());
return false;
} catch (CIFSException e) {
System.err.println("CIFS error: " + e.getMessage());
return false;
} catch (IOException e) {
System.err.println("IO error: " + e.getMessage());
return false;
}
}
/**
* 进度回调接口
*/
public interface ProgressCallback {
void onProgress(int progress);
}
}