「java读写ftp」java读写文件代码

admin 2023-01-03 18:18:09 683

本篇文章给大家谈谈java读写ftp，以及java读写文件代码对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

1、java获取ftp文件路径怎么写
2、用java怎么获取ftp上的文件
3、java远程读写文件详解
4、用java代码读取服务器的文件，请比较下ftpClien和SBMFile的优缺点。
5、java怎么打开FTP服务器上的文件
6、从JAVA写文件到FTP有几种方法?(2)

java获取ftp文件路径怎么写

package com.weixin.util;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.io.PrintWriter;

import java.io.RandomAccessFile;

import org.apache.commons.net.PrintCommandListener;

import org.apache.commons.net.;

import com.weixin.constant.DownloadStatus;

import com.weixin.constant.UploadStatus;

/**

* 支持断点续传的FTP实用类

* @version 0.1 实现基本断点上传下载

* @version 0.2 实现上传下载进度汇报

* @version 0.3 实现中文目录创建及中文文件创建，添加对于中文的支持

public class ContinueFTP {

public FTPClient ftpClient = new FTPClient();

public ContinueFTP(){

//设置将过程中使用到的命令输出到控制台

this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));

}

/**

* 连接到FTP服务器

* @param hostname 主机名

* @param port 端口

* @param username 用户名

* @param password 密码

* @return 是否连接成功

* @throws IOException

public boolean connect(String hostname,int port,String username,String password) throws IOException{

ftpClient.connect(hostname, port);

ftpClient.setControlEncoding("GBK");

if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){

if(ftpClient.login(username, password)){

return true;

}

disconnect();

return false;

}

/**

* 从FTP服务器上下载文件,支持断点续传，上传百分比汇报

* @param remote 远程文件路径

* @param local 本地文件路径

* @return 上传的状态

* @throws IOException

public DownloadStatus download(String remote,String local) throws IOException{

//设置被动模式

ftpClient.enterLocalPassiveMode();

//设置以二进制方式传输

ftpClient.setFileType();

DownloadStatus result;

//检查远程文件是否存在

FTPFile[] files = ftpClient.listFiles(new String(remote.getBytes("GBK"),"iso-8859-1"));

if(files.length != 1){

System.out.println("远程文件不存在");

return DownloadStatus.Remote_File_Noexist;

}

long lRemoteSize = files[0].getSize();

File f = new File(local);

//本地存在文件，进行断点下载

if(f.exists()){

long localSize = f.length();

//判断本地文件大小是否大于远程文件大小

if(localSize = lRemoteSize){

System.out.println("本地文件大于远程文件，下载中止");

return DownloadStatus.Local_Bigger_Remote;

}

//进行断点续传，并记录状态

FileOutputStream out = new FileOutputStream(f,true);

ftpClient.setRestartOffset(localSize);

InputStream in = ftpClient.retrieveFileStream(new String(remote.getBytes("GBK"),"iso-8859-1"));

byte[] bytes = new byte[1024];

long step = lRemoteSize /100;

long process=localSize /step;

int c;

while((c = in.read(bytes))!= -1){

out.write(bytes,0,c);

localSize+=c;

long nowProcess = localSize /step;

if(nowProcess process){

process = nowProcess;

if(process % 10 == 0)

System.out.println("下载进度："+process);

//TODO 更新文件下载进度,值存放在process变量中

}

in.close();

out.close();

boolean isDo = ftpClient.completePendingCommand();

if(isDo){

result = DownloadStatus.Download_From_Break_Success;

}else {

result = DownloadStatus.Download_From_Break_Failed;

}

}else {

OutputStream out = new FileOutputStream(f);

InputStream in= ftpClient.retrieveFileStream(new String(remote.getBytes("GBK"),"iso-8859-1"));

byte[] bytes = new byte[1024];

long step = lRemoteSize /100;

long process=0;

long localSize = 0L;

int c;

while((c = in.read(bytes))!= -1){

out.write(bytes, 0, c);

localSize+=c;

long nowProcess = localSize /step;

if(nowProcess process){

process = nowProcess;

if(process % 10 == 0)

System.out.println("下载进度："+process);

//TODO 更新文件下载进度,值存放在process变量中

}

in.close();

out.close();

boolean upNewStatus = ftpClient.completePendingCommand();

if(upNewStatus){

result = DownloadStatus.Download_New_Success;

}else {

result = DownloadStatus.Download_New_Failed;

}

return result;

}

/**

* 上传文件到FTP服务器，支持断点续传

* @param local 本地文件名称，绝对路径

* @param remote 远程文件路径，使用/home/directory1/subdirectory/file.ext 按照Linux上的路径指定方式，支持多级目录嵌套，支持递归创建不存在的目录结构

* @return 上传结果

* @throws IOException

public UploadStatus upload(String local,String remote) throws IOException{

//设置PassiveMode传输

ftpClient.enterLocalPassiveMode();

//设置以二进制流的方式传输

ftpClient.setFileType();

ftpClient.setControlEncoding("GBK");

UploadStatus result;

//对远程目录的处理

String remoteFileName = remote;

if(remote.contains("/")){

remoteFileName = remote.substring(remote.lastIndexOf("/")+1);

//创建服务器远程目录结构，创建失败直接返回

if(CreateDirecroty(remote, ftpClient)==UploadStatus.Create_Directory_Fail){

return UploadStatus.Create_Directory_Fail;

}

//检查远程是否存在文件

FTPFile[] files = ftpClient.listFiles(new String(remoteFileName.getBytes("GBK"),"iso-8859-1"));

if(files.length == 1){

long remoteSize = files[0].getSize();

File f = new File(local);

long localSize = f.length();

if(remoteSize==localSize){

return UploadStatus.File_Exits;

}else if(remoteSize localSize){

return UploadStatus.Remote_Bigger_Local;

}

//尝试移动文件内读取指针,实现断点续传

result = uploadFile(remoteFileName, f, ftpClient, remoteSize);

//如果断点续传没有成功，则删除服务器上文件，重新上传

if(result == UploadStatus.Upload_From_Break_Failed){

if(!ftpClient.deleteFile(remoteFileName)){

return UploadStatus.Delete_Remote_Faild;

}

result = uploadFile(remoteFileName, f, ftpClient, 0);

}

}else {

result = uploadFile(remoteFileName, new File(local), ftpClient, 0);

}

return result;

}

/**

* 断开与远程服务器的连接

* @throws IOException

public void disconnect() throws IOException{

if(ftpClient.isConnected()){

ftpClient.disconnect();

}

/**

* 递归创建远程服务器目录

* @param remote 远程服务器文件绝对路径

* @param ftpClient FTPClient对象

* @return 目录创建是否成功

* @throws IOException

public UploadStatus CreateDirecroty(String remote,FTPClient ftpClient) throws IOException{

UploadStatus status = UploadStatus.Create_Directory_Success;

String directory = remote.substring(0,remote.lastIndexOf("/")+1);

if(!directory.equalsIgnoreCase("/")!ftpClient.changeWorkingDirectory(new String(directory.getBytes("GBK"),"iso-8859-1"))){

//如果远程目录不存在，则递归创建远程服务器目录

int start=0;

int end = 0;

if(directory.startsWith("/")){

start = 1;

}else{

start = 0;

}

end = directory.indexOf("/",start);

while(true){

String subDirectory = new String(remote.substring(start,end).getBytes("GBK"),"iso-8859-1");

if(!ftpClient.changeWorkingDirectory(subDirectory)){

if(ftpClient.makeDirectory(subDirectory)){

ftpClient.changeWorkingDirectory(subDirectory);

}else {

System.out.println("创建目录失败");

return UploadStatus.Create_Directory_Fail;

}

start = end + 1;

end = directory.indexOf("/",start);

//检查所有目录是否创建完毕

if(end = start){

break;

}

return status;

}

/**

* 上传文件到服务器,新上传和断点续传

* @param remoteFile 远程文件名，在上传之前已经将服务器工作目录做了改变

* @param localFile 本地文件File句柄，绝对路径

* @param processStep 需要显示的处理进度步进值

* @param ftpClient FTPClient引用

* @return

* @throws IOException

public UploadStatus uploadFile(String remoteFile,File localFile,FTPClient ftpClient,long remoteSize) throws IOException{

UploadStatus status;

//显示进度的上传

long step = localFile.length() / 100;

long process = 0;

long localreadbytes = 0L;

RandomAccessFile raf = new RandomAccessFile(localFile,"r");

OutputStream out = ftpClient.appendFileStream(new String(remoteFile.getBytes("GBK"),"iso-8859-1"));

//断点续传

if(remoteSize0){

ftpClient.setRestartOffset(remoteSize);

process = remoteSize /step;

raf.seek(remoteSize);

localreadbytes = remoteSize;

}

byte[] bytes = new byte[1024];

int c;

while((c = raf.read(bytes))!= -1){

out.write(bytes,0,c);

localreadbytes+=c;

if(localreadbytes / step != process){

process = localreadbytes / step;

System.out.println("上传进度:" + process);

//TODO 汇报上传状态

}

out.flush();

raf.close();

out.close();

boolean result =ftpClient.completePendingCommand();

if(remoteSize 0){

status = result?UploadStatus.Upload_From_Break_Success:UploadStatus.Upload_From_Break_Failed;

}else {

status = result?UploadStatus.Upload_New_File_Success:UploadStatus.Upload_New_File_Failed;

}

return status;

}

public static void main(String[] args) {

ContinueFTP myFtp = new ContinueFTP();

try {

System.err.println(my("10.10.6.236", 21, "5", "jieyan"));

// my(new String("歌曲".getBytes("GBK"),"iso-8859-1"));

// my(new String("爱你等于爱自己".getBytes("GBK"),"iso-8859-1"));

// System.out.println(my("E:\\yw.flv", "/yw.flv",5));

// System.out.println(my("E:\\爱你等于爱自己.mp4","/爱你等于爱自己.mp4"));

//System.out.println(my("/爱你等于爱自己.mp4", "E:\\爱你等于爱自己.mp4"));

my;

} catch (IOException e) {

System.out.println("连接FTP出错："+e.getMessage());

}

用java怎么获取ftp上的文件

public class FtpClientUtil {

FtpClient ftpClient;

private String server;

private int port;

private String userName;

private String userPassword;

public FtpClientUtil(String server,int port,String userName,String userPassword)

{

this.server=server;

this.port=port;

this.userName=userName;

this.userPassword=userPassword;

}

/**

* 链接到服务器

* @return

public boolean open()

{

if(ftpClient!=nullftpClient.serverIsOpen())

return true;

try

{

ftpClient= new FtpClient();

ftpClient.openServer(server,port);

ftpClient.login(userName, userPassword);

ftpClient.binary();

return true;

}

catch(Exception e)

{

e.printStackTrace();

ftpClient=null;

return false;

}

public boolean cd(String dir){

boolean f = false;

try {

ftpClient.cd(dir);

} catch (IOException e) {

Logs.error(e.toString());

return f;

}

return true;

}

/**

* 上传文件到FTP服务器

* @param localPathAndFileName 本地文件目录和文件名

* @param ftpFileName 上传后的文件名

* @param ftpDirectory FTP目录如:/path1/pathb2/,如果目录不存在回自动创建目录

* @throws Exception

public boolean upload(String localDirectoryAndFileName,String ftpFileName,String ftpDirectory)throws Exception {

if(!open())

return false;

FileInputStream is=null;

TelnetOutputStream os=null;

try

{

char ch = ' ';

if (ftpDirectory.length() 0)

ch = ftpDirectory.charAt(ftpDirectory.length() - 1);

for (; ch == '/' || ch == '\\'; ch = ftpDirectory.charAt(ftpDirectory.length() - 1))

ftpDirectory = ftpDirectory.substring(0, ftpDirectory.length() - 1);

int slashIndex = ftpDirectory.indexOf(47);

int backslashIndex = ftpDirectory.indexOf(92);

int index = slashIndex;

String dirall = ftpDirectory;

if (backslashIndex != -1 (index == -1 || index backslashIndex))

index = backslashIndex;

String directory = "";

while (index != -1) {

if (index 0) {

String dir = dirall.substring(0, index);

directory = directory + "/" + dir;

ftpClient.sendServer("XMKD " + directory + "\r\n");

ftpClient.readServerResponse();

}

dirall = dirall.substring(index + 1);

slashIndex = dirall.indexOf(47);

backslashIndex = dirall.indexOf(92);

index = slashIndex;

if (backslashIndex != -1 (index == -1 || index backslashIndex))

index = backslashIndex;

}

ftpClient.sendServer("XMKD " + ftpDirectory + "\r\n");

ftpClient.readServerResponse();

os = ftpClient.put(ftpDirectory + "/"

+ ftpFileName);

File file_in = new File(localDirectoryAndFileName);

is = new FileInputStream(file_in);

byte bytes[] = new byte[1024];

int i;

while ((i = is.read(bytes)) != -1)

os.write(bytes, 0, i);

//清理垃圾

return true;

}

catch(Exception e)

{

e.printStackTrace();

return false;

}

finally

{

if (is != null)

is.close();

if (os != null)

os.close();

}

/**

* 从FTP服务器上下载文件并返回下载文件长度

* @param ftpDirectoryAndFileName

* @param localDirectoryAndFileName

* @return

* @throws Exception

public long download(String ftpDirectoryAndFileName,String localDirectoryAndFileName)throws Exception

{

long result = 0;

if(!open())

return result;

TelnetInputStream is = null;

FileOutputStream os = null;

try

{

is = ftpClient.get(ftpDirectoryAndFileName);

java.io.File outfile = new java.io.File(localDirectoryAndFileName);

os = new FileOutputStream(outfile);

byte[] bytes = new byte[1024];

int c;

while ((c = is.read(bytes)) != -1)

{

os.write(bytes, 0, c);

result = result + c;

}

catch (Exception e)

{

throw e;

}

finally

{

if (is != null)

is.close();

if (os != null)

os.close();

}

return result;

}

/**

* 返回FTP目录下的文件列表

* @param ftpDirectory

* @return

public ListString getFileNameList(String ftpDirectory)

{

ListString list = new ArrayListString();

if(!open())

return list;

try

{

DataInputStream dis = new DataInputStream(ftpClient.nameList(ftpDirectory));

String filename = "";

while((filename=dis.readLine())!=null)

{

list.add(filename);

}

} catch (Exception e)

{

e.printStackTrace();

}

return list;

}

/**

* 删除FTP上的文件

* @param ftpDirAndFileName

public boolean deleteFile(String ftpDirAndFileName)

{

if(!open())

return false;

ftpClient.sendServer("DELE "+ftpDirAndFileName+"\r\n");

return true;

}

/**

* 删除FTP目录

* @param ftpDirectory

public boolean deleteDirectory(String ftpDirectory)

{

if(!open())

return false;

ftpClient.sendServer("XRMD "+ftpDirectory+"\r\n");

return true;

}

/**

* 关闭链接

public void close()

{

try

{

if(ftpClient!=nullftpClient.serverIsOpen())

ftpClient.closeServer();

}catch(Exception e)

{

}

}望采纳，谢谢。

java远程读写文件详解

import java.io.BufferedReader;

import java.io.File;

import java.io.FileReader;

/**

* @author lmq

public class RemoteFile {

public static void main(String[] args) throws Exception {

File remoteFile = new File("//192.168.7.146/test/1.txt");// 192.168.7.146是对方机器IP，test是对方那个共享文件夹名字，如果没有共享是访问不到的

//远程文件其实主要是地址，地址弄对了就和本地文件没什么区别，windows里面//或者\\\\开头就表示这个文件是网络路径了其实这个地址就像我们再windows里面，点击开始

//然后点击运行，然后输入 \\192.168.7.146/test/1.txt访问远程文件一样的

BufferedReader br = new BufferedReader(new FileReader(remoteFile));

String str;

while ((str = br.readLine()) != null) {

System.out.println(str);

}

br.close();

}

希望能帮到你。

用java代码读取服务器的文件，请比较下ftpClien和SBMFile的优缺点。

相同点：都可以实现文件传输系统。

不同点：

FTP（File Transfer Protocol，文件传输协议），应用层协议，可跨平台。如其名，只能实现文件传输功能，不能实现一些其他的功能，例如文件系统挂载等功能，也就是只能将文件存到已存在的目录中。

SMB（Service Message Block，服务消息块协议），能够实现Windows和Linux主机之间的文件共享服务，可实现跨平台，在Linux上实现了微软CIFS（Common Internet File System）协议，CIFS使用户得到比FTP更好的对文件的控制。

相比之下SMB更好用

java怎么打开FTP服务器上的文件

http的话就用

httpclient

。open后，可以返回一个

InputStream

。这个就是你要读到

文件流

。

原理的话，参考你用浏览器打开这个链接显示的内容。

这个返回的是一个HTML网页，需要你解析出里面的文字（一般来说取body中间的内容就行）

其实对于这种文件一般用FTP来下载的。楼上写的那个不对，哈哈。

需要的话自己最好去查一下，怎么用，我有代码，不过告诉你的话也不太好？

URL

url

new

URL("http://你的地址");

URLConnection

connection

url.openConnection();

InputStream

connection.getInputStream();

BufferedReader

new

BufferedReader(new

InputStreamReader(is,"gb2312"));

下面就是解析这个字符串来，自己来吧

从JAVA写文件到FTP有几种方法?(2)

" );throw ftpprotocolexception; String responseStr = this .getResponseString(); int location = responseStr.lastIndexOf( " , " ); int n = Integer.parseInt(responseStr.substring(location + 1 , responseStr.indexOf( " ) " ))); responseStr = responseStr.substring( 0 ,location); location = responseStr.lastIndexOf( " , " ); int m = Integer.parseInt(responseStr.substring(location + 1 , responseStr.length())); socket = new Socket(serverAddr,m * 256 + n); } if (issueCommand(s) == FTP_ERROR){ MyFtpProtocolException ftpprotocolexception1 = new MyFtpProtocolException(s); throw ftpprotocolexception1; } return socket; } /** * 关闭与FTP服务器的连接 * @throws IOException */ public void closeServer() throws IOException{ socket.close(); socket = null ; super .closeServer(); } /** * 打开与FTP服务器的连接 * @param s FTP服务器地址 * @param i FTP服务器端口 * @throws IOException */ public void openServer(String s, int i) throws IOException{ super .openServer(s,i); serverAddr = s; } } /** * 自定义的FTP异常类 */ class MyFtpProtocolException extends IOException{ MyFtpProtocolException(String s){ super (s); } }编辑推荐Struts查看文件内容功能的方法每个Web应用程序都是一个独立的Servlet容器，每个Web应用程序分别用一个ServletContext对象。ServletContext对象包含在ServletConfig对象中，调用ServletConfig.getServletContext()方法获取ServletContext对象。调用ServletConfig.getServletContext()方法获取ServletContext对象。1、 getResourcePath 返回一个包含该目录和文件路径名称的Set集合2、 getResource 返回映射到资源上的URL对象。3、 getResourceAsStream 返回连接到某资源上的InputStream对象 InputStreamReader inputReader = new InputStreamReader(input); 需要重新包装成字符处理。

关于java读写ftp和java读写文件代码的介绍到此就结束了，不知道你从中找到你需要的信息了吗？如果你还想了解更多这方面的信息，记得收藏关注本站。

标签：java读写ftp