精华内容
下载资源
问答
  • 5、Java中用的线程调度算法是什么? 6、什么是线程组,为什么在Java中不推荐使用? 》7、为什么使用Executor框架? 8、在Java中Executor和Executors的区别? 9.如何在Windows和Linux上查找哪个线程使用的CPU时间最长? ...

    Java并发编程

    3、什么是多线程中的上下文切换?

    4、死锁与活锁的区别,死锁与饥饿的区别?

    5、Java中用到的线程调度算法是什么?

    6、什么是线程组,为什么在Java中不推荐使用?

    》7、为什么使用Executor框架?

    8、在Java中Executor和Executors的区别?

    9.如何在Windows和Linux上查找哪个线程使用的CPU时间最长?

    10、什么是原子操作?在Java Concurrency API中有哪些原子类(atomic cla

    11、Java Concurrency API中的Lock接口(Lock interface)是什么

    12、什么是Executors框架?

    13.什么是阻塞队列?阻塞队列的实现原理是什么?如何使用阻塞队列来实现生产者消费者模型?

    14、什么是Callable和Future?

    15.什么是FutureTask?使用ExecutorService启动任务。

    16.什么是并发容器的实现?

    17.多线程同步和互斥有几种实现方法,都是什么?

    18、 什么是竞争条件?你怎样发现和解决竞争?

    19、你将如何使用thread dump?你将如何分析Thread dump?

    20、为什么我们调用start0方法时会执行run0方法,为什么我们不能直接调用run0方法?

    21、Java中你怎样唤醒一个阻塞的线程?

    22、在Java中CycliBarriar和CountdownLatch有什么区别?

    23、什么是不可变对象,它对写并发应用有什么帮助?

    24、什么是多线程中的上下文切换?

    25、Java中用到的线程调度算法是什么?

    26.什么是线程组,为什么在Java中不推荐使用?

    27、为什么使用Executor框架比使用应用创建和管理线程好?

    28、java中有 几种方法可以实现一个线程?

    29、如何停止一个正在运行的线程?

    30. notifyO和notifyAIl0有什么区别?

    31、什么是Daemon线程?它有什么意义?

    32、java如何实现多线程之间的通讯和协作?

    33、什么是可重入锁(ReentrantLock) ?

    34.当一 个线程进入某个对象的一个synchronized的实例方法后,其

    它线程是否可进入此对象的其

    35、乐观锁和悲观锁的理解及如何实现,有哪些实现方式?

    36、SynchronizedMap和ConcurrentHashMap有什么区别?

    37、CopyOnWriteArrayList可以用于什么应用场暴?

    38、什么叫线程安全? servlet是线程安全吗?

    39、volatile有什么用? 能否用一句话说明 下volatile的应用场景?

    40.为什么代码会重排序?

    41、在java中wait和sleep方法的不同?

    42、用Java实现阻塞队列

    43、-个线程运行时发生异常会怎样?

    44、如何在两个线程间共享数据?

    45、Java中notify 和noftifyAll有什么区别44、 如何在两个线程间共享数据?

    46.为什么wait, notify 和ntfifAll这些万0ux四

    47.什么是ThreadLocal变量?

    48、Java中interrupted 和isInterrupted方法的区别?

    49、为什么wait和notify方法要在同步块中调用?

    50、为什么你应该在循环中检查等待条件?

    51、Java中的同步集合与并发集合有什么区别?

    52、什么是线程池?为什么要使用它?

    53、怎么检测一个线程是否拥有锁?

    54、 你如何在Java中获取线程堆栈?

    56、Thread类中的yield方法有什么作用?

    57. Java中ConcurrentHashMap的并发度是什么?

    58、Java中Semaphore是什么?

    59. Java线程池中submit0和execute0方法有什么区别?

    60.什么是阻塞式方法?

    61、Java中的ReadWriteLock是什么?

    62、volatile 变量和atomic变量有什么不同?

    63、可以直接调用Thread类的run 0方法么?

    64、如何让正在运行的线程暂停一段时间?

    65、你对线程优先级的理解是什么?

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    Spring面试题

    1.一般问题

    1.1.不同版本的Spring Framework有哪些主要功能?

    1.2.什么是Spring Framework? …

    1.3.列举Spring Framework的优点。

    1.4. Spring Framework有哪些不同的功能?

    1.5. Spring Framework中有多少个模块,它们分别是什么

    1.6.什么是Spring配置文件?

    1.7. Spring 应用程序有哪些不同组件? … …

    1.8.使用Spring有哪些方式?

    2.依赖注入(Ioc)

    2.1、什么是Spring IOC容器?

    2.2.什么是依赖注入?

    2.3.可以通过多少种方式完成依赖注入?

    2.4.区分构造函数注入和setter 注入。

    2.5. spring 中有多少种I0C 容器?

    2.6.区分BeanFactory 和ApplicationContext.

    2.7、列举loC 的一-些好处。

    2.8、Spring loC的实现机制。

    3.1.什么是spring bean?

    3.2. spring 提供了哪些配置方式?

    3.3. spring支持集中bean scope?

    3.4. spring bean容器的生命周期是什么样的?

    3.5.什么是spring的内部bean?

    3.6.什么是spring装配.

    3.7、自动装配有哪些方式?

    3.8、自动装配有什么局限?

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    Spring Boot面试题

    1.什么是Spring Boot?

    2、Spring Boot有哪些优点?

    3、什么是JavaConfig?

    4.如何重新加载Spring Boot上的更改,而无需重新启动服务器?

    5、Spring Boot中的监视器是什么? …

    6.如何在Spring Boot中禁用Actuator端点安全性?

    7.如何在自定义端口上运行Spring Boot应用程序?

    8.什么是YAML? …

    9.如何实现Spring Boot应用程序的安全性?

    10、如何集成Spring Boot和ActiveMQ?

    11、如何使用Spring Boot实现分页和排序?

    12.什么是Swagger?你用Spring Boot实现了它吗?

    13.什么是Spring Profiles?

    14.什么是Spring Batch?

    15. 什么是FreeMarker模板?

    16. 如何使用Spring Boot实现异常处理?

    17、您使用了哪些starter maven依赖项?

    18、什么是CSRF攻击?

    19. 什么是WebSockets?

    20、什么是AOP? .

    21、什么是Apache Kafka?

    22、我们如何监视所有Spring Boot微服务?

    Spring Cloud面试题.

    1.什么是Spring Cloud?

    2.使用Spring Cloud有什么优势?

    3.服务注册和发现是什么意思? Spring Cloud如何实现?

    4.负载平衡的意义什么?

    5.什么是Hytrix?它如何实现容错?

    6、什么是Hystrix断路器?我们需要它吗?

    7、什么是Netlix Feign?它的优点是什么?

    8、什么是Spring Cloud Bus?我们需要它吗?

    RabbitMQ面试题

    1.什么是rabbitm…

    2、为什么要使用rabitmq.

    3.使用rabbitmq的场景.

    4、如何确保消息正确地发送至RabbitMQ?如何确保消息接收

    费了消息?

    5.如何避免消息重复投递或重复消费?

    6.消息基于什么传输?

    7.消息如何分发?

    8.消息怎么路由?

    9.如何确保消息不丢失?

    10.使用RabbitMQ有什么好处?

    11、RabbitMQ 的集群.

    12、ma的缺点

    kafka面试题

    1.如何获取topic主题的列表…

    2、生产者和消费者的命令行是什么?

    3. consumer 是推还是拉?

    4.讲讲kafka维护消费状态跟踪的方法.

    5.讲一下主从同步.

    6.为什么需要消息系统,mysql 不能满足需求吗?

    7、Zookeeper对于Kafka的作用是什么?

    8、数据传输的事务定义有哪三种?

    9. Kafka 判断-个节点是否还活着有那两个条件?

    10、Kafka 与传统MQ消息系统之间有三个关键区…

    11.讲-讲kafka的ack的三种机制

    13.消费者故障,出现活锁问题如何解决?

    14.如何控制消费的位置.

    15. kafka 分布式(不是单机)的情况下,如何保证消息的顺序消

    16. kafka 的高可用机制是什么?

    17. kafka 如何减少数据丢失

    18、kafka 如何不消费重复数据?比如扣款,我们不能重复的扣。

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    MyBatis面试题

    1.什么是Mybatis? …

    2、Mybaits 的优点:

    3. MyBatis 框架的缺点:

    4. MyBatis 框架适用场合:

    5. MyBatis 与Hibemate有哪些不同?

    6. #0和$0的区别是什么?

    7、当实体类中的属性名和表中的字段名不-样,怎么办? …

    8、模糊查询like语句该怎么写?.

    9.通常一个Xml映射文件,都会写一个Dao接口与之对应,请

    这个Dao接口的工作原理是什么? Dao接口里的方法,参数不同方法能重载吗?

    10、 Mybatis是如何进行分页的?分页插件的原理是什么?

    11、Mybatis 是如何将sql执行结果封装为目标对象井返回的?哪些映射形式?

    12.如何执行批量插入?..

    13.如何获取自动生成的(生)键值?.

    14. 在mapper中如何传递多个参…

    15、 Mybatis动态sql有什么用?执行原理?有哪些动态sq!?

    16. Xml映射文件中,除了常见的selectinsertlupdaeldelete标外,还有哪些标签? … . … . …

    18.为什么说Mybatis是半自动ORM映射工具?它与全自动的在哪里?

    19. -对一、一对多的关联查询?

    20、MyBatis 实现-对一有几种方式?具体怎么操作的?

    21、MyBatis 实现- -对多有几种方式怎么操作的?

    22. Mybatis 是否支持延迟加载?如果支持,它的实现原理是什么

    23. Mybatis 的-级、二级缓存…

    24.什么是MyBatis的接口绑定?有哪些实现方式?

    25.使用MyBatis的mapper接口调用时有哪些要求?

    26. Mapper 编写有哪几种方式?

    27.简述Mybatis的插件运行原理,以及如何编写一个插件。

    ZooKeeper面试题

    1. ZooKeeper面试题?

    2. ZooKeeper提供了什么?

    3. Zookeeper文件系…

    4. ZAB协议?

    5.四种类型的数据节点Zno.e… …

    6. Zookeeper Watcher机制-数据变更通…

    7.客户端注册Watcher实现…

    8.服务端处理Watcher实现

    9.客户端回调Wartcer…_…

    10. ACL权限控制机制

    11. Chroot特性

    12.会话管理.

    13.服务器角色

    14. Zookeeper下Server工作状态

    15.数据同步

    16. zookeeper是如何保证事务的顺序一致性的?

    17.分布式集群中为什么会有Master?

    18. zk节点宕机如何处理?

    19. zookeeper负载均衡和nginx负载均衡区别…

    20. Zookeeper有哪几种几种部署模式?

    21.集群最少要几台机器,集群规则是怎样的?..

    22.集群支持动态添加机器吗?

    23. Zookeeper对节点的watch监听通知是永久的吗?为什么久的.?..

    24. Zookeeper的java客户端都有哪些?

    25. chubby是什么,和zookeeper比你怎么看?

    26.说几个zookeeper常用的命令。

    27. ZAB和Paxos算法的联系与区别?

    28. Zookeeper的典型应用场景

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    Dubbo面试题

    1.为什么要用Dubbo?

    2、Dubbo 的整体架构设计有哪些分层…

    3、默认使用的是什么通信框架,还有别的选择吗?

    4.服务调用是阻塞的吗?

    5. - 般使用什么注册中心?还有别的选择吗?

    6.默认使用什么序例化框架,你知道的还有哪些? …

    7、服务提供者能实现失效踢出是什么原理?

    8.服务上线怎么不影响旧版本?

    9.如何解决服务调用链过长的问题?

    10.说说核心的配置有哪些?

    11. Dubbo推荐用什么协议?

    12.同一个服务多个注册的情况下可以直连某一个服务吗? …

    13.画一画服务注册与发现的流程图?

    14. Dubbo集群容错有几种方案?

    15、Dubbo 服务降级,失败重试怎么做?

    16、Dubbo 使用过程中都遇到了些什么问题?

    17、Dubbo Monitor实现原理?

    18、Dubbo 用到哪些设计模式?

    19. Dubbo 配置文件是如何加载到Spring中的?

    20. Dubbo SPI和Java SPI区别?

    21. Dubbo 支持分布式事务吗?

    22. Dubbo 可以对结果进行缓存吗?

    23.服务上线怎么兼容旧版本?

    24、Dubbo 必须依赖的包有哪些?

    25. Dubbo telnet命令能做什么?

    26. Dubbo 支持服务降级吗? …

    27. Dubbo 如何优雅停机?

    28. Dubbo 和Dubbox之间的区别?

    29、Dubbo 和Spring Cloud的区别?

    30、你还了解别的分布式框架吗?

    Elasticsearch面试题.

    1. elasticsearch 了解多少,说说你们公司es的集群架构,索引楼大小,分片有多少,以及-些调优手段.

    2、elasticsearch 的倒排索引是什么

    3. elasticsearch 索引数据多了怎么办,如何调优,部署.

    4、elasticsearch 是如何实现master选举的.

    5.详细描述-下Elasticsearch索引文档的过程.

    6.详细描述-下Elasticsearch搜索的过程? … .

    7. Elasticsearch 在部署时,对Linux的设置有哪些优化方法… … .

    8. lucence 内部结构是什么?

    9. Elasticsearch 是如何实现Master选举的? .

    10、Elasticsearch 中的节点(比如共20个) ,其中的10个选了一master,另外10个选了另-个master,怎么办? …

    11、客户端在和集群连接时,如何选择特定的节点执行请求的?

    12.详细描述-下Elasticsearch索引|文档的过程。

    13、详细描述-下Elasticsearch更新和删除文档的过程。

    14、详细描述-下Elasticsearch搜索的过程。…

    15.在Elasticsearch中,是怎么根据一个词找到对应的倒排索引|的

    16、Elasticsearch 在部署时,对Linux的设置有哪些优化方法?

    17.对于GC方面,在使用Elasticsearch时要注意什么? … 9

    18. Elasticsearch对于大数据量(上亿量级)的聚合如何实现?

    19.在并发情况下,Elasticsearch如果保证读写-致?

    20、如何监控Elasticsearch集群状态?

    21.介绍下你们电商搜索的整体技术架构。

    22. 介绍一;下你们的个性化搜索方案? …

    23.是否了解字典树?

    24、拼写纠错是如何实现的?

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    Memcached面试题

    1、Memcached 是什么,有什么作用?

    2、Memcached 服务分布式集群如何实现?

    3、Memcached 服务特点及工作原理是什么?

    4、简述Memcached内存管理机制原理?

    5、memcached 是怎么工作的?

    6、memcached 最大的优势是什么?

    7、memcached 和MySQL的query.

    8、memcached和服务器的local cache

    9. memcached 的cache机制是怎样的?

    10、memcached如何实现冗余机制?

    11. memcached 如何处理容错的?

    12.如何将memcached中item批量导入导出?

    13.如果缓存数据在导出导入之间过期了,您又怎么处理这些数据听

    14、memcached 是如何做身份验证的?

    15. memcached的多线程是什么?如何使用它们?

    16. memcached 能接受的key的最大长度是多少?

    17. memcached 最大能存储多大的单个item?

    18、memcached 能够更有效地使用内存吗?

    19.什么是二进制协议,我该关注吗?

    20、memcached 的内存分配器是如何工作的?为什么不适

    malloc/free! ?为何要使用slabs?

    21. memcached 是原子的吗?

    22.如何实现集群中的session共享存储?

    23、memcached 与redis的区别?

    Redis面试题

    1、什么是Redis

    2、Redis 的数据类型?

    3.使用Redis有哪些好处?

    4、Redis 相比Memcached有哪些优势?

    5、Memcache 与Redis的区别都有哪些?

    6、Redis 是单进程单线程的?

    7. -个字符串类型的值能存储最大容量是多少?

    8、Redis 的持久化机制是什么?各自的优缺点?

    9、Redis 常见性能问题和解决方案:

    10、redis过期键的删除策略?

    11. Redis 的回收策略(淘汰策略) ?..

    12.为什么edis需要把所有数据放到内存中?

    13、Redis 的同步机制了解么?

    14、Pipeline 有什么好处,为什么要用pipeline?

    15. 是否使用过Redis集群,集群的原理是什么?

    16、Redis集群方案什么情况下会导致整个集群不可用?

    17. Redis 支持的Java客户端都有哪些?官方推荐用哪个?

    18、Jedis与Redisson对比有什么优缺点?

    19、Redis如何设置密码及验证密码?

    20、说说Redis哈希槽的概念?

    21. Redis 集群的主从复制模型是怎样的?

    22、Redis 集群会有写操作丢失吗?为什么?

    23、Redis 集群之间是如何复制的?

    24、Redis 集群最大节点个数是多少?

    25. Redis 集群如何选择数据库?

    26、怎么测试Redis的连通性?

    27.怎么理解Redis事务?

    28. Redis 事务相关的命令有哪几个?

    29. Redis key的过期时间和永久有效分别怎么设置?

    30、Redis 如何做内存优化?

    31. Redis 回收进程如何工作的?

    32、都有哪些办法可以降低Redis的内存使用情况呢?

    33、Redis 的内存用完了会发生什么?

    34、一个Redis实例最多能存放多少的keys? List. Set. Sorted:他们最多能存放多少元素?

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    MySQL面试题

    1、MySQL 中有哪几种锁?

    2、MySQL 中有哪些不同的表格?

    3.简述在MySQL数据库中MyISAM和InnoDB的区别… :

    4、MySQL中InnoDB支持的四种事务隔离级别名称,以及逐级之的区别?

    5、CHAR和VARCHAR的区别?

    6、主键和候选键有什么区别?

    7、myisamchk 是用来做什么的?

    8、如果-个表有一列定义为TIMESTAMP,将发生什么?

    9.你怎么看到为表格定义的所有索引?

    10、LIKE 声明中的%和是什么意思?

    11.列对比运算符是什么?

    12. BLOB 和TEXT有什么区别? …

    13. MySQL _fetch. array 和MySQL fetch. object 的区别是什么?

    14、MylSAM 表格将在哪里存储,并且还提供其存储格式?

    15. MySQL如何优化DISTINCT?

    16.如何显示前50行?

    17.可以使用多少列创建索引?

    18、NOW () 和CURRENT. DATE ()有什么区别?

    19.什么是非标准字符串类型?

    20.什么是通用SQL函数?

    21. MySQL 支持事务吗?

    22、MySQL 里记录货币用什么字段类型…

    23. MySQL 有关权限的表都有哪几个?

    三面美团、四面阿里成功斩下offer,全靠P8大佬的这份Java面经

    Kafka进阶篇知识点

    image

    Kafka高级篇知识点

    image

    44个Kafka知识点(基础+进阶+高级)解析如下

    image

    HAR的区别?

    6、主键和候选键有什么区别?

    7、myisamchk 是用来做什么的?

    8、如果-个表有一列定义为TIMESTAMP,将发生什么?

    9.你怎么看到为表格定义的所有索引?

    10、LIKE 声明中的%和是什么意思?

    11.列对比运算符是什么?

    12. BLOB 和TEXT有什么区别? …

    13. MySQL _fetch. array 和MySQL fetch. object 的区别是什么?

    14、MylSAM 表格将在哪里存储,并且还提供其存储格式?

    15. MySQL如何优化DISTINCT?

    16.如何显示前50行?

    17.可以使用多少列创建索引?

    18、NOW () 和CURRENT. DATE ()有什么区别?

    19.什么是非标准字符串类型?

    20.什么是通用SQL函数?

    21. MySQL 支持事务吗?

    22、MySQL 里记录货币用什么字段类型…

    23. MySQL 有关权限的表都有哪几个?

    [外链图片转存中…(img-VWKvvqdw-1627352504982)]

    Kafka进阶篇知识点

    [外链图片转存中…(img-4xMG9aUK-1627352504983)]

    Kafka高级篇知识点

    [外链图片转存中…(img-BUUTQwPq-1627352504984)]

    44个Kafka知识点(基础+进阶+高级)解析如下

    [外链图片转存中…(img-teCvs1UX-1627352504985)]

    由于篇幅有限,小编已将上面介绍的**《Kafka源码解析与实战》、Kafka面试专题解析、复习学习必备44个Kafka知识点(基础+进阶+高级)都整理成册,全部都是PDF文档**,有需求的朋友可以戳这里免费下载

    展开全文
  • java SFTP文件下载

    2019-04-21 22:44:25
    SFTPUtils.java import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.util.Properties; import org.apache.commons.logging.Log; import org.apache.commons.loggin...

    SFTPUtils.java

    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.util.Properties;
    
    import org.apache.commons.logging.Log;
    import org.apache.commons.logging.LogFactory;
    
    import com.jcraft.jsch.Channel;
    import com.jcraft.jsch.ChannelSftp;
    import com.jcraft.jsch.JSch;
    import com.jcraft.jsch.JSchException;
    import com.jcraft.jsch.Session;
    import com.jcraft.jsch.SftpException;
    
    public class SFTPUtils {
    	private static final Log log = LogFactory.getLog(SFTPUtils.class);
    	
    	/**
    	 * 通过密码SFTP连接服务器
    	 * 
    	 * @throws Exception
    	 */
    	public Session connectWithPassword(String username,String passwd,String address,int port) throws Exception {
    		try {
    			JSch jsch = new JSch();
    			Session session = jsch.getSession(username, address, port);
    			// if (log.isInfoEnabled()) {
    			// log.info("Session 已创建.");
    			// }
    			session.setPassword(passwd);
    			Properties sshConfig = new Properties();
    			sshConfig.put("StrictHostKeyChecking", "no");
    			session.setConfig(sshConfig);
    			session.connect();
    			
    			return session;
    		} catch (Exception e) {
    			throw new Exception("创建sftp连接异常", e);
    		}
    	}
    	
    	public ChannelSftp getChannelSftp(Session session){
    		Channel channel = null;
    		try {
    			channel = session.openChannel("sftp");
    			channel.connect();
    			
    		} catch (JSchException e) {
    			// TODO Auto-generated catch block
    			System.err.println("创建sftp连接异常");
    		}
    		
    		return (ChannelSftp) channel;
    		
    	}
    	
    	public void disconnect(ChannelSftp channelSftp,Session session) {
    		if (channelSftp != null) {
    			if (channelSftp.isConnected()) {
    				channelSftp.disconnect();
    			}
    		}
    		if (session != null) {
    			if (session.isConnected()) {
    				session.disconnect();
    			}
    		}
    	}
    	
    	/**
    	 * * 下载单个文件
    	 * 
    	 * @param remotPath
    	 *            远程下载目录(以路径符号结束)
    	 * @param remoteFileName
    	 *            下载文件名
    	 * @param localPath
    	 *            本地保存目录(以路径符号结束)
    	 * @param localFileName
    	 *            保存文件名
    	 * @return
    	 */
    	public boolean downloadFile(ChannelSftp channelSftp,String remotePath, String remoteFileName, String localPath, String localFileName) {
    		FileOutputStream fileoutput = null;
    		String remoteFile = "";
    		File file = null;
    		try {
    			String localFile = localPath + File.separator + localFileName;
    			remoteFile = remotePath + File.separator + remoteFileName;
    			file = new File(localFile);
    			mkdirs(localFile);
    			fileoutput = new FileOutputStream(file);
    			if(log.isInfoEnabled()){
    				log.info("localFile : " + localFile + ",remoteFile : " + remoteFile);
    			}
    			channelSftp.get(remoteFile, fileoutput);
    			
    			return true;
    		} catch(SftpException e){
    			 if(e.toString().equals("NO_FILE")){
    				 System.out.println("下载文件缺失");
    			 }
    			 if(log.isErrorEnabled()){
    				 log.error(e.getMessage());
    			 }
    			 return false;
    
    		}catch (Exception e) {
    			file.delete();
    			if(log.isErrorEnabled()){
    				 log.error(e.getMessage());
    			 }
    			return false;
    			
    		} finally {
    			if (null != fileoutput) {
    				try {
    					fileoutput.close();
    				} catch (IOException e) {
    					
    				}
    			}
    		}
    	}
    	
    	/**
    	 * 如果目录不存在就创建目录
    	 * 
    	 * @param path
    	 */
    	private void mkdirs(String path) {
    		File f = new File(path);
    		String fs = f.getParent();
    		f = new File(fs);
    		if (!f.exists()) {
    			f.mkdirs();
    		}
    	}
    
    }

    测试代码

    SFTPUtils sftpUtil = new SFTPUtils();
    		Session session = null;
    		ChannelSftp channelSftp = null;
    		String systemId = context.getDelocalizedValue(ContextConstants.REAL_SYSTEM);
    		String idmsPath = localPath + File.separator + "FileGateWay" + File.separator + systemId;
    		try {
    			session = sftpUtil.connectWithPassword(userName, passwd, address, port);
    			channelSftp = sftpUtil.getChannelSftp(session);
    			boolean sftpResult = sftpUtil.downloadFile(channelSftp, remotePath,remoteFileName, idmsPath, remoteFileName);
    			if(sftpResult){
    				log.info("下载文件成功");
    			}else{
    				log.error("下载文件失败");
    			}
    			
    		} catch (Exception e) {
    			// TODO Auto-generated catch block
    			log.error("下载文件失败");
    		}finally{
    			sftpUtil.disconnect(channelSftp, session);
    		}

     

    展开全文
  • Java SFTP文件上传下载

    千次阅读 2017-03-30 15:37:17
    Java实现SFTP,上传下载时可以变更文件名,记录一下 在安卓文章里看到的,用的包是:jsch-0.1.54.jar,log请换成log4jpublic class

    Java实现SFTP,上传下载时可以变更文件名,很实用
    在安卓文章里看到的,用的包是:jsch-0.1.54.jar,log请换成log4j

    public class SFTPUtils {  
    
        private String TAG="SFTPUtils";  
        private String host;  
        private String username;  
        private String password;  
        private int port = 22;  
        private ChannelSftp sftp = null;  
        private Session sshSession = null;  
    
        public SFTPUtils (String host, String username, String password) {  
            this.host = host;  
            this.username = username;  
            this.password = password;  
        }  
    
        /** 
         * connect server via sftp 
         */  
        public ChannelSftp connect() {  
            JSch jsch = new JSch();  
            try {  
                sshSession = jsch.getSession(username, host, port);  
                sshSession.setPassword(password);  
                Properties sshConfig = new Properties();  
                sshConfig.put("StrictHostKeyChecking", "no");  
                sshSession.setConfig(sshConfig);  
                sshSession.connect();  
                Channel channel = sshSession.openChannel("sftp");  
                if (channel != null) {  
                    channel.connect();  
                } else {  
                    Log.e(TAG, "channel connecting failed.");  
                }  
                sftp = (ChannelSftp) channel;  
            } catch (JSchException e) {  
                e.printStackTrace();  
            }  
            return sftp;  
        }  
    
    
    /** 
     * 断开服务器 
     */  
        public void disconnect() {  
            if (this.sftp != null) {  
                if (this.sftp.isConnected()) {  
                    this.sftp.disconnect();  
                    Log.d(TAG,"sftp is closed already");  
                }  
            }  
            if (this.sshSession != null) {  
                if (this.sshSession.isConnected()) {  
                    this.sshSession.disconnect();  
                    Log.d(TAG,"sshSession is closed already");  
                }  
            }  
        }  
    
        /** 
         * 单个文件上传 
         * @param remotePath 
         * @param remoteFileName 
         * @param localPath 
         * @param localFileName 
         * @return 
         */  
        public boolean uploadFile(String remotePath, String remoteFileName,  
                String localPath, String localFileName) {  
            FileInputStream in = null;  
            try {  
                createDir(remotePath);  
                System.out.println(remotePath);  
                File file = new File(localPath + localFileName);  
                in = new FileInputStream(file);  
                System.out.println(in);  
                sftp.put(in, remoteFileName);  
                System.out.println(sftp);  
                return true;  
            } catch (FileNotFoundException e) {  
                e.printStackTrace();  
            } catch (SftpException e) {  
                e.printStackTrace();  
            } finally {  
                if (in != null) {  
                    try {  
                        in.close();  
                    } catch (IOException e) {  
                        e.printStackTrace();  
                    }  
                }  
            }  
            return false;  
        }  
    
        /** 
         * 批量上传 
         * @param remotePath 
         * @param localPath 
         * @param del 
         * @return 
         */  
        public boolean bacthUploadFile(String remotePath, String localPath,  
                boolean del) {  
            try {  
                File file = new File(localPath);  
                File[] files = file.listFiles();  
                for (int i = 0; i < files.length; i++) {  
                    if (files[i].isFile()  
                            && files[i].getName().indexOf("bak") == -1) {  
                        synchronized(remotePath){  
                            if (this.uploadFile(remotePath, files[i].getName(),  
                                localPath, files[i].getName())  
                                && del) {  
                            deleteFile(localPath + files[i].getName());  
                            }  
                        }  
                    }  
                }  
                return true;  
            } catch (Exception e) {  
                e.printStackTrace();  
            } finally {  
                this.disconnect();  
            }  
            return false;  
    
        }  
    
        /** 
         * 批量下载文件 
         *  
         * @param remotPath 
         *            远程下载目录(以路径符号结束) 
         * @param localPath 
         *            本地保存目录(以路径符号结束) 
         * @param fileFormat 
         *            下载文件格式(以特定字符开头,为空不做检验) 
         * @param del 
         *            下载后是否删除sftp文件 
         * @return 
         */  
        @SuppressWarnings("rawtypes")  
        public boolean batchDownLoadFile(String remotPath, String localPath,  
                String fileFormat, boolean del) {  
            try {  
                connect();  
                Vector v = listFiles(remotPath);  
                if (v.size() > 0) {  
    
                    Iterator it = v.iterator();  
                    while (it.hasNext()) {  
                        LsEntry entry = (LsEntry) it.next();  
                        String filename = entry.getFilename();  
                        SftpATTRS attrs = entry.getAttrs();  
                        if (!attrs.isDir()) {  
                            if (fileFormat != null && !"".equals(fileFormat.trim())) {  
                                if (filename.startsWith(fileFormat)) {  
                                    if (this.downloadFile(remotPath, filename,  
                                            localPath, filename)  
                                            && del) {  
                                        deleteSFTP(remotPath, filename);  
                                    }  
                                }  
                            } else {  
                                if (this.downloadFile(remotPath, filename,  
                                        localPath, filename)  
                                        && del) {  
                                    deleteSFTP(remotPath, filename);  
                                }  
                            }  
                        }  
                    }  
                }  
            } catch (SftpException e) {  
                e.printStackTrace();  
            } finally {  
                this.disconnect();  
            }  
            return false;  
        }  
    
        /** 
         * 单个文件下载 
         * @param remotePath 
         * @param remoteFileName 
         * @param localPath 
         * @param localFileName 
         * @return 
         */  
        public boolean downloadFile(String remotePath, String remoteFileName,  
                String localPath, String localFileName) {  
            try {  
                sftp.cd(remotePath);  
                File file = new File(localPath + localFileName);  
                mkdirs(localPath + localFileName);  
                sftp.get(remoteFileName, new FileOutputStream(file));  
                return true;  
            } catch (FileNotFoundException e) {  
                e.printStackTrace();  
            } catch (SftpException e) {  
                e.printStackTrace();  
            }  
    
            return false;  
        }  
    
        /** 
         * 删除文件 
         * @param filePath 
         * @return 
         */  
        public boolean deleteFile(String filePath) {  
            File file = new File(filePath);  
                if (!file.exists()) {  
                    return false;  
                }  
                if (!file.isFile()) {  
                    return false;  
                }  
                return file.delete();  
            }  
    
        public boolean createDir(String createpath) {  
            try {  
                if (isDirExist(createpath)) {  
                    this.sftp.cd(createpath);  
                    Log.d(TAG,createpath);  
                    return true;  
                }  
                String pathArry[] = createpath.split("/");  
                StringBuffer filePath = new StringBuffer("/");  
                for (String path : pathArry) {  
                    if (path.equals("")) {  
                        continue;  
                    }  
                    filePath.append(path + "/");  
                        if (isDirExist(createpath)) {  
                            sftp.cd(createpath);  
                        } else {  
                            sftp.mkdir(createpath);  
                            sftp.cd(createpath);  
                        }  
                    }  
                    this.sftp.cd(createpath);  
                      return true;  
                } catch (SftpException e) {  
                    e.printStackTrace();  
                }  
                return false;  
            }  
    
        /** 
         * 判断目录是否存在 
         * @param directory 
         * @return 
         */  
        @SuppressLint("DefaultLocale")   
        public boolean isDirExist(String directory) {  
            boolean isDirExistFlag = false;  
            try {  
                SftpATTRS sftpATTRS = sftp.lstat(directory);  
                isDirExistFlag = true;  
                return sftpATTRS.isDir();  
            } catch (Exception e) {  
                if (e.getMessage().toLowerCase().equals("no such file")) {  
                    isDirExistFlag = false;  
                }  
            }  
            return isDirExistFlag;  
            }  
    
        public void deleteSFTP(String directory, String deleteFile) {  
            try {  
                sftp.cd(directory);  
                sftp.rm(deleteFile);  
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }  
    
        /** 
         * 创建目录 
         * @param path 
         */  
        public void mkdirs(String path) {  
            File f = new File(path);  
            String fs = f.getParent();  
            f = new File(fs);  
            if (!f.exists()) {  
                f.mkdirs();  
            }  
        }  
    
        /** 
         * 列出目录文件 
         * @param directory 
         * @return 
         * @throws SftpException 
         */  
    
        @SuppressWarnings("rawtypes")  
        public Vector listFiles(String directory) throws SftpException {  
            return sftp.ls(directory);  
        }  
    
    }
    展开全文
  • java读取从sftp下载到本地的zip文件代码: import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.FileInputStream; import java.io....
  • ... SFTP文件上传和下载 博客分类: Java基础 JavaJsch 1.jsch官方API查看地址(附件为需要的jar) http://www.jcraft.com/jsch/ 2.jsch简介 JSch(Java Secure Channel)是一个SS...

    https://blog.csdn.net/xyjcfucdi128/article/details/99290515

    https://www.cnblogs.com/niudaxianren/p/12532141.html

     

    SFTP文件上传和下载

    博客分类:

    JavaJsch 

    1.jsch官方API查看地址(附件为需要的jar) 
    http://www.jcraft.com/jsch/ 

    2.jsch简介 
    JSch(Java Secure Channel)是一个SSH2的纯Java实现。它允许你连接到一个SSH服务器,并且可以使用端口转发,X11转发,文件传输等,当然你也可以集成它的功能到你自己的应用程序。 
      SFTP(Secure File Transfer Protocol)安全文件传送协议。可以为传输文件提供一种安全的加密方法。SFTP 为 SSH的一部份,是一种传输文件到服务器的安全方式,但是传输效率比普通的FTP要低。 

    3.api常用的方法: 
    put():      文件上传 
    get():      文件下载 
    cd():       进入指定目录 
    ls():       得到指定目录下的文件列表 
    rename():   重命名指定文件或目录 
    rm():       删除指定文件 
    mkdir():    创建目录 
    rmdir():    删除目录 
    put和get都有多个重载方法,自己看源代码 

    4.对常用方法的使用,封装成一个util类 

    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.util.ArrayList;
    import java.util.Iterator;
    import java.util.List;
    import java.util.Properties;
    import java.util.Vector;
    
    import org.apache.log4j.Logger;
    
    import com.jcraft.jsch.Channel;
    import com.jcraft.jsch.ChannelSftp;
    import com.jcraft.jsch.JSch;
    import com.jcraft.jsch.Session;
    import com.jcraft.jsch.SftpATTRS;
    import com.jcraft.jsch.SftpException;
    import com.jcraft.jsch.ChannelSftp.LsEntry;
    /**
     * sftp工具类
     * 
     * @author xxx
     * @date 2014-6-17
     * @time 下午1:39:44
     * @version 1.0
     */
    public class SFTPUtils
    {
        private static Logger log = Logger.getLogger(SFTPUtils.class.getName());
    
        private String host;//服务器连接ip
        private String username;//用户名
        private String password;//密码
        private int port = 22;//端口号
        private ChannelSftp sftp = null;
        private Session sshSession = null;
    
        public SFTPUtils(){}
    
        public SFTPUtils(String host, int port, String username, String password)
        {
            this.host = host;
            this.username = username;
            this.password = password;
            this.port = port;
        }
    
        public SFTPUtils(String host, String username, String password)
        {
            this.host = host;
            this.username = username;
            this.password = password;
        }
    
        /**
         * 通过SFTP连接服务器
         */
        public void connect()
        {
            try
            {
                JSch jsch = new JSch();
                jsch.getSession(username, host, port);
                sshSession = jsch.getSession(username, host, port);
                if (log.isInfoEnabled())
                {
                    log.info("Session created.");
                }
                sshSession.setPassword(password);
                Properties sshConfig = new Properties();
                sshConfig.put("StrictHostKeyChecking", "no");
                sshSession.setConfig(sshConfig);
                sshSession.connect();
                if (log.isInfoEnabled())
                {
                    log.info("Session connected.");
                }
                Channel channel = sshSession.openChannel("sftp");
                channel.connect();
                if (log.isInfoEnabled())
                {
                    log.info("Opening Channel.");
                }
                sftp = (ChannelSftp) channel;
                if (log.isInfoEnabled())
                {
                    log.info("Connected to " + host + ".");
                }
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }
        }
    
        /**
         * 关闭连接
         */
        public void disconnect()
        {
            if (this.sftp != null)
            {
                if (this.sftp.isConnected())
                {
                    this.sftp.disconnect();
                    if (log.isInfoEnabled())
                    {
                        log.info("sftp is closed already");
                    }
                }
            }
            if (this.sshSession != null)
            {
                if (this.sshSession.isConnected())
                {
                    this.sshSession.disconnect();
                    if (log.isInfoEnabled())
                    {
                        log.info("sshSession is closed already");
                    }
                }
            }
        }
    
        /**
         * 批量下载文件
         * @param remotPath:远程下载目录(以路径符号结束,可以为相对路径eg:/assess/sftp/jiesuan_2/2014/)
         * @param localPath:本地保存目录(以路径符号结束,D:\Duansha\sftp\)
         * @param fileFormat:下载文件格式(以特定字符开头,为空不做检验)
         * @param fileEndFormat:下载文件格式(文件格式)
         * @param del:下载后是否删除sftp文件
         * @return
         */
        public List<String> batchDownLoadFile(String remotePath, String localPath,
                String fileFormat, String fileEndFormat, boolean del)
        {
            List<String> filenames = new ArrayList<String>();
            try
            {
                // connect();
                Vector v = listFiles(remotePath);
                // sftp.cd(remotePath);
                if (v.size() > 0)
                {
                    System.out.println("本次处理文件个数不为零,开始下载...fileSize=" + v.size());
                    Iterator it = v.iterator();
                    while (it.hasNext())
                    {
                        LsEntry entry = (LsEntry) it.next();
                        String filename = entry.getFilename();
                        SftpATTRS attrs = entry.getAttrs();
                        if (!attrs.isDir())
                        {
                            boolean flag = false;
                            String localFileName = localPath + filename;
                            fileFormat = fileFormat == null ? "" : fileFormat
                                    .trim();
                            fileEndFormat = fileEndFormat == null ? ""
                                    : fileEndFormat.trim();
                            // 三种情况
                            if (fileFormat.length() > 0 && fileEndFormat.length() > 0)
                            {
                                if (filename.startsWith(fileFormat) && filename.endsWith(fileEndFormat))
                                {
                                    flag = downloadFile(remotePath, filename,localPath, filename);
                                    if (flag)
                                    {
                                        filenames.add(localFileName);
                                        if (flag && del)
                                        {
                                            deleteSFTP(remotePath, filename);
                                        }
                                    }
                                }
                            }
                            else if (fileFormat.length() > 0 && "".equals(fileEndFormat))
                            {
                                if (filename.startsWith(fileFormat))
                                {
                                    flag = downloadFile(remotePath, filename, localPath, filename);
                                    if (flag)
                                    {
                                        filenames.add(localFileName);
                                        if (flag && del)
                                        {
                                            deleteSFTP(remotePath, filename);
                                        }
                                    }
                                }
                            }
                            else if (fileEndFormat.length() > 0 && "".equals(fileFormat))
                            {
                                if (filename.endsWith(fileEndFormat))
                                {
                                    flag = downloadFile(remotePath, filename,localPath, filename);
                                    if (flag)
                                    {
                                        filenames.add(localFileName);
                                        if (flag && del)
                                        {
                                            deleteSFTP(remotePath, filename);
                                        }
                                    }
                                }
                            }
                            else
                            {
                                flag = downloadFile(remotePath, filename,localPath, filename);
                                if (flag)
                                {
                                    filenames.add(localFileName);
                                    if (flag && del)
                                    {
                                        deleteSFTP(remotePath, filename);
                                    }
                                }
                            }
                        }
                    }
                }
                if (log.isInfoEnabled())
                {
                    log.info("download file is success:remotePath=" + remotePath
                            + "and localPath=" + localPath + ",file size is"
                            + v.size());
                }
            }
            catch (SftpException e)
            {
                e.printStackTrace();
            }
            finally
            {
                // this.disconnect();
            }
            return filenames;
        }
    
        /**
         * 下载单个文件
         * @param remotPath:远程下载目录(以路径符号结束)
         * @param remoteFileName:下载文件名
         * @param localPath:本地保存目录(以路径符号结束)
         * @param localFileName:保存文件名
         * @return
         */
        public boolean downloadFile(String remotePath, String remoteFileName,String localPath, String localFileName)
        {
            FileOutputStream fieloutput = null;
            try
            {
                // sftp.cd(remotePath);
                File file = new File(localPath + localFileName);
                // mkdirs(localPath + localFileName);
                fieloutput = new FileOutputStream(file);
                sftp.get(remotePath + remoteFileName, fieloutput);
                if (log.isInfoEnabled())
                {
                    log.info("===DownloadFile:" + remoteFileName + " success from sftp.");
                }
                return true;
            }
            catch (FileNotFoundException e)
            {
                e.printStackTrace();
            }
            catch (SftpException e)
            {
                e.printStackTrace();
            }
            finally
            {
                if (null != fieloutput)
                {
                    try
                    {
                        fieloutput.close();
                    }
                    catch (IOException e)
                    {
                        e.printStackTrace();
                    }
                }
            }
            return false;
        }
    
        /**
         * 上传单个文件
         * @param remotePath:远程保存目录
         * @param remoteFileName:保存文件名
         * @param localPath:本地上传目录(以路径符号结束)
         * @param localFileName:上传的文件名
         * @return
         */
        public boolean uploadFile(String remotePath, String remoteFileName,String localPath, String localFileName)
        {
            FileInputStream in = null;
            try
            {
                createDir(remotePath);
                File file = new File(localPath + localFileName);
                in = new FileInputStream(file);
                sftp.put(in, remoteFileName);
                return true;
            }
            catch (FileNotFoundException e)
            {
                e.printStackTrace();
            }
            catch (SftpException e)
            {
                e.printStackTrace();
            }
            finally
            {
                if (in != null)
                {
                    try
                    {
                        in.close();
                    }
                    catch (IOException e)
                    {
                        e.printStackTrace();
                    }
                }
            }
            return false;
        }
    
        /**
         * 批量上传文件
         * @param remotePath:远程保存目录
         * @param localPath:本地上传目录(以路径符号结束)
         * @param del:上传后是否删除本地文件
         * @return
         */
        public boolean bacthUploadFile(String remotePath, String localPath,
                boolean del)
        {
            try
            {
                connect();
                File file = new File(localPath);
                File[] files = file.listFiles();
                for (int i = 0; i < files.length; i++)
                {
                    if (files[i].isFile()
                            && files[i].getName().indexOf("bak") == -1)
                    {
                        if (this.uploadFile(remotePath, files[i].getName(),
                                localPath, files[i].getName())
                                && del)
                        {
                            deleteFile(localPath + files[i].getName());
                        }
                    }
                }
                if (log.isInfoEnabled())
                {
                    log.info("upload file is success:remotePath=" + remotePath
                            + "and localPath=" + localPath + ",file size is "
                            + files.length);
                }
                return true;
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }
            finally
            {
                this.disconnect();
            }
            return false;
    
        }
    
        /**
         * 删除本地文件
         * @param filePath
         * @return
         */
        public boolean deleteFile(String filePath)
        {
            File file = new File(filePath);
            if (!file.exists())
            {
                return false;
            }
    
            if (!file.isFile())
            {
                return false;
            }
            boolean rs = file.delete();
            if (rs && log.isInfoEnabled())
            {
                log.info("delete file success from local.");
            }
            return rs;
        }
    
        /**
         * 创建目录
         * @param createpath
         * @return
         */
        public boolean createDir(String createpath)
        {
            try
            {
                if (isDirExist(createpath))
                {
                    this.sftp.cd(createpath);
                    return true;
                }
                String pathArry[] = createpath.split("/");
                StringBuffer filePath = new StringBuffer("/");
                for (String path : pathArry)
                {
                    if (path.equals(""))
                    {
                        continue;
                    }
                    filePath.append(path + "/");
                    if (isDirExist(filePath.toString()))
                    {
                        sftp.cd(filePath.toString());
                    }
                    else
                    {
                        // 建立目录
                        sftp.mkdir(filePath.toString());
                        // 进入并设置为当前目录
                        sftp.cd(filePath.toString());
                    }
    
                }
                this.sftp.cd(createpath);
                return true;
            }
            catch (SftpException e)
            {
                e.printStackTrace();
            }
            return false;
        }
    
        /**
         * 判断目录是否存在
         * @param directory
         * @return
         */
        public boolean isDirExist(String directory)
        {
            boolean isDirExistFlag = false;
            try
            {
                SftpATTRS sftpATTRS = sftp.lstat(directory);
                isDirExistFlag = true;
                return sftpATTRS.isDir();
            }
            catch (Exception e)
            {
                if (e.getMessage().toLowerCase().equals("no such file"))
                {
                    isDirExistFlag = false;
                }
            }
            return isDirExistFlag;
        }
    
        /**
         * 删除stfp文件
         * @param directory:要删除文件所在目录
         * @param deleteFile:要删除的文件
         * @param sftp
         */
        public void deleteSFTP(String directory, String deleteFile)
        {
            try
            {
                // sftp.cd(directory);
                sftp.rm(directory + deleteFile);
                if (log.isInfoEnabled())
                {
                    log.info("delete file success from sftp.");
                }
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }
        }
    
        /**
         * 如果目录不存在就创建目录
         * @param path
         */
        public void mkdirs(String path)
        {
            File f = new File(path);
    
            String fs = f.getParent();
    
            f = new File(fs);
    
            if (!f.exists())
            {
                f.mkdirs();
            }
        }
    
        /**
         * 列出目录下的文件
         * 
         * @param directory:要列出的目录
         * @param sftp
         * @return
         * @throws SftpException
         */
        public Vector listFiles(String directory) throws SftpException
        {
            return sftp.ls(directory);
        }
    
        public String getHost()
        {
            return host;
        }
    
        public void setHost(String host)
        {
            this.host = host;
        }
    
        public String getUsername()
        {
            return username;
        }
    
        public void setUsername(String username)
        {
            this.username = username;
        }
    
        public String getPassword()
        {
            return password;
        }
    
        public void setPassword(String password)
        {
            this.password = password;
        }
    
        public int getPort()
        {
            return port;
        }
    
        public void setPort(int port)
        {
            this.port = port;
        }
    
        public ChannelSftp getSftp()
        {
            return sftp;
        }
    
        public void setSftp(ChannelSftp sftp)
        {
            this.sftp = sftp;
        }
        
        /**测试*/
        public static void main(String[] args)
        {
            SFTPUtils sftp = null;
            // 本地存放地址
            String localPath = "D:/tomcat5/webapps/ASSESS/DocumentsDir/DocumentTempDir/txtData/";
            // Sftp下载路径
            String sftpPath = "/home/assess/sftp/jiesuan_2/2014/";
            List<String> filePathList = new ArrayList<String>();
            try
            {
                sftp = new SFTPUtils("10.163.201.115", "tdcp", "tdcp");
                sftp.connect();
                // 下载
                sftp.batchDownLoadFile(sftpPath, localPath, "ASSESS", ".txt", true);
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }
            finally
            {
                sftp.disconnect();
            }
        }
    }
    


    5.需要的时间辅助类,顺带记下,下次可以直接拿来用 

    /**
     * 时间处理工具类(简单的)
     * @author Aaron
     * @date 2014-6-17
     * @time 下午1:39:44
     * @version 1.0
     */
    public class DateUtil {
         /**
         * 默认时间字符串的格式
         */
        public static final String DEFAULT_FORMAT_STR = "yyyyMMddHHmmss";
        
        public static final String DATE_FORMAT_STR = "yyyyMMdd";
        
        /**
         * 获取系统时间的昨天
         * @return
         */
        public static String getSysTime(){
             Calendar ca = Calendar.getInstance();   
             ca.set(Calendar.DATE, ca.get(Calendar.DATE)-1);
             Date d = ca.getTime();
             SimpleDateFormat sdf =  new SimpleDateFormat("yyyyMMdd");
             String a = sdf.format(d);
            return a;
        }
        
        /**
         * 获取当前时间
         * @param date
         * @return
         */
        public static String getCurrentDate(String formatStr)
        {
            if (null == formatStr)
            {
                formatStr=DEFAULT_FORMAT_STR;
            }
            return date2String(new Date(), formatStr);
        }
        
        /**
         * 返回年月日
         * @return yyyyMMdd
         */
        public static String getTodayChar8(String dateFormat){
            return DateFormatUtils.format(new Date(), dateFormat);
        }
        
        /**
         * 将Date日期转换为String
         * @param date
         * @param formatStr
         * @return
         */
        public static String date2String(Date date, String formatStr)
        {
            if (null == date || null == formatStr)
            {
                return "";
            }
            SimpleDateFormat df = new SimpleDateFormat(formatStr);
    
            return df.format(date);
        }
    }
    展开全文
  • Java Sftp上传下载文件

    2016-01-23 19:33:00
    需要使用jar包 jsch-0.1....sftp上传下载实现类 package com.bstek.transit.sftp; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException;...
  • Java SFTP 传输文件实例

    2019-07-29 14:52:34
    这篇文章将介绍如何用 Java 在远程服务器上通过 SFTP 上传和下载文件。 接下来将使用三种不同的开发库实现,分别是 JSch、SSHJ 和 Apache Commons VFS。 2. 使用 JSch 首先,让我们看看如何使用 JSch 在...
  • java sftp工具类 引用: jsch-0.1.54.jar <dependency> <groupId>com.jcraft</groupId> <artifactId>jsch</artifactId> <version>0.1.54</version> </...
  • 3、文件上传:jdk下载到本机/software目录,用sftp进入到服务器的存放目录,用put发送文件 pwd查看服务器当前目录 lpwd查看本地当前目录 quit退出sftp 4、文件下载 get xxx.jar lls列举本地...
  • sftp下载文件 java

    2018-11-27 20:30:31
    角色:服务器A,服务器B,...所以我们需要将A的文件下载到B上,然后再下载到本地C。 JSch jsch = new JSch(); com.jcraft.jsch.Session session = jsch.getSession("youruserName", "IP", ...
  • 最近用到了sftp,记录一下,安装sftp我就不介绍了,网上有的是 依赖 <dependency> <groupId>com.jcraft</groupId> <artifactId>jsch</artifactId> <version>0.1.54</...
  • import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java...
  • JAVA Sftp 上传下载

    2019-01-03 14:15:35
    * * @param delRemote:下载后是否删除sftp文件 * * @return * */ public List<String> downloadFiles(String remotePath, String localPath, String prefix, String suffix, boolean delRemote) { ...
  • java远程下载文件到本地 public class getFile { public static void downloadFile(String remoteFilePath, String localFilePath){ URL urlfile = null; HttpURLConnection httpUrl = null; ...
  • 主要介绍了Java使用SFTP上传文件到服务器的简单使用,非常不错,具有参考借鉴价值,需要的朋友可以参考下
  • JAVA sftp单个文件上传

    2020-05-19 16:55:57
    import com.jcraft.jsch.Channel; import com.jcraft.jsch.ChannelSftp; ... ... import java.io.File;...import java.io.FileInputStream;...import java.io.InputStream;...import java.time.LocalDateTime;...import java..
  • Java 通过SFTP下载文件

    2021-07-02 16:46:40
    通过SFTP下载文件 工具类 import com.jcraft.jsch.*; import com.jcraft.jsch.Session; import com.sun.istack.internal.logging.Logger; import java.io.*; import java.util.*; public class SFTPUtils { ...
  • java sftp连接读取上传下载 Nav logo写文章 注册登录 首页 下载App 搜索 × 广告 java利用jsch操作sftp工具类 96 decodelife 关注 2018.08.14 18:15* 字数 0 阅读 324评论 0喜欢 0 package ...
  • 1、将sftp文件无法保存到本地 2、无法删除本地文件问题 二、问题分析 问题1由于在代码中没有对应的父级目录,导致创建本地文件失败 问题2由于FileOutputStream 在写文件后,io没有关闭, 导致文件一直有引用而无法...
  • 首先声明: 该项目会先在本地创建一个临时文件夹,将文件下载到本地后打包发送到浏览器,发送完成后将本地文件删除。 jsp页面部分 <div class="queryCondition"> <table class="query" width="100%" ...
  • JAVA代码实现SFTP文件下载

    万次阅读 2016-03-24 23:37:45
    JAVA代码实现SFTP文件下载
  • Java中使用sftp进行文件上传与下载最近项目中使用sftp进行文件上传与下载,特意写一篇文章用来作为例子参考: 注:项目的pom文件里面需要加上依赖包: <groupId>com.jcraft</groupId> <artifactId>jsch ...
  • JavaSFTP服务器下载文件

    千次阅读 2017-11-30 16:19:55
    SFTP下载文件需要用到jsch的jar包,我用的是jsch-0.1.54.jar,可以到http://www.jcraft.com/jsch/中下载到最新的jsch的jar包,源码以及实例。 package test; import java.io.File; import java.util.Properties
  • Java使用sftp定时下载文件

    千次阅读 2018-05-11 18:02:55
    * 下载文件到本地 * * @param source 源文件 * @param target 目标文件 * @throws SftpException 异常 * @throws FileNotFoundException 异常 */ private void download (String source, ...
  • java sftp demo

    2020-10-09 14:02:41
    import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.UnsupportedEncodingException; import java.util.ArrayList; import java.util.List; import java.util.Prop
  • * 根据指定URL将文件下载到指定目标位置 * urlPath 下载路径 * downloadDir 文件存放目录 * @return */ public String downloadFile(HttpServletRequest request,String urlPath){ File file = null...
  • java编码,通过ftp和sftp连接linux服务器上次和下载文件

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 5,880
精华内容 2,352
关键字:

javasftp下载文件到本地

java 订阅