文件传输服务应用1——java集成smb2/3实现文件共享方案详细教程和windows共享服务使用配置

本文主要是介绍文件传输服务应用1——java集成smb2/3实现文件共享方案详细教程和windows共享服务使用配置,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在实际项目开发过程中,读取网络资源或者局域网内主机的文件是必要的操作和需求。而FTP(文件传输协议)和SMB(服务器消息块)是两种最为常见的文件传输协议。它们各自在文件传输领域拥有独特的优势和特点,但同时也存在一些差异。

本文以java集成smb为案例说明,其中SMB作为一种在Windows环境中广泛使用的文件共享协议,特别适合于局域网内的文件共享和协作,具体如何集成开发请详细阅读。

本文案以springboot2.1.5作为开发对象。

一.设置共享文件夹,也就是smb服务(以windows为测试对象)

1.首先在我的电脑下,找C盘之外的盘符新建一个文件夹,本例以SMB_Server做介绍

2.然后就可以用网络路径在局域网内的浏览器或者我的电脑访问共享的文件。

注意:

可以使用ip或者域来访问,其中域指的是smb服务电脑的设备名称(在我的电脑属性查看)

3.开启smb服务后,如果不能正常访问请查看以下网站处理

https://learn.microsoft.com/zh-CN/troubleshoot/windows-server/networking/dns-cname-alias-cannot-access-smb-file-server-share

二.java项目引入smb共享文件包

需要注意的是:

使用smb作为传输协议时,其存在协议版本的问题,需要同时引入smb1和smb2/3才能正常工作。

        <!--SMB共享文件--><!-- https://mvnrepository.com/artifact/jcifs/jcifs --><!--smb1--><dependency><groupId>jcifs</groupId><artifactId>jcifs</artifactId><version>1.3.17</version></dependency><!--smb2/3--><dependency><groupId>com.hierynomus</groupId><artifactId>smbj</artifactId><version>0.11.3</version></dependency>

三.配置smb链接信息,构造java链接使用工具

1.新增smb-config.properties配置文件
##########################
# SMB配置信息
##################################### ———以下是Windows本地服务配置信息
smb.hostname=127.0.0.1
## 域名,没有可以为空
smb.domain=wp-pc
smb.username=wp
smb.password=123456
## 一定记得是共享目录名称,其他无须添加
smb.server.root=SMB_Server
## 需要访问的目录名称,后缀必须带"/"
smb.server.path=/project/opt/
## 本地存放SMB下载的结果文件的目录
smb.local.path=D:\\test\\project\\opt\\
# 本地存放运行对接需要的数据
smb.local.rundata=D:\\data\\rundata\\############## ———以下是linux服务器配置信息
#smb.hostname=10.1.0.21
#smb.domain=
#smb.username=root
#smb.password=root
#smb.server.root=SMB_Server
#smb.server.path=/project/opt/
#smb.local.path=/root/demo/project/opt/
#smb.local.rundata=/root/demo/project/rundata/
@lombok.Data
@Component
/*** 加载SMB自定义配置文件* 配置文件需放在resources文件夹根目录*/
@PropertySource("classpath:smb-config.properties")
public class SMBConfigInfo {@Value("${smb.hostname}")private String hostname;@Value("${smb.domain}")private String domain;@Value("${smb.username}")private String username;@Value("${smb.password}")private String password;@Value("${smb.server.root}")private String rootPath;@Value("${smb.server.path}")private String serverPath;@Value("${smb.local.rundata}")private String runDataPath;
}
 2.新增SMB共享文件工具,可支持登录,读取,下载,上传等操作
/*** SMB共享文件工具* 支持登录,读取,下载,上传等操作* @author wp*/
@Component
public class SMBUtils {@Autowiredprivate SMBConfigInfo smbConfigInfo;/*** 登录SMB服务** @return*/private NtlmPasswordAuthentication loginSMBServer() {UniAddress dc;NtlmPasswordAuthentication authentication = null;try {dc = UniAddress.getByName(smbConfigInfo.getHostname());authentication = new NtlmPasswordAuthentication(smbConfigInfo.getDomain(), smbConfigInfo.getUsername(), smbConfigInfo.getPassword());SmbSession.logon(dc, authentication);} catch (Exception e) {e.printStackTrace();System.out.println("loginSMBServer fail:" + smbConfigInfo.toString());return null;}return authentication;}/*** 从SMB服务器下载文件到本地路径* 路径格式:smb://192.168.1.21/test/新建文本文档.txt* smb://username:password@192.168.1.21/test** @param remoteUrl 远程路径* @param localDir  要写入的本地路径*/public void getSMBFileByDown(String remoteUrl, String localDir) {InputStream in = null;OutputStream out = null;NtlmPasswordAuthentication auth = loginSMBServer();if (auth == null) {return;}try {SmbFile remoteFile = new SmbFile(remoteUrl, auth);if (!remoteFile.isFile()) {System.out.println("共享文件不存在");return;}String fileName = remoteFile.getName();File fileDir = new File(localDir);if (!fileDir.exists()) {fileDir.mkdirs();}File localFile = new File(localDir + File.separator + fileName);in = new BufferedInputStream(new SmbFileInputStream(remoteFile));out = new BufferedOutputStream(new FileOutputStream(localFile));byte[] buffer = new byte[1024];while (in.read(buffer) != -1) {out.write(buffer);buffer = new byte[1024];}} catch (Exception e) {e.printStackTrace();} finally {try {out.close();in.close();} catch (IOException e) {e.printStackTrace();}}}/*** 通过读取SMB远程文件获得输入流* 如果输入流在别处使用的时候,一定记得不要先关闭* 另外流不能直接上传或者操作,否则有异常* 须先下载到本地,然后再处理** @param remoteUrl* @return*/public InputStream getInputStreamBySMBFile(String remoteUrl) {NtlmPasswordAuthentication auth = loginSMBServer();if (auth == null) {return null;}InputStream in = null;try {SmbFile remoteFile = new SmbFile(remoteUrl, auth);if (!remoteFile.isFile()) {System.out.println("共享文件不存在");return in;}in = new BufferedInputStream(new SmbFileInputStream(remoteFile));byte[] buffer = new byte[1024];while (in.read(buffer) != -1) {buffer = new byte[1024];}} catch (Exception e) {e.printStackTrace();} finally {/*try {in.close();} catch (IOException e) {e.printStackTrace();}*/}return in;}/*** 从本地上传文件到指定SMB指定目录** @param remoteUrl     文件的全路径+文件名称* @param localFilePath*/public void getSMBFileByUpload(String remoteUrl, String localFilePath) {NtlmPasswordAuthentication auth = loginSMBServer();if (auth == null) {return;}InputStream in = null;OutputStream out = null;try {File localFile = new File(localFilePath);String fileName = localFile.getName();SmbFile remoteFile = new SmbFile(remoteUrl + "/" + fileName, auth);if (!remoteFile.exists()) {remoteFile.createNewFile();}in = new BufferedInputStream(new FileInputStream(localFile));out = new BufferedOutputStream(new SmbFileOutputStream(remoteFile));byte[] buffer = new byte[1024];while (in.read(buffer) != -1) {out.write(buffer);buffer = new byte[1024];}} catch (Exception e) {e.printStackTrace();} finally {try {out.close();in.close();} catch (IOException e) {e.printStackTrace();}}}/*** 读取SMB服务指定目录的文件* smb://administrator:dibindb@10.1.1.12/share/aa.txt** @param remoteUrl* @param fileName* @return*/public String readSMBFile(String remoteUrl, String fileName) {NtlmPasswordAuthentication auth = loginSMBServer();if (auth == null) {return "";}SmbFileInputStream smbIn = null;StringBuffer strBu = new StringBuffer();try {SmbFile smbCatalog = new SmbFile(remoteUrl, auth);if (!smbCatalog.exists()) {smbCatalog.mkdirs();}SmbFile smbFile = new SmbFile(remoteUrl + fileName, auth);if (!smbFile.isFile()) {smbFile.createNewFile();}// 得到文件的大小int length = smbFile.getContentLength();byte buffer[] = new byte[ConstantDataList.SYSTEM_BUFFER_SIZE];// 建立smb文件输入流smbIn = new SmbFileInputStream(smbFile);int leng = -1;while ((leng = smbIn.read(buffer)) != -1) {strBu.append(new String(buffer, 0, leng));}} catch (Exception e) {e.printStackTrace();} finally {try {smbIn.close();} catch (IOException e) {e.printStackTrace();}}return strBu.toString();}/*** 将jsonStr写入SMB指定的目录文件中** @param remoteUrl* @param fileName* @param jsonStr*/public void writeSMBFile(String remoteUrl, String fileName,String jsonStr) {NtlmPasswordAuthentication auth = loginSMBServer();if (auth == null) {return;}//将str转化成输入流ByteArrayInputStream smbIn = new ByteArrayInputStream(jsonStr.getBytes());SmbFileOutputStream out = null;try {SmbFile smbCatalog = new SmbFile(remoteUrl, auth);if (!smbCatalog.exists()) {smbCatalog.mkdirs();}SmbFile smbFile = new SmbFile(remoteUrl + fileName, auth);if (!smbFile.isFile()) {smbFile.createNewFile();}out = new SmbFileOutputStream(smbFile);// 得到文件的大小byte buffer[] = new byte[4096];int leng = -1;while ((leng = smbIn.read(buffer)) != -1) {out.write(buffer, 0, leng);}out.flush();} catch (Exception e) {e.printStackTrace();} finally {try {smbIn.close();out.close();} catch (IOException e) {e.printStackTrace();}}}}

 四.测试java链接操作smb功能

通过后台日志打印,可以清楚的看到链接,登录以及获取权限等操作信息

这篇关于文件传输服务应用1——java集成smb2/3实现文件共享方案详细教程和windows共享服务使用配置的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1002040

相关文章

Oracle查询优化之高效实现仅查询前10条记录的方法与实践

《Oracle查询优化之高效实现仅查询前10条记录的方法与实践》:本文主要介绍Oracle查询优化之高效实现仅查询前10条记录的相关资料,包括使用ROWNUM、ROW_NUMBER()函数、FET... 目录1. 使用 ROWNUM 查询2. 使用 ROW_NUMBER() 函数3. 使用 FETCH FI

Python脚本实现自动删除C盘临时文件夹

《Python脚本实现自动删除C盘临时文件夹》在日常使用电脑的过程中,临时文件夹往往会积累大量的无用数据,占用宝贵的磁盘空间,下面我们就来看看Python如何通过脚本实现自动删除C盘临时文件夹吧... 目录一、准备工作二、python脚本编写三、脚本解析四、运行脚本五、案例演示六、注意事项七、总结在日常使用

Java实现Excel与HTML互转

《Java实现Excel与HTML互转》Excel是一种电子表格格式,而HTM则是一种用于创建网页的标记语言,虽然两者在用途上存在差异,但有时我们需要将数据从一种格式转换为另一种格式,下面我们就来看看... Excel是一种电子表格格式,广泛用于数据处理和分析,而HTM则是一种用于创建网页的标记语言。虽然两

java图像识别工具类(ImageRecognitionUtils)使用实例详解

《java图像识别工具类(ImageRecognitionUtils)使用实例详解》:本文主要介绍如何在Java中使用OpenCV进行图像识别,包括图像加载、预处理、分类、人脸检测和特征提取等步骤... 目录前言1. 图像识别的背景与作用2. 设计目标3. 项目依赖4. 设计与实现 ImageRecogni

Java中Springboot集成Kafka实现消息发送和接收功能

《Java中Springboot集成Kafka实现消息发送和接收功能》Kafka是一个高吞吐量的分布式发布-订阅消息系统,主要用于处理大规模数据流,它由生产者、消费者、主题、分区和代理等组件构成,Ka... 目录一、Kafka 简介二、Kafka 功能三、POM依赖四、配置文件五、生产者六、消费者一、Kaf

Java访问修饰符public、private、protected及默认访问权限详解

《Java访问修饰符public、private、protected及默认访问权限详解》:本文主要介绍Java访问修饰符public、private、protected及默认访问权限的相关资料,每... 目录前言1. public 访问修饰符特点:示例:适用场景:2. private 访问修饰符特点:示例:

python管理工具之conda安装部署及使用详解

《python管理工具之conda安装部署及使用详解》这篇文章详细介绍了如何安装和使用conda来管理Python环境,它涵盖了从安装部署、镜像源配置到具体的conda使用方法,包括创建、激活、安装包... 目录pytpshheraerUhon管理工具:conda部署+使用一、安装部署1、 下载2、 安装3

Mysql虚拟列的使用场景

《Mysql虚拟列的使用场景》MySQL虚拟列是一种在查询时动态生成的特殊列,它不占用存储空间,可以提高查询效率和数据处理便利性,本文给大家介绍Mysql虚拟列的相关知识,感兴趣的朋友一起看看吧... 目录1. 介绍mysql虚拟列1.1 定义和作用1.2 虚拟列与普通列的区别2. MySQL虚拟列的类型2

Window Server创建2台服务器的故障转移群集的图文教程

《WindowServer创建2台服务器的故障转移群集的图文教程》本文主要介绍了在WindowsServer系统上创建一个包含两台成员服务器的故障转移群集,文中通过图文示例介绍的非常详细,对大家的... 目录一、 准备条件二、在ServerB安装故障转移群集三、在ServerC安装故障转移群集,操作与Ser

详解Java如何向http/https接口发出请求

《详解Java如何向http/https接口发出请求》这篇文章主要为大家详细介绍了Java如何实现向http/https接口发出请求,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 用Java发送web请求所用到的包都在java.net下,在具体使用时可以用如下代码,你可以把它封装成一