java读取ftp中TXT文件的案例

java读取ftp中TXT文件的案例

最近在开发关于java读取ftp中TXT文件，其中有些坑踩了一下，再次做个记录

1、读取文件时我会根据文件名称去生成数据库表，oracle数据库对于表名的长度是有限制的，最多30个字符

2、对于多个文件的ftp的读取，每次获取文件后再次回去文件的流会为空，即在循环中多次根据ftp获取文件的流

当出现这种情况时，需要在循环时每次开启和关闭ftp的链接即可解决，否则在第二次获取的时候inputsteam为null

3、读取txt文件时，如果文件中包含中文，进行读取时可能会出现乱码，这是可设置读取的字符集为UTF-8，如果不行，再试试

GB2312

4、java读取TXT文件：

InputStreamReader reader = new InputStreamReader(is, "GB2312");

BufferedReader br = new BufferedReader(reader);

String lineTxt = null; //每行数据

int rowNum = 0;

while ((lineTxt = br.readLine()) != null) {}

补充知识：Java实现从FTP获取文件下载到本地，并读取文件中的内容的成功方法

我就废话不多说了，大家还是直接看代码吧~

package com.aof.web.servlet;

import java.io.BufferedReader;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStream;

import javax.jws.WebServicehttp://;

import org.apache.commons.net.ftp.FTPClient;

import org.apache.commons.net.ftp.FTPFile;

@WebService(endpointInterface="com.aof.web.servlet.QualityComplainServices")

public class QualityComplainServicesImpl implements QualityComplainServices {

//ftp对象

private FTPClient ftp;

//需要连接到的ftp端的ip

private String ip = "10.46.249.7";

//连接端口，默认21

private int port = 21;

//要连接到的ftp端的名字

private String name = "DKEDI";

//要连接到的ftp端的对应得密码

private String pwd = "P@ssw0rd";

//调用此方法，输入对应得ip，端口，要连接到的ftp端的名字，要连接到的ftp端的对应得密码。连接到ftp对象，并验证登录进入fto

public boolean ftp1() {

ftp = new FTPClient();

try {

// ftp.connect(ip, port);

if(!ftp.isConnected()){

ftp.connect(ip, port);

}

System.out.println(ftp.login(name, pwd));

// ftp.setCharset(Charset.forName("UTF-8"));

ftp.setControlEncoding("UTF-8");

return true;

} catch (IOException e) {

e.printStackTrace();

return true;

}

}

public void disconnect() throws Exception {

if (ftp.isConnected()) {

ftp.disconnect();

}

}

// 下载文件到本地

public boolean download(FTPFile file) throws Exception {

boolean result = true;

// 本地文件路径

File f = new File("E:\\crmFiles\\");

if (!f.exists()) {

f.getParentFile().mkdirs();

}

long lRemoteSize = file.getSize();

try {// 下载过的不在下载了

OutputStream out = new FileOutputStream(f);

if (f.length() >= lRemoteSize) {

System.out.println("~~~~~~~~~~~~~~~~~~~~~~~~本地已经存在,下载中止");

out.flush();

out.close();

}

boolean iss = ftp.retrieveFile(file.getName(), out);

System.out.println("~~~~~~~~~~~~~~~~~~~~~~~~下载成功\r\n");

out.close();

} catch (Exception ex) {

ex.printStackTrace();

System.out.println("~~~~~~~~~~~~~~~~~~~~~~~~下载失败\r\n");

return false;

}

return result;

}

private InputStreamReader read;

private BufferedReader reader;

private String preRead(String filepath) throws Exception {

File file = new File(filepath);

String ordertype = null;

if (file.isFile() && file.exists()) {

try {

read = new InputStreamReader(new FileInputStream(file), "GBK");

reader = new BufferedReader(read);

StringBuffer FileContent = new StringBuffer();

String temp = null;

while ((temp = reader.readLine()) != null) {

FileContent.append(temp);

}

System.out.println("订单内容为------------------>>>>> "+FileContent+" <<<<<------------------");

} catch (FileNotFoundException e) {

System.out.println("！！！！！！！！！！！！！！！！！没有找到合适的订单信息！！！！！！！！！！！！！！！");

e.printStackTrace();

} finally {

reader.close();

read.close();

// file.delete();

}

}

return ordertype;

}

public void gmRead(String remote) throws Exception {

boolean downloadResult = false;

try {

ftp.changeWorkingDirectory(remote);

System.out.println("远程路径为*************************"+remote);

FTPFile[] files = ftp.listFiles(remote); // 通过路径得到文件

System.out.println("文件数量为*************************"+files.length);

for (int i = 0; i < files.length; i++) {

FTPFile file = files[i];

if (file.isFile()) {

downloadResult = this.download(file);// http://下载文件 到本地读取路径

if (downloadResult) {

String ordertype = this.preRead("E:\\crmFiles\\");

}

/*//读取文件内容，将内容存数据库

InputStreamReader isr = new InputStreamReader(new FileInputStream(file), "utf-8");

BufferedReader br = new BufferedReader(isr);

String lineTxt = null;

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

lineTxt+=lineTxt;

}

System.out.println(lineTxt);

br.close();*/

}else{

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

}

}

} catch (Exception e) {

e.printStackTrace();

}

}

@Override

public String threeDAndEightDReports(String orderNum, String FTPUrl, String FileType) {

//抱怨单号、FTP地址、3D/8D文件类型

System.out.println("1-------------"+orderNum);

System.out.println("2-------------"+FTPUrl);

Systhttp://em.out.println("3-------------"+FileType);

if(null != orderNum && null != FTPUrl && null != FileType){

//连接FTP

boolean flag = this.ftp1();

if(flag){

try {

//获取文件、解析文件内容，进库操作

this.gmRead(FTPUrl);

// 关闭连接

this.disconnect();

} catch (Exception e) {

e.printStackTrace();

}

}else{

System.out.println("！！！！！！！！！！！！！！！！！FTP连接失败！！！！！！！！！！！！！！！！！");

}

return "success";

}else{

return "fail";

}

}

public static void main(String[] args) {

QualityComplainServicesImpl q = new QualityComplainServicesImpl();

q.threeDAndEightDReports("001","/CRMINTERFACE","3D");

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。