FTP上传文件

Java代码  

1. package cn.com.songjy;   
2.   
3. import java.io.File;   
4. import java.io.FileInputStream;   
5. import java.io.IOException;   
6.   
7. import org.apache.log4j.Logger;   
8.   
9. import sun.net.TelnetOutputStream;   
10. import sun.net.ftp.FtpClient;   
11.   
12. public class FTPUPload {   
13.   
14.     private static Logger log = Logger.getLogger(FTPUPload.class);   
15.     static FtpClient ftpClient = null;   
16.   
17.     /**  
18.      * 建立FTP连接  
19.      * @method connection  
20.      * @param ip 远程计算机IP  
21.      * @param user ftp用户  
22.      * @param password ftp用户的密码  
23.      * @param newpath 远程计算机目录  
24.      * @return  
25.      */  
26.     public static boolean connection(String ip, String user, String password,   
27.             String newpath) {   
28.            
29.         log.info("远程IP地址："+ip);   
30.         log.info("FTP账户："+user);   
31.         log.info("FTP账户密码："+password);   
32.         log.info("远程目录："+newpath);   
33.            
34.         ftpClient = new FtpClient();   
35.         try {   
36.             ftpClient.openServer(ip);   
37.             ftpClient.login(user, password);   
38.             if (newpath.length() > 0) {   
39.                 ftpClient.cd(newpath);   
40.             }   
41.             ftpClient.binary();   
42.             return true;   
43.         } catch (IOException e) {   
44.             e.printStackTrace();   
45.         }   
46.         return false;   
47.     }   
48.   
49.     /**  
50.      * 上传文件至远程计算机  
51.      * @method upload  
52.      * @param ip 远程计算机IP  
53.      * @param user ftp用户  
54.      * @param password ftp用户的密码  
55.      * @param path 需上传文件的路径  
56.      * @param newPath 远程ftp上传目录  
57.      */  
58.     public static void upload(String ip, String user, String password,   
59.             String path, String newPath) {   
60.            
61.         File file = new File(path);   
62.            
63.         if (!file.exists()){   
64.             log.info("文件不存在！");   
65.             return;   
66.         }   
67.            
68.         log.info("上传文件全路径："+file.getAbsolutePath());   
69.            
70.         //建立FTP连接   
71.         boolean conn=connection(ip,user,password,newPath);   
72.            
73.         if(false==conn){   
74.             log.info("建立FTP连接失败！");   
75.             return;   
76.         }   
77.            
78.         System.getProperties().put("file.encoding", "UTF-8");   
79.         TelnetOutputStream os = null;   
80.         FileInputStream is = null;   
81.            
82.         try {   
83.                
84.             is = new FileInputStream(file);   
85.             File newfile=new File(newPath);   
86.             if(newfile.exists()){   
87.                 newfile.mkdirs();   
88.                 newfile.createNewFile();   
89.             }   
90.                
91.                
92.             os = ftpClient.put(newPath+file.getName());   
93.             byte[] b = new byte[1024];   
94.             int c;   
95.             log.info("开始上传文件...");   
96.             while (-1 != (c=is.read(b))) {   
97.                 os.write(b, 0, c);   
98.             }   
99.             os.flush();   
100.             os.close();   
101.             is.close();   
102.                
103.             log.info("文件上传完毕！");   
104.                
105.             if (null != ftpClient)   
106.                 ftpClient.closeServer();   
107.                
108.         } catch (IOException e) {   
109.             System.err.println("上传文件异常！");   
110.             e.printStackTrace();   
111.         }   
112.   
113.     }   
114.   
115.     public static void main(String[] args) {   
116.         upload("192.168.23.1", "songjy", "123456","E:\\Workspaces\\java\\srt\\ezg\\demo-web\\pom.xml", "/songjy/upload/");   
117.     }   
118.   
119. }  

package cn.com.songjy;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;

import org.apache.log4j.Logger;

import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;

public class FTPUPload {

	private static Logger log = Logger.getLogger(FTPUPload.class);
	static FtpClient ftpClient = null;

	/**
	 * 建立FTP连接
	 * @method connection
	 * @param ip 远程计算机IP
	 * @param user ftp用户
	 * @param password ftp用户的密码
	 * @param newpath 远程计算机目录
	 * @return
	 */
	public static boolean connection(String ip, String user, String password,
			String newpath) {
		
		log.info("远程IP地址："+ip);
		log.info("FTP账户："+user);
		log.info("FTP账户密码："+password);
		log.info("远程目录："+newpath);
		
		ftpClient = new FtpClient();
		try {
			ftpClient.openServer(ip);
			ftpClient.login(user, password);
			if (newpath.length() > 0) {
				ftpClient.cd(newpath);
			}
			ftpClient.binary();
			return true;
		} catch (IOException e) {
			e.printStackTrace();
		}
		return false;
	}

	/**
	 * 上传文件至远程计算机
	 * @method upload
	 * @param ip 远程计算机IP
	 * @param user ftp用户
	 * @param password ftp用户的密码
	 * @param path 需上传文件的路径
	 * @param newPath 远程ftp上传目录
	 */
	public static void upload(String ip, String user, String password,
			String path, String newPath) {
		
		File file = new File(path);
		
		if (!file.exists()){
			log.info("文件不存在！");
			return;
		}
		
		log.info("上传文件全路径："+file.getAbsolutePath());
		
		//建立FTP连接
		boolean conn=connection(ip,user,password,newPath);
		
		if(false==conn){
			log.info("建立FTP连接失败！");
			return;
		}
		
		System.getProperties().put("file.encoding", "UTF-8");
		TelnetOutputStream os = null;
		FileInputStream is = null;
		
		try {
			
			is = new FileInputStream(file);
			File newfile=new File(newPath);
			if(newfile.exists()){
				newfile.mkdirs();
				newfile.createNewFile();
			}
			
			
			os = ftpClient.put(newPath+file.getName());
			byte[] b = new byte[1024];
			int c;
			log.info("开始上传文件...");
			while (-1 != (c=is.read(b))) {
				os.write(b, 0, c);
			}
			os.flush();
			os.close();
			is.close();
			
			log.info("文件上传完毕！");
			
			if (null != ftpClient)
				ftpClient.closeServer();
			
		} catch (IOException e) {
			System.err.println("上传文件异常！");
			e.printStackTrace();
		}

	}

	public static void main(String[] args) {
		upload("192.168.23.1", "songjy", "123456","E:\\Workspaces\\java\\srt\\ezg\\demo-web\\pom.xml", "/songjy/upload/");
	}

}