Método de implementação Java para fazer upload de arquivos para o servidor FTP

Este artigo descreve o método de fazer upload de arquivos para um servidor FTP por Java. Compartilhe -o para sua referência, como segue:

Ferramentas:

 pacote com.fz.common.util; importar java.io.datainputStream; importar java.io.dataoutputStream; importar java.io.fileInputStream; import java.io.filenotfoundException; importar java.io.fileOutstream; importStrio.Il.io.IOXEXCECCEIRA; java.text.simpledEformat; importar java.util.date; importar org.apache.commons.net.ftp.ftpclient; importar org.apache.commons.net.ftp.ftPreply; public class FileUtil {** ** * * @Date Sep 26, 2011 10:17 DatainputStream getInput () {DatainputStream d = null; tente {d = new DatainputStream (new FileInputStream ("c: /wmc.dat")); retornar d; } catch (fileNotfoundException e) {// TODO BLOCO DE CATAGEM AUTOMENTADO E.PRINTSTACKTRACE (); } retornar d; } / ** * * @Date 26 de setembro de 2011 10:17:44 * @param whites * @return * @author zhangh * / public static boolean CreateWhitemanageFile (byte [] brancos, arquivo string) {dataOutputStream d; tente {d = new DataOutputStream (new FileOutputStream (arquivo)); D.Write (brancos); d.flush (); } Catch (Exceção e) {// TODO BLOCO DE CATO GONERATO AUTOMADO RETORNO FALSO; // E.PrintStackTrace (); } retornar true; } /** * * @date Sep 16, 2011 4:39:22 PM * @param url * @param username * @param password * @param path * @param filename * @param input * @return * @author zhangh */ public static boolean uploadFile(String url, String username, String password, String path, String filename, InputStream input) { boolean success = falso; FtpClient ftp = new ftpClient (); tente {int Responder; ftp.connect (url); // ftp.connect (url, porta); // conectar -se ao servidor FTP // se a porta padrão for usada, você poderá conectar -se diretamente ao servidor FTP usando ftp.connect (url); ftp.login (nome de usuário, senha); // Login Responder = ftp.getReplyCode (); if (! ftPreply.ispositiveCeliction (Responder)) {ftp.disconnect (); sucesso de sucesso; } ftp.ChangeWorkingDirectory (caminho); ftp.storefile (nome do arquivo, entrada); ftp.logout (); input.Close (); sucesso = true; } catch (ioexception e) {e.printStackTrace (); } finalmente {if (ftp.isconnected ()) {try {ftp.disconnect (); } catch (ioexception ioo) {}} retorna sucesso; } / ** * * Nome do método: UPLOPFILEFTP * Método Descrição: BlackList, Black User File Upload FTP Server * @param url * @param nome de usuário * @param senha * @param caminho * @param filename * @param input * @param input2 * return * boolean * versão 1.0 * autor * autor UPLOPLEFILEFTP (URL da String, Nome de usuário da String, String Senha, String Path, String FileName, InputStream Input, InputStream Input2) {Date Date = new Date (); SimpledateFormat Formatter = new SimpleDateFormat ("AA YYYY-MM-DD HH: MM: SS"); String time = formatter.format (data); sucesso booleano = false; FtpClient ftp = new ftpClient (); tente {int Responder; ftp.connect (url); ftp.login (nome de usuário, senha); // Login Responder = ftp.getReplyCode (); if (! ftPreply.ispositiveCeliction (Responder)) {ftp.disconnect (); sucesso de sucesso; } ftp.ChangeWorkingDirectory (caminho); ftp.storefile (nome do arquivo, entrada); ftp.storefile (nome do arquivo + tempo, input2); ftp.logout (); input.Close (); sucesso = true; } catch (ioexception e) {e.printStackTrace (); } finalmente {if (ftp.isconnected ()) {try {ftp.disconnect (); } catch (ioexception ioe) {}}} retornar sucesso; }}

Leia o arquivo de configuração:

 pacote com.fz.fzbike.Domain; importar java.io.bufferInputStream; importar java.io.fileInputStream; importar java.io.ioException; importar java.io.inpStream; import java.util.properties; import org.apache.Log4J.GroGgers; Classe de feijão que obtém informações do servidor FTP * * @Author Wuxq * */public classe syconstats {private static logger log = logger.getLogger (syconstats.class); public static string ftpServer; // Endereço IP do servidor FTP public static string ftpuserName; // servidor ftp nome de usuário public static string ftppassword; // ftp servidor senha public static string enveloveResulTroot; // o caminho para armazenar o servidor ftp public sysconStats () (try {{Try Syconstants.public_path.substring (0, sysconstants.public_path.length () - 7) + "/bidFileConfig.properties")); Propriedades prop = new Properties (); Prop.Load (in); Syconstats.ftpServer = prop.getProperty ("ftpSserver", "nenhum"); Syconstats.ftpusername = prop.getProperty ("ftpuserName", "nenhum"); Syconstats.ftppassword = prop.getProperty ("ftppassword", "nenhum"); Syconstats.enveloveresulTroot = prop.getProperty ("enveloperesultroot", "nenhum"); log.debug ("Leia as informações de configuração do FTP com sucesso!"); } catch (ioexception e) {log.debug ("Falha ao ler informações de configuração do FTP!"); E.PrintStackTrace (); }} public static string getftpServer () {return ftpServer; } public static void SetftpServer (String ftpServer) {ftpServer = ftpServer; } public static string getftpuserName () {return ftpuserName; } public static void setftpUserName (string ftpuserName) {ftpuserName = ftpuserName; } public static string getftpPassword () {return ftppassword; } public static void SetftpPassword (string ftppassword) {ftppassword = ftppassword; } public static string getenveloveResulTroot () {return envelopreesultroot; } public static void setenvelopherresulTroot (string enveloveresulTroot) {enveloveresulTroot = enveloveresulTroot; } public static void main (string args []) {new SySconstats (); }}

Carregue o arquivo ftp:

 pacote com.fz.fzbike.biz; importar java.io.bufferedInputStream; importar java.io.byteArrayoutputStream; importar java.io.dataoutputStream; import java.io.fileInputStream; import java.io.filenotFoundException; java.Text.DecimalFormat; import com.enets.basesys.user.vo.uservo; import com.enets.framework.assemble.requesthashnew; import com.enets.framework.database.dbconnection; import.fz.common.util.fileUtil; com.fz.fzbike.Domain.SySCONSTATS;/** * Carregue o código do cartão para o servidor FTP para gerar um arquivo de bat de morcego * * @author wuxq 2011-09-28 */public classe uPLOPARCARDINNOFTPACTION {/** * Nome do método: uploadftp Descrição: upload o arquivo para ftpp * 10:38:38 AM */ public void uploadftp (requestHashnew reh) {string cardtype = reh.get ("cardtype"). Tostring (); DbConnection dbc = reh.getdbc (); // link banco de dados dbc.endtran (); // determine se está vazio e pode ser uma perda de relatório, sair da perda de relatório, sair da lista negra e obtenha o tipo de cartão com base no ID do cartão se (stringutil.isnull (cardtype)) {string cardtypesql = "selecione CI.CARD_TYPE de lc_t_card_info ci where ci.car CardType = dbc.getList0 (CardTypeSQL); } String top = "c:/upload/"; Arquivo string = top + "bmc.dat"; // Defina um diretório para armazenar o arquivo de bat de morcego da lista negra temporária string whitefile = top + "wmc.dat"; // Defina um diretório para armazenar o arquivo de bat de morcego temporário de Bat String Buerfile = top + "Buser.dat"; // Defina um diretório para armazenar o arquivo de usuário preto temporário string fileid = dbc.SetoracleGlideValue ("LC_T_UPGRADER_FILE"); // Obtenha o número de série da tabela de arquivos // Obtenha o ID do usuário atual uservo = reh.getUservo (); String userID = uservo.getUserId (); Decimalformat df = novo decimalformat ("0,0"); if (CardType.equals ("7")) {StringBuffer bf = new StringBuffer (1024); BF .Append ("Selecione Distinct Card_in_no de (selecione TC.CARD_IN_NO") .APPEND ("de LC_T_BLACKLIST TB LONG LC_T_CARD_INFO TC") .APPEND ("ON TB.CARD_ID = TC. Selecione ") .Append (" tc.card_in_no de lc_t_card_loss Cl junção esquerda ") .append (" lc_t_card_info tc em cl.card_id = tc.card_id onde tc.card_type = 7 e "them. na lista negra e na tabela de registro de relatório StringBuffer Brush = new StringBuffer (1024); Bfffer .Append ("Selecione ti.card_in_no de lc_t_card_info ti") .append ("onde ti.card_type = 7 e ti.card_make_status = 2 pedidos por ti.card_in_in_in); // todos os administradores na tabela de informações // arr [] [] = dbc.Gegarr (bf.toString ()); // Defina uma matriz para receber os códigos de cartão classificados na tabela de informações do cartão string ouvicer [] [] = dbc.Getarr (bffer.toString ()); upload_f (arr, arquivo); // Obtenha o número da versão do arquivo Blacklist BAT, o valor inicial é 1.0 String Vectorsql = "Selecione File_vesion de (selecione Row_Number () sobre (Ordem por t.file_vesion desc) num," + "t.file_vesion de LC_T_UPGRADE_FILE T WHERE T.FILE_TYPE = 2) String vesion = dbc.getList0 (vesionsql); duplo ve = 1,0; // define a variável número da versão da lista negra, o valor inicial é 1,0/ * * se houver uma versão antiga no banco de dados, a versão será aumentada em 0,1 */ se (stringutil.isnotnull (vesion)) {ve = (duplo.parsedouble (vesion) + 0.1); } vesion = df.format (ve); // Versão registra a instrução sql string bmcsql = "inserir em lc_t_upgrade_file valores (" + fileid + ", '" + file + "', '" + vesion + "', '2', sysdate," + userID + "); dbc.insertdb (bmcsql); // persiste no banco de dados upload_f (listarr, whitefile); // Obtenha o número da versão do arquivo de morcego de Whitelisted, o valor inicial é 1.0 string vesionsql2 = "Selecione file_vesion de (selecione row_number () sobre (ordem por t.file_vesion desc) num," + "t.file_vesion de LC_T_UPGRADE_FILE t Where t.File_type = 5) onde 1" String vesion2 = dbc.getList0 (vesionsql2); VE2 duplo = 1.0; // Defina a variável do número da versão da lista de permissões, o valor inicial é 1,0/ * * se houver uma versão antiga no banco de dados, a versão será aumentada em 0,1 */ if (stringutil.isnotNull (vesion2)) {ve2 = (duplo.parsEdouble (vesion2) + 0.1); } String bfileId = dbc.SetoracleGlideValue ("LC_T_UPGRADE_FILE"); // Obtenha o número de série da tabela de arquivos vesion2 = df.format (VE2); // Versão registra a instrução sql string bmcsql2 = "inserir em lc_t_upgrade_file valores (" + bfileId + ", '" + whitefile + "', '" + vesion2 + "', '5', sysdate," + userID + ")"; dbc.insertdb (bmcsql2); // persiste no banco de dados} else {stringBuffer bf2 = new StringBuffer (1024); BF2 .Append ("Selecione Distinct Card_in_no de (selecione TC.CARD_IN_NO") .APPEND ("de LC_T_BLACKLIST TB LONG LC_T_CARD_INFO TC") .ApnPend ("On Tb.Card_id = Tc.Card_Id Where tc.card_typEnd (" On Tb.Card_id = Tc.Card_Id "). união todos selecionados ") .Append (" tc.card_in_no de lc_t_card_loss Cl junção esquerda ") .append (" lc_t_card_info tc em cl.card_id = tc.card_id ") .append (" where tc.card_type <> 7 e cl.wheth_hether "). t.card_in_no "); // Todos os registros não administradores na tabela Blacklist e relataram a tabela de usuários perdidos // Defina uma matriz para receber os códigos de cartão de usuário classificados em usuários pretos string ARR2 [] [] = dbc.GetArr (bf2.tostring ()); upload_f (ARR2, BUSERFILE); // Obtenha o número da versão do arquivo de morcego do usuário preto, o valor inicial é 1.0 string hsersql = "Selecione file_vesion de (selecione row_number () sobre (encomendar por t.file_vesion desc) num," + "t.file_vesion de lc_t_upgrade_file t where t.file_type = 4) String vesion3 = dbc.getList0 (husersql); duplo ves = 1,0; // define a variável do número da versão do usuário preto, o valor inicial é 1,0/ * * se houver uma versão antiga no banco de dados, a versão será aumentada em 0,1 */ se (stringutil.isnotNull (vesion3)) {ves = (duplo.parsEdouble (vesion3) + 0.1); } vesion3 = df.format (ves); // versão registra a instrução sql string husersql = "inserir em lc_t_upgrade_file valores (" + fileid + ", '" + Buerfile + "', '" + vesion3 + "', '4', sysdate," + userID + "); dbc.insertdb (husersql); // persiste no banco de dados}}/ ** * * Nome do método: Método WriteLong Descrição: Escreva o número inteiro longo no fluxo de saída * * @param input * @return byte [] versão 1.0 Autor Wuxq Sep 28, 2011ONGONG 10:54:58 AM */ public byte byTe [] [] versão 1.0 WUXQ SEP 28, 2011ONGONG 10:54:58 AM */ public byte byte [] = novo byteArrayOutputStream (); DataOutputStream OS = new DataOutputStream (BAOS); tente {OS.Writelong (Long.ReverseBytes (entrada)); } catch (ioexception e) {// TODO GATO GENERADO AUTOMENTADO BLOCO E.PRINTSTACKTRACE (); } byte [] b = baos.tobytearray (); retornar b; } / ** * * Nome do método: upload_f Método Descrição: Faça o upload do arquivo no servidor FTP * * @param arr * @param arquivo * void versão 1.0 Autor Wuxq 8 de outubro de 2011 11:37:27 am * / public static void upload_f (string [] [] [] arr, arquivo string) {byte por [] = null; byte [] resultado = novo byte [1]; if (stringutil.isnotNull (arr)) {resultado = novo byte [arr.length * 4]; int position = 0; for (int i = 0; i <arr.length; i ++) {por = writelong (long.parselong (arr [i] [0])); Lista de bytes [] = novo byte [4]; for (int h = 0; h <list.length; h ++) {list [h] = por [h]; } para (int g = position; g <position+4; g ++) {resultado [g] = list [g - 4 * i]; } posição = posição + 4; }} boolean bool = fileutil.creatwhitemanagefile (resultado, arquivo); // Crie um arquivo de bat if (bool) {// inputStreamReader isr = new inputStreamReader (new // fileInputStream (file)); InputStream inp = null; InputStream inp2 = null; tente {inp = new bufferInputStream (new FileInputStream (arquivo)); inp2 = new bufferInputStream (new FileInputStream (arquivo)); } catch (fileNotfoundException e) {// TODO BLOCO DE CATAGEM AUTOMENTADO E.PRINTSTACKTRACE (); } // interceptar o nome do arquivo string f = file.substring (10, file.length ()); // Obtenha informações de configuração FTP sySconstats sc = new SySconstats (); Fileutil.uploadfileftp (sc.ftpServer, sc.ftpuserName, sc.ftppassword, sc.enveloveresultroot, f, inp, inp2); }}}

Para obter mais informações sobre o conteúdo relacionado a Java, consulte os tópicos deste site: "Resumo dos arquivos Java e habilidades de operação de diretório", "Tutorial sobre estruturas e algoritmos de dados Java", "Resumo da operação Java Dom Node Operation Skills" e "Resumo de Java Cache Operation Skills"

Espero que este artigo seja útil para a programação Java de todos.