关于文件传输_JAVA_编程开发_程序员俱乐部

最近项目经常使用到文件传输ftp、url访问等方式，查阅了些资料做了些整理和添加并不完善，希望能对大家有所帮助。
1.ftp文件传输源码：
1.1采用Runtime.getRuntime().exec()执行操作系统的ftp命令
1.1.1 ftp上传脚本
Windows脚本：
open 目标IP
用户名
密码（没有密码则不用写）
cd 目标路径
asc
prompt
put 本地文件（完整路径）
bye

Unix脚本：
ftp -n -i 目标IP <<!EOF
user 用户名 密码
cd 目标路径
lcd 本地文件路径
asc
prompt
put 本地文件
bye
!EOF
　　
这里传送的是文本文件，所以采用asc模式传输。然后Java Runtime执行命令 [Runtime.getRuntime().exec(cmd)] 如下：

1.1.2cmd指令
Windows命令：
ftp -s:脚本文件（完整路径）

Unix命令：
sh 脚本文件（完整路径）

1.1.3代码示例：（注意命令不要有空格）

a.脚本示例：C:/Users/gkq/Desktop/ftp.txt
open 127.0.0.1
gkq
cd gkq
asc
prompt
put C:/Users/gkq/Desktop/test1.txt
bye
b.代码：
public class RuntimeTest {
public static void main(String[] args) throws IOException{
@SuppressWarnings("unused")
java.lang.Process process = java.lang.Runtime.getRuntime().exec("ftp -s:C:/Users/gkq/Desktop/ftp.txt ");
}
}
注：貌似采用这种方式中文路径问题是无法上传的
1.2实现本地文件传输到ftp服务器指定目录（中文路径支持），需要使用apache common.net jar包
代码示例：
public class FtpClient{
private String userName;
private String pwd;
private String url;
private int port;
private FTPClient ftpClient;
public FtpClient(String url, int port, String username, String password) throws Exception {
this.url = new String(url);
this.port = port;
this.userName = new String(username);
this.pwd = new String(password);
ftpClient=new FTPClient();
}
private void connect() throws SocketException, IOException{
ftpClient.connect(url, port);//连接FTP服务器
FTPClientConfig config = new FTPClientConfig(FTPClientConfig.SYST_UNIX);  
config.setServerLanguageCode("zh");  
config.setServerTimeZoneId("XXXX");
ftpClient.configure(config);
//设置默认超时
ftpClient.setDefaultTimeout(30000);
//设置数据超时
ftpClient.setDataTimeout(30000);
//socket超时
ftpClient.setSoTimeout(30000);
ftpClient.setBufferSize(524288);
//传输模式和类型
ftpClient.setFileTransferMode(FTP.BINARY_FILE_TYPE);  
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
ftpClient.setControlEncoding("GBK");
}
private void disconnect() throws IOException{
if (ftpClient.isConnected()) {
try {
ftpClient.disconnect();
} catch (IOException ioe) {
System.out.println("断开连接出错");
ioe.printStackTrace();
throw ioe;
}
}
}
private void login() throws Exception{
int reply;
try{
if(!ftpClient.login(userName, pwd)){
System.out.println("登入失败，用户名密码不匹配");
throw new Exception("登入失败，用户名密码不匹配");
}else{
//服务器是否响应
reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftpClient.disconnect();
throw new Exception("服务器无响应，登入失败");
}
}
}catch(Exception e){
e.printStackTrace();
throw e;
}
}
private void logout() throws Exception{
try{
if(!ftpClient.logout()){
System.out.println("退出失败");
throw new Exception("退出失败");
}
}catch(Exception e){
e.printStackTrace();
throw e;
}
}
public boolean uploadFile(String pathInPlatform, String filenameInPlatform, String fileInLocal) throws Exception{
try{
//连接ftp
this.connect();
//登入
this.login();
//转到指定目录，中文路径的处理
if(!ftpClient.changeWorkingDirectory(new String(pathInPlatform.getBytes("GBK"), "iso-8859-1"))){
System.out.println("访问目录不存在");
throw new Exception("访问目录不存在");
}else{
//上传文件
FileInputStream input=new FileInputStream(new File(fileInLocal));
ftpClient.storeFile(new String(filenameInPlatform.getBytes("GBK"), "iso-8859-1"),input);
input.close();
}
this.logout();
this.disconnect();
return true;
}catch(Exception e){
e.printStackTrace();
this.disconnect();
throw e;
}
}
}

2..web文件传输
通过url下载文件转为2进制流
public static synchronized byte[] getDataFromPlatform(URL url) throws Exception{
InputStream is=null;
HttpURLConnection httpConn;
int responseCode;
try{
    httpConn=(HttpURLConnection) url.openConnection();
responseCode=httpConn.getResponseCode();
if(responseCode==HttpURLConnection.HTTP_OK){
is=httpConn.getInputStream();
if (is != null) {  
ByteArrayOutputStream baos = new ByteArrayOutputStream();  
byte[] buf = new byte[1024];  
int ch = -1;  
int count = 0;  
while ((ch = is.read(buf)) != -1) {//读取1024字节数据,存储到buf中  ，是否读完
baos.write(buf, 0, ch);//从0开始ch长度的byte写入outstream
count += ch;//总数   
}
is.close();
baos.close();
return  baos.toByteArray();//--->存到数据库中
}
else{
    throw new Exception("Error,input Stream is null");
}
    }else{
    throw new Exception("Connect error,can not get any data");
    }
    }catch(Exception e){
    e.printStackTrace();
    throw e;
    }finally{
    httpConn.disconnect();
    }
}

3.Socket传输
待整理….