利用java-RMI进行大文件传输代码,Java代码库,德仔网

代码语言
代码分类
【Java】利用java-RMI进行大文件传输
作者:萧宇宙 / 发布于2013/5/28/ 550
简单模拟RMI传输大文件。

	FileDataService

	import java.rmi.Remote;
	import java.rmi.RemoteException;

	public interface FileDataService extends Remote {
	
	public static final String FILE_SERVICE = "rmi://localhost:9001/FileDataService";
	
	public String start(String filename) throws RemoteException;

	public void upload(String uploadId,byte[] part,int offset,int len) throws RemoteException;
	
	
	public void finish(String uploadId) throws RemoteException;

	}

	

	

	

	FileDataServiceImpl

	

	import java.io.BufferedOutputStream;
	import java.io.File;
	import java.io.FileOutputStream;
	import java.io.IOException;
	import java.io.OutputStream;
	import java.rmi.RemoteException;
	import java.rmi.server.UnicastRemoteObject;
	import java.util.HashMap;
	import java.util.Map;
	import java.util.UUID;

	public class FileDataServiceImpl extends UnicastRemoteObject implements FileDataService {
	
	Map<String, OutputStream> os = new HashMap<String, OutputStream>();

	public FileDataServiceImpl() throws RemoteException {
	 super();
	}
	
	public String start(String filename) throws RemoteException{
	 File file = new File(filename);
	 try {
	 if (!file.exists())
	 file.createNewFile();
	 OutputStream upOS = new BufferedOutputStream(new FileOutputStream(file));
	 String uploadId = UUID.randomUUID().toString();
	 os.put(uploadId, upOS);
	 return uploadId;
	 }catch (Exception e) {
	 throw new RemoteException("初始化文件上传失败：",e);
	 }
	
	}

	public void upload(String uploadId,byte[] part,int offset,int len) throws RemoteException {
	 OutputStream upOS = os.get(uploadId);
	 if(upOS == null){
	 throw new RemoteException("上传文件的id不存在:" + uploadId);
	 }
	 try {
	 upOS.write(part,offset,len);
	 } catch (Exception e) {
	 throw new RemoteException("File Up[" + uploadId+"]Exception:",e);
	 }
	}
	
	
	public void finish(String uploadId) throws RemoteException{
	 try {
	 os.get(uploadId).close();
	 } catch (IOException e) {
	 throw new RemoteException("结束文件上传失败：",e);
	 }
	}

	}

	

	

	FileServer

	

	import java.net.MalformedURLException;
	import java.rmi.Naming;
	import java.rmi.RemoteException;
	import java.rmi.registry.LocateRegistry;

	public class FileServer {

	 FileDataService fileDataService;

	 public FileServer() {
	 try {
	 fileDataService = new FileDataServiceImpl();
	 LocateRegistry.createRegistry(9001);
	 Naming.rebind(FileDataService.FILE_SERVICE, fileDataService);
	 } catch (RemoteException e) {
	 e.printStackTrace();
	 } catch (MalformedURLException e) {
	 e.printStackTrace();
	 }
	 }

	 /**
	 * @param args
	 */
	 public static void main(String[] args) {
	 new FileServer();
	 }

	}

	

	

	[Java]代码

	

	import java.io.FileInputStream;
	import java.rmi.Naming;

	public class FileClient {

	 public FileClient() {
	 }

	 public static void main(String[] args) {
	 try {
	 FileInputStream fis = new FileInputStream("d:/r1.log");
	 FileDataService fileDataService = (FileDataService) Naming.lookup(FileDataService.FILE_SERVICE);
	 String uploadId = fileDataService.start("d:/r12.log");
	 byte[] buffer = new byte[1024];
	 int len = fis.read(buffer);
	 while(len> -1){
	 fileDataService.upload(uploadId, buffer, 0, len);
	 System.out.println("read part");
	 len = fis.read(buffer);
	 }
	 fileDataService.finish(uploadId);
	 System.out.println("file upload finished");
	 } catch (Exception e) {
	 e.printStackTrace();
	 }
	 }
	}
试试其它关键字
　大文件传输　
同语言下
可能有用的
萧宇宙贡献的其它代码(1)
.利用java-RMI进行大文件传输