SpringBoot访问windows共享文件的方法
更新时间：2023年02月06日 08:39:01 作者：code2roc
这篇文章主要介绍了SpringBoot访问windows共享文件,项目使用minio存储且不在同一台服务器上，为了优化速度决定使用windows共享功能进行文件传输，本文结合实例代码给大家介绍的非常详细，需要的朋友可以参考下
前言
最近有项目需要开发档案打包下载功能，其中包含很多大附件，项目使用minio存储且不在同一台服务器上，为了优化速度决定使用windows共享功能进行文件传输
SMB1.0
集成jcifs类库，主要适用于一些老旧系统，但下载速度比较慢，仅作参考
此类库没有maven引用，官网地址：http://jcifs.samba.org/
注意事项：
设置jcifs.smb.client.dfs.disabled选项开启，可以提高传输速度
使用NtlmPasswordAuthentication认证代替smb协议url携带用户名密码方式，避免特殊字符传递造成认证失败
public static void downloadFile(String ip, String shareFolder, String filePath, String localDir) throws Exception {
System.setProperty("jcifs.smb.client.dfs.disabled", "true");
String url = getFileUrl(ip, shareFolder, filePath);
SmbFile smbFile = new SmbFile(url);
smbFile.connect();
FileUtil.initfloderPath(localDir);
String localFilePath = localDir + "/" + smbFile.getName();
BufferedInputStream buf = new BufferedInputStream(new SmbFileInputStream(smbFile));
FileUtil.writeFile(localFilePath, FileUtil.convertStreamToByte(buf));
}
public static void downloadFileByAuth(String ip, String shareFolder, String userName, String password, String filePath, String localDir) throws Exception {
System.setProperty("jcifs.smb.client.dfs.disabled", "true");
String url = getFileUrl(ip, shareFolder, filePath);
NtlmPasswordAuthentication auth = new NtlmPasswordAuthentication(ip, userName, password);
SmbFile smbFile = new SmbFile(url, auth);
smbFile.connect();
FileUtil.initfloderPath(localDir);
String localFilePath = localDir + "/" + smbFile.getName();
BufferedInputStream buf = new BufferedInputStream(new SmbFileInputStream(smbFile));
FileUtil.writeFile(localFilePath, FileUtil.convertStreamToByte(buf));
}
public static String getFileUrl(String ip, String shareFolder, String filePath) {
return "smb://" + ip + "/" + shareFolder + "/" + filePath;
}SMB2.0
集成smbj类库，适用于windows server2012及以上操作系统，默认安装开启无需额外配置
此类库maven引用很久没有发布最新版本，需要下载代码自行编译，github地址：https://github.com/hierynomus/smbj
经测试，500MB文件传输大概比minio协议传输快了4秒左右，小文件传输速度基本保持一致
public static void downloadFileV2(String ip, String shareFolder, String filePath, String localDir) throws Exception {
SMBClient client = new SMBClient(SmbConfig.createDefaultConfig());
Connection conn = client.connect(ip);
Session session = conn.authenticate(AuthenticationContext.anonymous());
downLoadSMB2(session, shareFolder, filePath, localDir);
}
public static void downloadFileByAuthV2(String ip, String shareFolder, String userName, String password, String filePath, String localDir) throws Exception {
SMBClient client = new SMBClient(SmbConfig.createDefaultConfig());
Connection conn = client.connect(ip);
Session session = conn.authenticate(new AuthenticationContext(userName, password.toCharArray(), ip));
downLoadSMB2(session, shareFolder, filePath, localDir);
}
private static void downLoadSMB2(Session session, String shareFolder, String filePath, String localDir) throws Exception {
InputStream fis = null;
FileOutputStream os = null;
DiskShare diskShare = null;
try {
diskShare = (DiskShare) session.connectShare(shareFolder);
if (!diskShare.fileExists(filePath)) {
throw new FileNotFoundException(filePath);
}
if (!diskShare.isConnected())
diskShare = (DiskShare) session.connectShare(shareFolder);
com.hierynomus.smbj.share.File file = diskShare.openFile(filePath,
EnumSet.of(AccessMask.GENERIC_READ),
(Set) null,
SMB2ShareAccess.ALL,
SMB2CreateDisposition.FILE_OPEN,
(Set) null
);
fis = file.getInputStream();
FileUtil.initfloderPath(localDir);
String[] filePathList = filePath.split("\\/");
String localFilePath = localDir + "/" + filePathList[filePathList.length - 1];
os = new FileOutputStream(localFilePath);
byte[] b = new byte[4096];
int length;
while ((length = fis.read(b)) > 0) {
os.write(b, 0, length);
}
} catch (IOException e) {
throw e;
} finally {
IOUtils.close(os);
IOUtils.close(fis);
if (diskShare != null && diskShare.isConnected()) diskShare.close();
}
}
445端口被禁用解决办法
一般企业/政府项目为了系统安全会禁用445端口，而445端口禁用后文件共享功能无法使用，此时我们需要进行端口转发，即将客户端445端口转发到共享服务器端口A，共享服务器将本地端口A转发到445即可完成共享，具体操作步骤如下，192.168.1.164就是共享文件服务器的内网ip
查看服务器转发规则
netsh interface portproxy show all
删除服务器转发规则
netsh interface portproxy reset
共享文件服务器
- 执行CMD代码
netsh interface portproxy add v4tov4 listenport=4455 listenaddress=192.168.1.164 connectport=445 connectaddress=127.0.0.1 netsh interface portproxy add v4tov4 listenport=4455 listenaddress=127.0.0.1 connectport=445 connectaddress=127.0.0.1
客户端服务器
- 关闭Server服务
- CMD执行代码
netsh interface portproxy add v4tov4 listenaddress=127.0.0.1 listenport=445 connectaddress=192.168.1.164 connectport=4455
- 重启系统
到此这篇关于SpringBoot访问windows共享文件的文章就介绍到这了,更多相关SpringBoot访问windows共享文件内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了springboot枚举类型传递的步骤，帮助大家更好的理解和学习使用springboot，感兴趣的朋友可以了解下2021-04-04
Spring-cloud 服务发现与消费(以ribbon为例)
这篇文章主要介绍了Spring-cloud 服务发现与消费(以ribbon为例)，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-04-04
在日常工作中，我们常常会进行Excel文件读写操作，这篇文章主要介绍了java读写excel文件实现POI解析Excel的方法,实例分析了java读写excel的技巧，非常具有实用价值，需要的朋友可以参考下2018-10-10
这篇文章主要介绍了spring-mybatis获取mapper的四种方式汇总，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-03-03
在这篇文章中，小编将带大家了解一下Java数据结构中链表的增删查改（以下结果均在IDEA中编译）希望在方便自己复习的同时也能帮助到大家2022-09-09
今天教各位小伙伴怎么用IDEA配置JUnit并进行单元测试,文中有非常详细的图文介绍及代码示例,对正在学习IDEA的小伙伴有很好的帮助,需要的朋友可以参考下2021-05-05
SpringCloud-Alibaba-Sentinel服务降级,热点限流,服务熔断
这篇文章主要介绍了SpringCloud-Alibaba-Sentinel服务降级,热点限流,服务熔断,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-12-12
这篇文章主要介绍了通过RedisTemplate连接多个Redis过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-08-08
这篇文章主要介绍了java 中单例模式饿汉式与懒汉式的对比的相关资料,这里对这两种单例模式进行对比，希望大家能理解并应用，需要的朋友可以参考下2017-08-08
IDEA启动服务提示端口被占用,Web server failed to start.Port was al
这篇文章主要介绍了IDEA启动服务提示端口被占用，Web server failed to start.Port was already in use.,本文给大家分享解决方案，分为linux系统和windows系统解决方案，需要的朋友可以参考下2023-07-07
最新评论