程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> Java完成FTP批量年夜文件上傳下載篇2

Java完成FTP批量年夜文件上傳下載篇2

編輯:關於JAVA

Java完成FTP批量年夜文件上傳下載篇2。本站提示廣大學習愛好者:(Java完成FTP批量年夜文件上傳下載篇2)文章只能為提供參考,不一定能成為您想要的結果。以下是Java完成FTP批量年夜文件上傳下載篇2正文


接著上一篇停止進修java文件上傳下載1。

5、斷點續傳 

關於熟用QQ的法式員,QQ的斷點續傳功效應當是印象很深入的。由於它很適用也很方面。是以,在我們的上傳下載進程中,很完成了斷點續傳的功效。 

其實斷點續傳的道理很簡略,就在上傳的進程中,先去辦事長進行查找,能否存在此文件,假如存在些文件,則比擬辦事器上文件的年夜小與當地文件的年夜小,假如辦事器上的文件比當地的要小,則以為此文件上傳進程中應當可以停止斷點續傳。 

在完成的進程中,RandomAccessFile類變得很有效。此類的實例支撐對隨機存取文件的讀取和寫入。隨機存取文件的行動相似存儲在文件體系中的一個年夜型字節數組。存在指向該隱含數組的光標或索引,稱為文件指針;輸出操作從文件指針開端讀取字節,並跟著對字節的讀取而前移此文件指針。假如隨機存取文件以讀取/寫入形式創立,則輸入操作也可用;輸入操作從文件指針開端寫入字節,並跟著對字節的寫入而前移此文件指針。寫入隱含數組確當前末尾以後的輸入操作招致該數組擴大。該文件指針可以經由過程 getFilePointer 辦法讀取,並經由過程 seek 辦法停止設置。 

RandomAccessFile類的skipBytes辦法測驗考試跳過輸出的 n 個字節以拋棄跳過的字節。假如從辦事器上查得待上傳文件的年夜小n,則采取skipBytes辦法可以跳過這n個字節,從而開端重新的處所開端停止斷點續傳。詳細的辦法解釋可以拜見JDK5的API解釋。 

可以在net.sf.jftp.net. DataConnection類的run辦法中,可以看出上傳下載中止點續傳的完成,代碼以下: 

public void run()
  {
    try
    {
    newLine = con.getCRLF();

      if(Settings.getFtpPasvMode())
      {
        try
        {
          sock = new Socket(host, port);
          sock.setSoTimeout(Settings.getSocketTimeout());
        }
        catch(Exception ex)
        {
          ok = false;
          debug("Can't open Socket on port " + port);
        }
      }
      else
      {
        //Log.debug("trying new server socket: "+port);
        try
        {
          ssock = new ServerSocket(port);
        }
        catch(Exception ex)
        {
          ok = false;
          Log.debug("Can't open ServerSocket on port " + port);
        }
      }
    }
    catch(Exception ex)
    {
      debug(ex.toString());
    }

    isThere = true;

    boolean ok = true;

    RandomAccessFile fOut = null;
    BufferedOutputStream bOut = null;
    RandomAccessFile fIn = null;

    try
    {
      if(!Settings.getFtpPasvMode())
      {
        int retry = 0;

        while((retry++ < 5) && (sock == null))
        {
          try
          {
            ssock.setSoTimeout(Settings.connectionTimeout);
            sock = ssock.accept();
          }
          catch(IOException e)
          {
            sock = null;
            debug("Got IOException while trying to open a socket!");

            if(retry == 5)
            {
              debug("Connection failed, tried 5 times - maybe try a higher timeout in Settings.java");
            }

        finished = true;

            throw e;
          }
          finally
          {
            ssock.close();
          }

          debug("Attempt timed out, retrying");
        }
      }

      if(ok)
      {
        byte[] buf = new byte[Settings.bufferSize];
        start = System.currentTimeMillis();

        int buflen = 0;

        //---------------download,下載----------------------
        if(type.equals(GET) || type.equals(GETDIR))
        {
          if(!justStream)
          {
            try
            {
              if(resume)
              {
                File f = new File(file);
                fOut = new RandomAccessFile(file, "rw");
                fOut.skipBytes((int) f.length());
                buflen = (int) f.length();
              }
              else
              {
                if(localfile == null)
                {
                  localfile = file;
                }

                File f2 = new File(Settings.appHomeDir);
                f2.mkdirs();

                File f = new File(localfile);

                if(f.exists())
                {
                  f.delete();
                }

                bOut = new BufferedOutputStream(new FileOutputStream(localfile),
                                Settings.bufferSize);
              }
            }
            catch(Exception ex)
            {
              debug("Can't create outputfile: " + file);
              ok = false;
              ex.printStackTrace();
            }
          }

        
        //---------------upload,上傳----------------------
        if(type.equals(PUT) || type.equals(PUTDIR))
        {
          if(in == null)
          {
            try
            {
              fIn = new RandomAccessFile(file, "r");
              
              if(resume)
              {
                fIn.skipBytes(skiplen);
              }
              
              //fIn = new BufferedInputStream(new FileInputStream(file));
            }
            catch(Exception ex)
            {
              debug("Can't open inputfile: " + " (" + ex + ")");
              ok = false;
            }
          }
          
          if(ok)
          {
            try
            {
              out = new BufferedOutputStream(sock.getOutputStream());
            }
            catch(Exception ex)
            {
              ok = false;
              debug("Can't get OutputStream");
            }
            
            if(ok)
            {
              try
              {
                int len = skiplen;
                char b;
                
                while(true)
                {
                  int read;
                  
                  if(in != null)
                  {
                    read = in.read(buf);
                  }
                  else
                  {
                    read = fIn.read(buf);
                  }
                  
                  len += read;
                  
                  //System.out.println(file + " " + type+ " " + len + " " + read);
                  if(read == -1)
                  {
                    break;
                  }
                  
                  if(newLine != null) 
                  {
                    byte[] buf2 = modifyPut(buf, read);
                    out.write(buf2, 0, buf2.length);
                  }
                  else 
                  {
                    out.write(buf, 0, read);
                  }
                  
                  con.fireProgressUpdate(file, type, len);
                  
                  if(time())
                  {
                    //  Log.debugSize(len, false, false, file);
                  }
                  
                  if(read == StreamTokenizer.TT_EOF)
                  {
                    break;
                  }
                }
                
                out.flush();
                
                //Log.debugSize(len, false, true, file);
              }
              catch(IOException ex)
              {
                ok = false;
                debug("Error: Data connection closed.");
                con.fireProgressUpdate(file, FAILED, -1);
                ex.printStackTrace();
              }
            }
          }
        }
      }
    }
    catch(IOException ex)
    {
      Log.debug("Can't connect socket to ServerSocket");
      ex.printStackTrace();
    }
    finally
    {
      try
      {
        if(out != null)
        {
          out.flush();
          out.close();
        }
      }
      catch(Exception ex)
      {
        ex.printStackTrace();
      }
      
      try
      {
        if(bOut != null)
        {
          bOut.flush();
          bOut.close();
        }
      }
      catch(Exception ex)
      {
        ex.printStackTrace();
      }
      
      try
      {
        if(fOut != null)
        {
          fOut.close();
        }
      }
      catch(Exception ex)
      {
        ex.printStackTrace();
      }
      
      try
      {
        if(in != null && !justStream)
        {
          in.close();
        }
        
        if(fIn != null)
        {
          fIn.close();
        }
      }
      catch(Exception ex)
      {
        ex.printStackTrace();
      }
    }
    
    try
    {
      sock.close();
    }
    catch(Exception ex)
    {
      debug(ex.toString());
    }
    
    if(!Settings.getFtpPasvMode())
    {
      try
      {
        ssock.close();
      }
      catch(Exception ex)
      {
        debug(ex.toString());
      }
    }
    
    finished = true;
    
    if(ok)
    {
      con.fireProgressUpdate(file, FINISHED, -1);
    }
    else
    {
      con.fireProgressUpdate(file, FAILED, -1);
    }
  }

6、FTP端口映照 

FTP的數據銜接有PASV和PORT兩種,假如你的FTP辦事器位於內網中,須要做端口映照。筆者剛開端時對FTP的網外網映照也是不怎樣懂得,是以開端走了很多的彎路,開端一向認為是本身的法式有成績,糟蹋了很多時光,願望經由過程這段,能讓年夜家在開辟的時刻少花或不花這些無謂的時光與精神。 

PCD上已經有一篇文章引見過一種直接拜訪內網的辦法,其實我們只需用端口映照對象,便可輕松完成穿透內網的目標。“端口映照器”就是一款如許的對象,更值得一提的是,它解脫了敕令行形式,供給了圖形界面的操作情況。 

為了讓列位能加倍明確,先說一下道理。假定如今有一個局域網,主機為A,局域網內除主機外,還有一台機械為B,B機械固然是經由過程主機A上彀的。別的還有一台可上彀的機械為C,與A和B其實不在一個局域網內。平日情形下,C機械只能拜訪到A主機,而沒法穿透局域網,拜訪到B。而經由過程端口映照後,當C機械拜訪主機A的指定端口時,主機A上的“端口映照器”就起感化了,它會把指定端口上的數據轉到局域網內另外一台機械的指定端口上,從而完成拜訪內網機械的目標。如許說,年夜家明確了吧。至於詳細的若何停止設置裝備擺設,筆者以為應當不是件很難的工作,再說,網上如許的圖形說明許多,請年夜家參考收集上的文章停止設置。 

固然,完成直接拜訪內網的長處是不言而喻的,其余不說,最少FTP資本是被充足應用了。不外必需提示讀者的是,直接拜訪內網能夠使內網的平安性遭到威逼。筆者信任年夜部門同伙對主機平安的主要性照樣看重的,但常常會疏忽內網機械的平安設置。一旦你完成了直接拜訪內網,那就必需像看待主機一樣看待內網機械,不然你的全部收集將能夠處於風險狀況。 

拜訪客戶端資本

Java運用法式情況的平安戰略,關於分歧的代碼所具有的分歧資本的允許,它由一個Policy對象來表達。為了讓Applet(或許運轉在 SecurityManager下的一個運用法式)可以或許履行受掩護的行動,例如讀寫文件,Applet(或 Java運用法式)必需取得那項操作的允許,平安戰略文件就是用來完成這些允許。 

Policy對象能夠有多個實體,固然任什麼時候候只能有一個起感化。以後裝置的Policy對象,在法式中可以經由過程挪用getPolicy辦法獲得,也能夠經由過程挪用setPolicy辦法轉變。Policy對象評價全部戰略,前往一個恰當的Permissions對象,具體解釋哪些代碼可以拜訪哪些資本。戰略文件可以貯存在無格局的ASCII文件或Policy類的二進制文件或數據庫中。本文僅評論辯論無格局的ASCII文件的情勢。 

在現實應用中,我們可以不須要本身手動去編寫那末龐雜的java.policy文件,特殊是在不應用數字簽名時。這時候,我們完整可以自創JRE供給給我們的現成的 C:\Program Files\Java\jre1.5.0_12\lib\security\java.policy文件,依據我們的須要做響應的修正,本文就針對不應用數字簽名情形編寫平安戰略文件。上面,是一個完全的在Windows NT/XP下應用的java.policy文件。在文件中,分離應用正文的情勢解釋了每一個“permission”記載的用處。固然,分歧的法式對資本拜訪權限的請求能夠紛歧樣,可以依據項目須要停止調劑與選擇。 

grant  { 
    //對體系和用戶目次“讀”的權限
    permission  java.util.PropertyPermission  "user.dir",  "read";  
    permission  java.util.PropertyPermission  "user.home",  "read";  
    permission  java.util.PropertyPermission  "java.home",  "read";  
    permission  java.util.PropertyPermission  "java.class.pat",  "read";  
    permission  java.util.PropertyPermission  "user.name",  "read";  
    //對線程和線程組的操作權限
    permission  java.lang.RuntimePermission  "accessClassInPackage.sun.misc";  
    permission  java.lang.RuntimePermission  "accessClassInPackage.sun.audio";  
    permission  java.lang.RuntimePermission  "modifyThread";  
    permission  java.lang.RuntimePermission  "modifyThreadGroup";  
    permission  java.lang.RuntimePermission  "loadLibrary.*";  
    //讀寫文件的權限
    permission  java.io.FilePermission  "<<ALL  FILES>>",  "read";  
    permission  java.io.FilePermission  "${user.dir}${/}jmf.log",  "write";  
    permission  java.io.FilePermission  "${user.home}${/}.JMStudioCfg",  "write";  
    permission  java.net.SocketPermissio  "*",  "connect,accept";  
    permission  java.io.FilePermission  "C:\WINNT\TEMP\*",  "write";  
    permission  java.io.FilePermission  "C:\WINNT\TEMP\*",  "delete";  
    permission  java.awt.AWTPermission  "showWindowWithoutWarningBanner";  
    permission  javax.sound.sampled.AudioPermission  "record"; 

  // //操作Socket端口的各類權限
    permission  java.net.SocketPermission  "-",  "listen";  
    permission  java.net.SocketPermission  "-",  "accept";  
    permission  java.net.SocketPermission  "-",  "connect";  
    permission  java.net.SocketPermission  "-",  "resolve";  
    permission  java.security.AllPermission;  
   };

  grant  signedBy  "saili"  { 
    permission  java.net.SocketPermission  "*:1024-65535",  "connect,accept,resolve";  
    permission  java.net.SocketPermission  "*:80",  "connect";  
    permission  java.net.SocketPermission  "-",  "listen,  accept,  connect,  listen,  resolve",  signedBy  "ganja";  
    permission  java.net.SocketPermission  "-",  "accept";  
    permission  java.net.SocketPermission  "-",  "connect";  
    permission  java.net.SocketPermission  "-",  "resolve";  
    permission  java.security.AllPermission;  
   };

筆者在本項目中,為了應用客戶真個用戶設置加倍的便利與簡略,將下面的文件采取VB或C#來做成一個小法式來寫。然後將JRE及些exe配合打成一個EXE包,當JRE裝置完成後,此小法式擔任找到JRE在操作體系中的裝置途徑,並在法式中寫出此java.policy文件,籠罩原本的文件。如斯一來,用戶就只需裝置一個EXE文件,從而簡化了裝置的操作次數。 

7、Applet回調辦事器

JavaScript與Applet之間可以或許互相通信給我們帶來了許多便利,Java與JavaScript相互彌補,以開辟功效更完善的Web運用法式。B/S下可以或許充足應用java的優勢,給我們帶來更多的收集體驗,便利用戶。筆者用的比擬多的是應用Swing組件開辟的運用法式應用Applet完成B/s下架構,如許可以或許充足顯示Swing組件的優勢,便於體系進級,便於保護;還有就是在WEB下,有時客戶端要應用當地的硬件資本,筆者所曉得的是經由過程Applet來完成,經由過程Applet去挪用javaAPI來完成。 我們詳細來看看JavaScript與Applet之間究竟是如何通信的呢? 

1.JavaScript拜訪Applet

<applet name="appletName" ....../>//JavaScript拜訪Applet屬性。

window.document.appletName.appletField (屬性必需是public的,"window.document."也能夠不寫) //JavaScript拜訪Applet辦法。

window.document.appletName.appletMethod (辦法必需是public的,"window.document."也能夠不寫)。 

2.Applet拜訪JavaScript 

Live Connect供給了Java與JavaScript的接口,可以許可在Java Applet小法式中應用JavaScript。 

須要用到一個jar包,在C:\Program Files\Java\目次下找,年夜概有5M多,其實就是翻開看哪一個有netscape.javascript.JSObject。假如沒有裝個NetScape或從網高低都可以。 可以把它重定名為netscape.jar(不是必需的),必定要參加到classpath,目標是使開辟的時刻可以或許編譯。特殊留意的是:安排時不須要包含netscape.jar,由於全部包會下載到客戶端,影響速度。

 //引入netscape類
import netscape.javascript.JSObject; 
import netscape.javascript.JSException; //可許可在小法式中處置異常事宜
public void callJavaScript(String callBackJavascript) {
  JSObject window = JSObject.getWindow(this); // 獲得JavaScript窗口句柄,援用以後文檔窗口
  JSObject docment = (JSObject) window.getMember("document");
    form=(JSObject)doc.getMember("textForm"); //拜訪JavaScript form對象 
    textField=(JSObject)form.getMember("textField");拜訪JavaScript text對象 
     text=(String) textField.getMember("value"); //獲得文本區的值
  // 挪用JavaScript的alert()辦法
  // window.eval("alert(\"This alert comes from Java!\")");
  window.call(callBackJavascript, null);// 參數用數組的情勢表現。
  }

8、運轉後果 

1.上傳

(1).啟動上傳下面


(2).上傳中


(3).上傳中


(4).上傳勝利


2.下載

(1)下載文件的保留途徑


(2)下載中


(3)下載中


(4)下載勝利


9、小結

在本文中,筆者將在現實項目中的上傳下載成績的處理計劃停止了論述,經由過程采取FTP協定,來到達批量的,根本Web的年夜文件的上傳下載。同時經由過程Applet技巧完成在客戶端對當地資本停止拜訪。就一些年夜家常常碰到的現實功效如進度條、斷點續傳、FTP表裡網映照等成績停止了初步的商量。這是筆者基於一些FTP的Java客戶端庫的基本運用。願望對讀者有必定的自創感化。對個中一些未盡事宜停止彌補。還有一些比擬輕易並且網上都有解釋或實例的內容在此沒有逐個羅列。如FTP在辦事器端Serv-U軟件若何樹立FTP辦事、Applet在JSP頁面中的嵌入方法及參數傳遞辦法、在Eclipse或是NetBeans下開端Applet等外容,因為篇幅的限制,並沒有詳實描寫,請讀者參考網上的例子或其他參考材料。

下載地址:http://xiazai.jb51.net/201608/yuanma/FTPTransfer(jb51.net).rar

正文,斟酌到版權的成績,沒有把JAVA類文件發下去,不外如許的JAR文件若何復原成java文件,我想年夜家曾經是很熟習了吧,呵呵.

以上就是本文的全體內容,願望對年夜家的進修有所贊助,也願望年夜家多多支撐。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved