自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

利用java-RMI進行大文件傳輸

開發(fā) 后端
Java RMI指的是遠程方法調用 ,它不是什么新技術(在Java1.1的時代都有了),但卻是是非常重要的底層技術。它是一種機制,能夠讓在某個 Java 虛擬機上的對象調用另一個 Java 虛擬機中的對象上的方法。可以用此方法調用的任何對象必須實現(xiàn)該遠程接口。

為什么要用RMI​

在這次的項目中,對于客戶端與服務器之間的通信,想了許多辦法,由于做的是富客戶端應用,最終將技術選定在了RMI和Java-sockets兩種之間,其中RMI的靈活性不高,客戶端和服務器端都必須是java編寫,但使用比較方便,反觀java-sockets,雖然比較靈活,但需要自己規(guī)定服務器端和客戶端之間的通信協(xié)議。比較麻煩,幾經權衡,最終還是選擇RMI來進行服務器-客戶端通信

文件上傳問題

在使用java-rmi的過程中,必然會遇到一個文件上傳的問題,由于在rmi中無法傳輸文件流(比如rmi中的方法參數(shù)不能是FileInputStream之類的),那么我們只好選擇一種折中的辦法,就是先用FileInputStream將文件讀到一個 Byte數(shù)組中,然后把這個Byte數(shù)組作為參數(shù)傳進RMI的方法中,然后在服務器端將Byte數(shù)組還原為outputStream,這樣就能通過RMI 來傳輸文件了

這樣做也有缺點,就是無法檢驗傳輸過來的數(shù)據(jù)的準確性,汗。。。

下面我就一個實例來講解一下

文件結構

FileClient

  1. package rmiupload; 
  2.       
  3.     import java.io.BufferedInputStream; 
  4.     import java.io.File; 
  5.     import java.io.FileInputStream; 
  6.     import java.io.FileNotFoundException; 
  7.     import java.io.IOException; 
  8.     import java.net.MalformedURLException; 
  9.     import java.rmi.Naming; 
  10.     import java.rmi.NotBoundException; 
  11.     import java.rmi.RemoteException; 
  12.       
  13.     public class FileClient { 
  14.       
  15.         public FileClient() { 
  16.             // TODO Auto-generated constructor stub 
  17.         } 
  18.       
  19.         public static void main(String[] args) { 
  20.             try { 
  21.                 FileDataService fileDataService = (FileDataService) Naming.lookup("rmi://localhost:9001/FileDataService"); 
  22.                 fileDataService.upload("/Users/NeverDie/Documents/test.mp4"new FileClient().fileToByte("/Users/NeverDie/Music/test.mp4")); 
  23.             } catch (MalformedURLException | RemoteException | NotBoundException e) { 
  24.                 // TODO Auto-generated catch block 
  25.                 e.printStackTrace(); 
  26.             } 
  27.         } 
  28.     //這個方法比較重要,通過這個方法把一個名為filename的文件轉化為一個byte數(shù)組 
  29.         private byte[] fileToByte(String filename){ 
  30.             byte[] b = null
  31.             try { 
  32.                 File file = new File(filename); 
  33.                 b = new byte[(int) file.length()]; 
  34.                 BufferedInputStream is = new BufferedInputStream(new FileInputStream(file)); 
  35.                 is.read(b); 
  36.             } catch (FileNotFoundException e) { 
  37.             // TODO Auto-generated catch block 
  38.                 e.printStackTrace(); 
  39.             } catch (IOException e) { 
  40.                 // TODO Auto-generated catch block 
  41.                 e.printStackTrace(); 
  42.             } 
  43.             return b; 
  44.         } 
  45.     } 

FileDataService

  1. package rmiupload; 
  2.       
  3.     import java.net.URL; 
  4.     import java.rmi.Remote; 
  5.     import java.rmi.RemoteException; 
  6.       
  7.     public interface FileDataService extends Remote{ 
  8.       
  9.         //這里的filename應該是該文件存放在服務器端的地址 
  10.         public void upload(String filename, byte[] file) throws RemoteException; 
  11.       
  12.     } 

FileDataService_imp

  1. package rmiupload; 
  2.       
  3.     import java.io.BufferedOutputStream; 
  4.     import java.io.File; 
  5.     import java.io.FileNotFoundException; 
  6.     import java.io.FileOutputStream; 
  7.     import java.io.IOException; 
  8.     import java.net.URL; 
  9.     import java.rmi.RemoteException; 
  10.     import java.rmi.server.RMIClientSocketFactory; 
  11.     import java.rmi.server.RMIServerSocketFactory; 
  12.     import java.rmi.server.UnicastRemoteObject; 
  13.       
  14.     public class FileDataService_imp extends UnicastRemoteObject implements FileDataService{ 
  15.       
  16.         public FileDataService_imp() throws RemoteException { 
  17.       
  18.         } 
  19.       
  20.         @Override 
  21.         public void upload(String filename, byte[] fileContent) throws RemoteException{ 
  22.             File file = new File(filename); 
  23.             try { 
  24.                 if (!file.exists()) 
  25.                     file.createNewFile(); 
  26.                 BufferedOutputStream os = new BufferedOutputStream(new FileOutputStream(file)); 
  27.                 os.write(fileContent); 
  28.             } catch (FileNotFoundException e) { 
  29.                 // TODO Auto-generated catch block 
  30.                 e.printStackTrace(); 
  31.             } catch (IOException e) { 
  32.                 // TODO Auto-generated catch block 
  33.                 e.printStackTrace(); 
  34.             } 
  35.       
  36.     ;   } 
  37.       
  38.     } 

FileServer

  1. package rmiupload; 
  2.       
  3.     import java.net.MalformedURLException; 
  4.     import java.rmi.Naming; 
  5.     import java.rmi.RemoteException; 
  6.     import java.rmi.registry.LocateRegistry; 
  7.       
  8.     public class FileServer { 
  9.       
  10.         FileDataService fileDataService; 
  11.       
  12.         public FileServer() { 
  13.             try { 
  14.                 fileDataService = new FileDataService_imp(); 
  15.                 LocateRegistry.createRegistry(9001); 
  16.                 Naming.rebind("rmi://localhost:9001/FileDataService", fileDataService); 
  17.             } catch (RemoteException e) { 
  18.                 // TODO Auto-generated catch block 
  19.                 e.printStackTrace(); 
  20.             } catch (MalformedURLException e) { 
  21.                 // TODO Auto-generated catch block 
  22.                 e.printStackTrace(); 
  23.             } 
  24.       
  25.       
  26.         } 
  27.       
  28.         /** 
  29.          * @param args 
  30.          */ 
  31.         public static void main(String[] args) { 
  32.             new FileServer(); 
  33.       
  34.         } 
  35.       
  36.     } 

原文鏈接:http://my.oschina.net/wangxuanyihaha/blog/133894

責任編輯:陳四芳 來源: 開源中國博客
相關推薦

2014-04-28 09:29:36

2013-12-20 11:05:13

IBM大數(shù)據(jù)Aspera

2009-10-27 16:52:41

VB.NET文件傳輸

2020-11-23 17:25:37

鐳速聯(lián)合架構存儲

2010-06-28 14:25:16

2017-02-27 20:24:27

Linux文件傳輸命令

2010-07-01 15:55:54

FTP文件傳輸協(xié)議

2012-03-19 10:35:51

ibmdw

2010-12-08 12:34:46

文件傳輸

2013-06-10 16:28:23

2010-11-09 17:28:27

嗅探嗅探網絡TFTP

2021-02-25 15:09:24

微信文件傳輸助手錄音

2021-06-07 00:03:31

HTTP大文件方案

2014-09-17 09:24:30

2020-11-13 08:30:57

Socket

2011-03-04 11:23:55

FileZilla

2023-06-06 08:57:27

2013-11-19 20:07:18

遠程桌面文件文件傳輸

2009-09-07 13:38:03

C# HTTP文件傳輸HTTP文件傳輸

2010-06-09 15:40:01

FTP文件傳輸協(xié)議
點贊
收藏

51CTO技術棧公眾號