上傳下載的代碼
成都創(chuàng)新互聯(lián)公司專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于成都網(wǎng)站設(shè)計、成都網(wǎng)站制作、盤龍網(wǎng)絡(luò)推廣、重慶小程序開發(fā)、盤龍網(wǎng)絡(luò)營銷、盤龍企業(yè)策劃、盤龍品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務(wù)，您的肯定，是我們最大的嘉獎；成都創(chuàng)新互聯(lián)公司為所有大學(xué)生創(chuàng)業(yè)者提供盤龍建站搭建服務(wù)，24小時服務(wù)熱線：18982081108，官方網(wǎng)址：www.cdcxhl.com
import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import sun.net.TelnetOutputStream;
import sun.net.TelnetInputStream;
import sun.net.;
public class download {
String localfilename;
String remotefilename;
FtpClient ftpClient;
// server：服務(wù)器名字
// user：用戶名
// password：密碼
// path：服務(wù)器上的路徑
public void connectServer(String ip, int port,String user
, String password,String path) {
try {
ftpClient = new FtpClient();
ftpClient.openServer(ip,port);
ftpClient.login(user, password);
System.out.println("login success!");
if (path.length() != 0) ftpClient.cd(path);
ftpClient.binary();
} catch (IOException ex) {
System.out.println("not login");
System.out.println(ex);
}
}
public void closeConnect() {
try {
ftpClient.closeServer();
System.out.println("disconnect success");
} catch (IOException ex) {
System.out.println("not disconnect");
System.out.println(ex);
}
}
public void upload() {
this.localfilename = "D://test2//test.txt";
this.remotefilename = "test.txt";
try {
TelnetOutputStream os = ftpClient.put(this.remotefilename);
java.io.File file_in = new java.io.File(this.localfilename);
FileInputStream is = new FileInputStream(file_in);
byte[] bytes = new byte[1024];
int c;
while ((c = is.read(bytes)) != -1) {
os.write(bytes, 0, c);
}
System.out.println("upload success");
is.close();
os.close();
} catch (IOException ex) {
System.out.println("not upload");
System.out.println(ex);
}
}
public void download() {
try {
TelnetInputStream is = ftpClient.get(this.remotefilename);
java.io.File file_in = new java.io.File(this.localfilename);
FileOutputStream os = new FileOutputStream(file_in);
byte[] bytes = new byte[1024];
int c;
while ((c = is.read(bytes)) != -1) {
// System.out.println((char)is.read());
// System.out.println(file_in);
os.write(bytes, 0, c);
}
System.out.println("download success");
os.close();
is.close();
} catch (IOException ex) {
System.out.println("not download");
System.out.println(ex);
}
}
public void download(String remotePath,String remoteFile,String localFile) {
try {
if (remotePath.length() != 0) ftpClient.cd(remotePath);
TelnetInputStream is = ftpClient.get(remoteFile);
java.io.File file_in = new java.io.File(localFile);
FileOutputStream os = new FileOutputStream(file_in);
byte[] bytes = new byte[1024];
int c;
while ((c = is.read(bytes)) != -1) {
// System.out.println((char)is.read());
// System.out.println(file_in);
os.write(bytes, 0, c);
}
System.out.println("download success");
os.close();
is.close();
} catch (IOException ex) {
System.out.println("not download");
System.out.println(ex);
}
}
public void download(String remoteFile,String localFile) {
try {
TelnetInputStream is = ftpClient.get(remoteFile);
java.io.File file_in = new java.io.File(localFile);
FileOutputStream os = new FileOutputStream(file_in);
byte[] bytes = new byte[1024];
int c;
while ((c = is.read(bytes)) != -1) {
// System.out.println((char)is.read());
// System.out.println(file_in);
os.write(bytes, 0, c);
}
System.out.println("download success");
os.close();
is.close();
} catch (IOException ex) {
System.out.println("not download");
System.out.println(ex);
}
}
public static void main(String agrs[]) {
String filepath[] = { "/callcenter/index.jsp", "/callcenter/ip.txt",
"/callcenter/mainframe/image/processing_bar_2.gif",
"/callcenter/mainframe/image/logo_01.jpg" };
String localfilepath[] = { "C:\\FTP_Test\\index.jsp",
"C:\\FTP_Test\\ip.txt", "C:\\FTP_Test\\processing_bar_2.gif",
"C:\\FTP_Test\\logo_01.jpg" };
download fu = new download();
fu.connectServer("172.16.1.66",22, "web_test", "123456","/callcenter");
for(int i=0;ifilepath.length;i++){
fu.download(filepath[i],localfilepath[i]);
}
//fu.upload();
//fu.download();
fu.closeConnect();
}
}
package?com.quantongfu.;
import?java.io.File;
import?java.io.FileInputStream;
import?java.io.IOException;
import?java.net.ServerSocket;
import?java.util.List;
import?org.apache.commons.net.;
import?org.apache.log4j.Logger;
import?org.apache.log4j.net.SocketServer;
import?com.quantongfu.conf.FtpConf;
/**
*?@項目名稱:?telinSyslog
*?@文件名稱:?
*?@創(chuàng)建日期：2015年9月14日?下午3:22:08
*?@功能描述：ftp實體類，用于連接，上傳
*?@修訂記錄：
*/
public?class?Ftp?{
private?static?Logger?logger?=?Logger.getLogger();
private?FTPClient?ftp;
/**
*?
*?@param?path
*????????????上傳到ftp服務(wù)器哪個路徑下
*?@param?addr
*????????????地址
*?@param?port
*????????????端口號
*?@param?username
*????????????用戶名
*?@param?password
*????????????密碼
*?@return
*?@throws?Exception
*/
public?boolean?connect()?throws?Exception?{
boolean?result?=?false;
ftp?=?new?FTPClient();
int?reply;
(FtpConf.FTP_HOST,?FtpConf.FTP_PORT);
(FtpConf.FTP_USER_NAME,?FtpConf.FTP_PASSWORD);
;
;
reply?=?;
if?(!FTPReply.isPositiveCompletion(reply))?{
;
return?result;
}
if?(FtpConf.IS_FTP_DIRECTORY)?{
;
}
result?=?true;
return?result;
}
/**
*?
*?@param?files
*????????????上傳的文件
*?@throws?Exception
*/
public?boolean?upload(File?file)?throws?IOException?{
FileInputStream?input?=?null;
try?{
input?=?new?FileInputStream(file);
boolean?b?=?(file.getName()?+?".tmp",?input);
if?(b)?{
b?=?(file.getName()?+?".tmp",?file.getName());
}
return?b;
}?catch?(Exception?e)?{
e.printStackTrace();
return?false;
}?finally?{
if?(input?!=?null)?{
input.close();
}
}
}
/**
*?
*?@param?files
*????????????上傳的文件
*?@throws?Exception
*/
public?boolean?upload(ServerSocket?server,?File?file)?throws?Exception?{
FileInputStream?input?=?null;
try?{
if?(!file.exists())?{
return?true;
}
input?=?new?FileInputStream(file);
boolean?b?=?(server,?file.getName()?+?".tmp",?input);
if?(b)?{
b?=?(file.getName()?+?".tmp",?file.getName());
if?(b)?{
file.delete();
}
}
return?b;
}?catch?(Exception?e)?{
logger.error("ftp?error"?+?e.getMessage());
return?false;
}?finally?{
if?(input?!=?null)?{
try?{
input.close();
}?catch?(IOException?e)?{
e.printStackTrace();
}
}
}
}
/*斷開連接*/
public?void?disConnect()?{
try?{
if?(ftp?!=?null)?{
;
}
}?catch?(IOException?e)?{
e.printStackTrace();
}
}
/*獲取連接*/
public?static?Ftp?getFtp()?{
Ftp?ftp?=?new?Ftp();
try?{
;
}?catch?(Exception?e)?{
logger.error("FTP連接異常"?+?e.getMessage());
e.printStackTrace();
}
return?ftp;
}
/*重連*/
public?Ftp?reconnect()?{
disConnect();
return?getFtp();
}
}
使用Apache FtpClient jar包，獲取jar :
import java.io.File;
import java.io.FileInputStream;
import org.apache.commons.net.;
import org.apache.commons.net.;
public class test {
private FTPClient ftp;
/**
*
* @param path 上傳到ftp服務(wù)器哪個路徑下
* @param addr 地址
* @param port 端口號
* @param username 用戶名
* @param password 密碼
* @return
* @throws Exception
*/
private boolean connect(String path,String addr,int port,String username,String password) throws Exception {
boolean result = false;
ftp = new FTPClient();
int reply;
;
;
;
reply = ;
if (!FTPReply.isPositiveCompletion(reply)) {
;
return result;
}
;
result = true;
return result;
}
/**
*
* @param file 上傳的文件或文件夾
* @throws Exception
*/
private void upload(File file) throws Exception{
if(file.isDirectory()){
(file.getName());
(file.getName());
String[] files = file.list();
for (int i = 0; i files.length; i++) {
File file1 = new File(file.getPath()+"\\"+files[i] );
if(file1.isDirectory()){
upload(file1);
;
}else{
File file2 = new File(file.getPath()+"\\"+files[i]);
準(zhǔn)備條件：java實現(xiàn)ftp上傳用到了commons-net-3.3.jar包
首先建立ftphost連接
public?boolean?connect(String?path,?String?addr,?int?port,?String?username,?String?password)?{
try?{
//FTPClient?ftp?=?new?FTPHTTPClient(addr,?port,?username,?password);
ftp?=?new?FTPClient();
int?reply;
;
System.out.println("連接到："?+?addr?+?":"?+?port);
System.out.print();
reply?=?;
if?(!FTPReply.isPositiveCompletion(reply))?{
;
System.err.println("FTP目標(biāo)服務(wù)器積極拒絕.");
System.exit(1);
return?false;
}else{
(username,?password);
;
;
;
System.out.println("已連接："?+?addr?+?":"?+?port);
return?true;
}
}?catch?(Exception?ex)?{
ex.printStackTrace();
System.out.println(ex.getMessage());
return?false;
}
}
然后再利用ftpclient的makeDirectory方法創(chuàng)建文件夾
public?void?createDir(String?dirname){
try{
;
System.out.println("在目標(biāo)服務(wù)器上成功建立了文件夾:?"?+?dirname);
}catch(Exception?ex){
System.out.println(ex.getMessage());
}
}
斷開host連接
public?void?disconnect(){
try?{
;
}?catch?(IOException?e)?{
e.printStackTrace();
}
}
最后是程序的調(diào)用方法
public?static?void?main(String[]?args)?{
FtpUploadTest?ftpupload?=?new?FtpUploadTest();
if(ftpupload.connect("",?"172.39.8.x",?20,?"administrator",?"abc@123")){
ftpupload.createDir("/UPLOAD");
ftpupload.disconnect();
}
}
重慶分公司
重慶分公司
