Android app通过jcifs-ng实现Samba连接共享文件夹

Android端使用Samba连接共享文件夹,下载或上传文件的功能实现。如果你是用jcifs工具包,那么你要注意jcifs-ng 和 jcifs 支持的SMB版本区别。

JCIFS-NG的github地址
JCIFS官网地址 这里有关于jciffsjcifs-codelibsjcifs-ngsmbj的详细介绍

对比

  • 支持的smb版本
    jcifs:
    仅支持SMB 1.0(CIFS), jcifs 最初是针对 SMB 1.0(CIFS)协议开发的,因此它是对 SMB 1.0 版本的最好支持。
    jcifs-ng 2.1:
    此版本默认启用SMB2支持,并包含一些实验性的SMB3.0支持。
    协商的协议级别现在可以使用jcifs.smb.client.minVersion和jcifs.smb.client.maxVersion进行控制(这会弃用jcifs.smb.client.enableSMB2/jcifs.sm b.client.disableSMB1属性)。默认的最小/最大版本是SMB1到SMB210。
    此版本禁止服务器浏览(即服务器/工作组枚举),并包含有关身份验证的一些突破性API更改。
    jcifs-ng 2.0:
    此版本支持SMB2(2.02协议级别),目前仅在配置了jcifs.smb.client.enableSMB2的情况下宣布支持SMB2,但如果服务器不支持SMB1方言,也可以选择支持SMB2。

  • 开发状态:
    jcifs: jcifs 是最初由 Mike Allen 开发的 Java CIFS 实现,最后一个官方发布版本是 1.3.19,发布于 2007 年。此后,jcifs 进入了维护模式,不再进行主要更新。
    jcifs-ng: jcifs-ng(jcifs-next generation)是基于 jcifs 的一个分支,由 Alexander Böhm 等人开发。它是对 jcifs 的改进和扩展,具有更现代化的代码结构和更多功能。jcifs-ng 目前仍在活跃地开发和维护。

  • 功能和性能:
    jcifs-ng 在功能和性能上进行了改进和优化,相比于原始的 jcifs,它提供了更多的功能和更好的性能。例如,jcifs-ng 支持更多的 SMB 协议特性,并且在速度和稳定性方面进行了改进。

  • API 和使用方式:
    jcifs-ng 在 API 和使用方式上与 jcifs 类似,但可能会有一些差异和改进。因此,如果你已经熟悉 jcifs,那么迁移到 jcifs-ng 应该相对容易。

这里使用的是jcifs-ng 2.1.9

添加依赖

implementation 'eu.agno3.jcifs:jcifs-ng:2.1.9'

代码实现(Kotlin)

package com.xxx.customer

import android.util.Log
import androidx.lifecycle.LifecycleOwner
import androidx.lifecycle.lifecycleScope
import jcifs.CIFSContext
import jcifs.context.SingletonContext
import jcifs.smb.SmbException
import jcifs.smb.SmbFile
import jcifs.smb.SmbFileInputStream
import jcifs.smb.SmbFileOutputStream
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import java.io.BufferedInputStream
import java.io.BufferedOutputStream
import java.io.File
import java.io.FileInputStream
import java.io.FileOutputStream
import java.io.IOException
import java.util.Properties


class SambaManager {

	private val SAMBA_SERVER_IP = "your server ip"
	private val SAMBA_USERNAME = "username"
	private val SAMBA_PASSWORD = "password"
	
    companion object {
        private const val TAG = "SambaManager"
        private var mCIFSContext: CIFSContext? = null

    }

    /**
     * 上传文件到共享文件夹指定目录
     * @param viewLifecycleOwner
     * @param localFilePathList 待上传的本地文件路径列表
     * @param remoteFolderPath 要上传到的远端路径,
     *        如果共享文件夹为shared_folder,则该路径应该包含shared_folder,
     *        如:shared_folder/ 或 shared_folder/xxx
     * @param onComplete 任务完成厚的回调
     */
    fun uploadFiles(
        viewLifecycleOwner: LifecycleOwner,
        localFilePathList: MutableList<String>,
        remoteFolderPath: String,
        onComplete: (Int) -> Unit
    ) {
        viewLifecycleOwner.lifecycleScope.launch(Dispatchers.IO) {
            var count = 0
            val smbContext = getCIFSContext()
            for (filePath in localFilePathList) {
                val localFile = File(filePath)
                if (!localFile.exists()) {
                    continue
                }
                val folderUrl = "smb://${SAMBA_SERVER_IP}/${remoteFolderPath.trim('/')}"
                val smbFolder = try {
                    SmbFile(folderUrl, smbContext)
                } catch (e: IOException) {
                    Log.e(TAG, "Failed to create SmbFile", e)
                    continue
                }
                //创建目录
                smbFolder.mkdirs()

                val url = "$folderUrl/${localFile.name}"
                val smbFile = try {
                    SmbFile(url, smbContext)
                } catch (e: IOException) {
                    Log.e(TAG, "Failed to create SmbFile", e)
                    continue
                }

                try {
                    if (smbFile.exists()) {
                        smbFile.delete()
                    }
                    smbFile.createNewFile()
                } catch (e: SmbException) {
                    Log.e(TAG, "Failed to create new SmbFile", e)
                    continue
                }

                try {
                    val outputStream = BufferedOutputStream(SmbFileOutputStream(smbFile))
                    val inputStream = BufferedInputStream(FileInputStream(localFile))
                    inputStream.use { input ->
                        outputStream.use { output ->
                            val buffer = ByteArray(1024)
                            var bytesRead: Int
                            while (input.read(buffer).also { bytesRead = it } != -1) {
                                output.write(buffer, 0, bytesRead)
                            }
                        }
                    }
                    count++
                } catch (e: IOException) {
                    Log.e(TAG, "Failed to download file", e)
                    continue
                }
            }
            onComplete(count)
        }
    }


    /**
     * 批量下载文件
     * @param viewLifecycleOwner
     * @param remoteFilePathList 需要下载的远端文件路径列表
     * @param localFolderPath 本地文件夹路径,用于保存下载的文件
     * @param onComplete 任务完成后的回调
     */
    fun downloadFiles(
        viewLifecycleOwner: LifecycleOwner,
        remoteFilePathList: MutableList<String>,
        localFolderPath: String,
        onComplete: (Int) -> Unit
    ) {
        viewLifecycleOwner.lifecycleScope.launch(Dispatchers.IO) {
            var count = 0

            val smbContext = getCIFSContext()

            for (path in remoteFilePathList) {
                val strList = path.split("/")
                var fileName = strList[strList.lastIndex]

                val url = "smb://${SAMBA_SERVER_IP}/${path.trimStart('/')}"
                val smbFile = try {
                    SmbFile(url, smbContext)
                } catch (e: IOException) {
                    Log.e(TAG, "Failed to create SmbFile", e)
                    continue
                }

                if (!smbFile.exists()) {
                    Log.e(TAG, "File does not exist: ${path}")
                    continue
                }

                try {
                    val localFile = File("$localFolderPath/$fileName")
                    if (!localFile.exists()) {
                        localFile.createNewFile()
                    }
                    val inputStream = BufferedInputStream(SmbFileInputStream(smbFile))
                    val outputStream = BufferedOutputStream(FileOutputStream(localFile))
                    inputStream.use { input ->
                        outputStream.use { output ->
                            val buffer = ByteArray(1024)
                            var bytesRead: Int
                            while (input.read(buffer).also { bytesRead = it } != -1) {
                                output.write(buffer, 0, bytesRead)
                            }
                        }
                    }
                    count++
                } catch (e: IOException) {
                    Log.e(TAG, "Failed to download file", e)
                    continue
                }
            }
            onComplete(count)
        }
    }

    /**
     * 获取包含配置参数的CIFSContext
     */
    private fun getCIFSContext(): CIFSContext {
        if (mCIFSContext == null) {
            val properties = Properties()
            properties.setProperty("jcifs.smb.client.domain", SAMBA_SERVER_IP);
            properties.setProperty("jcifs.smb.client.username", SAMBA_USERNAME);
            properties.setProperty("jcifs.smb.client.password", SAMBA_PASSWORD);
            SingletonContext.init(properties) //init只能初始化一次
            mCIFSContext = SingletonContext.getInstance()
        }
        return mCIFSContext!!
    }
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/609219.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

windows11如何设置无线网卡不休眠

为了在家里用向日葵等软件连接上公司的台式电脑&#xff0c;发现尴尬的事情&#xff1a;在家里连接时提示公司的电脑下线了。经排查&#xff0c;发现长时间不用时&#xff0c;公司的台式电脑的无线网卡休眠了。 windows11可以用下面的步骤设置无线网卡不休眠&#xff1a; 1. 设…

Sybase数据库分页查询(指定起始位置)

针对单表数据量过大的场景&#xff0c;分页查询必不可少。针对sybase数据库分页查询的案例全网稀少&#xff0c;特别是指定起始页的分页查询实现。 本文依靠实际开发场景&#xff0c;特此总结Sybase数据库分页查询&#xff08;指定起始位置&#xff09;。 目录 一、 SQL实现分…

SQL统计语句记录

1.达梦数据库 统计指定单位的12个月份的业务数据 SELECT a.DEPT_ID, b.dept_name, a.USER_NAME, count(a.dept_id) as count, sum(case when to_char(a.CREATE_TIME,yyyy-mm) 2023-01 THEN 1 else 0 end) as one,sum(case when to_char(a.CREATE_TIME,yyyy-mm) 2023-02 T…

JavaScript手写专题——图片懒加载、滚动节流、防抖手写

图片懒加载场景&#xff1a;在一些图片量比较大的网站&#xff08;比如电商网站首页&#xff0c;或者团购网站、小游戏首页等&#xff09;&#xff0c;如果我们尝试在用户打开页面的时候&#xff0c;就把所有的图片资源加载完毕&#xff0c;那么很可能会造成白屏、卡顿等现象&a…

内网安全-隧道技术SSHDNSICMPSMB上线通讯LinuxMac 简单总结

第126天&#xff1a;内网安全-隧道技术&SSH&DNS&ICMP&SMB&上线通讯Linux&Mac_内网安全-隧道技术_ssh_dns_icmp_smb_上线通讯linux_mac-CSDN博客 内网渗透—隧道技术_隧道技术csdn-CSDN博客 #SMB 隧道&通讯&上线 判断&#xff1a;445 通讯 上…

Azure Windows2012升级2016

Azure Windows2012升级2016 在自己电脑配置Azure PowerShell前置条件PowerShell 登录到 Azure Azure 中运行 Windows Server 的 VM 的就地升级前置条件&#xff0c;生成一块OS磁盘将生成的OS磁盘附件到需升级的服务器执行就地升级到 Windows Server 2016 升级后配置故障恢复 在…

一觉醒来 AI科技圈发生的大小事儿 05月09日

&#x1f4f3;AlphaFold 3 重磅问世&#xff0c;全面预测蛋白质与所有生命分子相互作用及结构&#xff0c;准确性远超以往水平 Google DeepMind发布了AlphaFold3模型&#xff0c;能够联合预测蛋白质、核酸、小分子等复合物结构&#xff0c;准确性显著提高&#xff0c;对跨生物…

代码随想录算法训练营第36期DAY22

DAY22 654最大二叉树 自己做的时候忽略了&#xff1a;nums.length>1的题给条件。所以每次递归都要判断是否size()>1&#xff0c;不要空的。 /** * Definition for a binary tree node. * struct TreeNode { * int val; * TreeNode *left; * TreeNode *rig…

让数据更「高效」一点!IvorySQL在Neon平台上的迅速部署和灵活应用

IvorySQL本身就是一个100%兼容PostgreSQL最新内核的开源数据库系统&#xff0c;而Neon Autoscaling Platform通常支持多种数据库和应用程序。将IvorySQL集成到该平台后&#xff0c;可以进一步增强与其他系统和应用程序的兼容性&#xff0c;同时更全面的体验IvorySQL的Oracle兼容…

深入探究 Spring Boot Starter:从概念到实践

序言 Spring Boot Starter 是 Spring Boot 生态系统中的一个核心概念&#xff0c;它为开发者提供了一种便捷的方式来捆绑和配置应用程序所需的依赖项。本文将深入探讨 Spring Boot Starter 的概念、原理以及如何创建自定义的 Starter。 一、什么是 Spring Boot Starter Spri…

docker 安装elasticsearch8.X

docker 安装elasticsearch8.X 安装elasticsearch8.X前言安装elasticsearch安装elasticsearch-analysis-ik安装kibana 安装elasticsearch8.X 前言 由于需要安装elasticsearch、IK分词插件、kibana。所以需要保持这三者的版本一致性。 elasticsearch 8.12.2 kibana 8.12.2 ela…

科沃斯梦碎“扫地茅”,钱东奇跌落“风口”

昔日“扫地茅“不香了&#xff0c;科沃斯跌落神坛。 4月27日&#xff0c;科沃斯发布2023年报显示&#xff1a;2023年&#xff0c;科沃斯的营收为155.02亿元&#xff0c;同比增加1.16%&#xff1b;同期&#xff0c;净利为6.10亿元&#xff0c;同比减少63.96%。科沃斯的经营业绩…

Mysql数据在磁盘上的存储结构

一. 前言 一行数据的存储格式大致如下所示: 变长字段的长度列表&#xff0c;null值列表&#xff0c;数据头&#xff0c;column01的值&#xff0c;column02的值&#xff0c;column0n的值… 二. 变长字段 在MySQL里有一些字段的长度是变长的&#xff0c;是不固定的&#xff0c;…

可视化-实验五-Pyecharts工具包的使用及文本数据可视化

1.2.1 pyecharts的数据类型以及新的数据导入逻辑 由于pyecharts背后封装的js库&#xff0c;会涉及到数据类型转化。它暂时要求输入数据必须是python的基础数据类型&#xff0c;比如字符串&#xff0c;列表&#xff0c;字典&#xff0c;而不能是序列这样的数据类型。因此序列输入…

RockChip Android13 添加/删除ListPreference方法

概述: 本章将讲述在Android添加或删除ListPreference的几种方法,并以EthernetSettingsActivity为例,添加/删除一项ListPreference: 默认效果图: 添加后效果图: 方法一: 1、全部添加xml 在Activity类中使用addPreferencesFromResource()方法解析XML文件并添加Prefere…

Node.js安装与配置环境 v20.13.1(LTS)

1 下载 Node.js — Run JavaScript Everywhere LTS -- long-term support&#xff0c;长期维护版本 如果要下载其他版本在download里选择下载 2 安装 一路点击next&#xff0c;默认安装路径C:\Program Files\nodejs 3 环境变量配置 1&#xff09;Path环境变量增加nodejs安装…

艾体宝方案 | 加密USB金融解决方案

在现代金融行业中&#xff0c;保护敏感数据和合规性已成为至关重要的任务。为了帮助金融公司应对移动性风险和合规挑战&#xff0c;我们提供了一种高效的加密USB解决方案。 一、为什么金融公司需要加密USB解决方案 1、降低移动性风险 金融服务公司正在迅速过渡到一种模式&a…

将本地托管模型与 Elastic AI Assistant 结合使用的好处

作者&#xff1a;来自 Elastic James Spiteri, Dhrumil Patel 当今公共部门组织利用生成式人工智能解决安全挑战的一种方式。 凭借其筛选大量数据以发现异常模式的能力&#xff0c;生成式人工智能现在在帮助团队保护其组织免受网络威胁方面发挥着关键作用。 它还可以帮助安全专…

短信平台群发服务有什么优点

短信平台群发服务有什么优点 提高营销效率 短信平台群发服务利用自动化技术&#xff0c;可以帮助企业迅速向大量潜在客户营销信息。相比传统的逐一方式&#xff0c;群发服务可以同时大批目标客户&#xff0c;大大提高了营销效率。企业可以轻松地在短时间内覆盖更多的潜在客户&…

JavaSE——异常(2/2)-异常的处理(记录异常并提示 、尝试重新修复)

目录 记录异常并提示 案例演示 流程解析 写法优化 尝试重新修复 开发中对于异常的常见处理方式 一层一层往上抛出异常&#xff0c;并且在最上层捕获异常&#xff0c;分为两种不同的处理方式。 例如&#xff0c;B站网页报错就是采取的第一种方式&#xff1a; 记录异常并…
最新文章