【JAVA】利用java-RMI进行大文件传输
【JAVA】利用java-RMI进行大文件传输
王选易 发表于5年前
【JAVA】利用java-RMI进行大文件传输
  • 发表于 5年前
  • 阅读 6167
  • 收藏 123
  • 点赞 0
  • 评论 19

标题:腾讯云 新注册用户域名抢购1元起>>>   

摘要: 讲解了在java中用byte数组来保存文件并传输的技术

点击进入我的新博客

#利用java-RMI进行大文件传输

###为什么要用RMI

在这次的项目中,对于客户端与服务器之间的通信,想了许多办法,由于做的是富客户端应用,最终将技术选定在了RMI和Java-sockets两种之间,其中RMI的灵活性不高,客户端和服务器端都必须是java编写,但使用比较方便,反观java-sockets,虽然比较灵活,但需要自己规定服务器端和客户端之间的通信协议。比较麻烦,几经权衡,最终还是选择RMI来进行服务器-客户端通信

###文件上传问题

在使用java-rmi的过程中,必然会遇到一个文件上传的问题,由于在rmi中无法传输文件流(比如rmi中的方法参数不能是FileInputStream之类的),那么我们只好选择一种折中的办法,就是先用FileInputStream将文件读到一个Byte数组中,然后把这个Byte数组作为参数传进RMI的方法中,然后在服务器端将Byte数组还原为outputStream,这样就能通过RMI来传输文件了

这样做也有缺点,就是无法检验传输过来的数据的准确性,汗。。。

下面我就一个实例来讲解一下

###文件结构

在此输入图片描述

FileClient

<!-- lang: java -->
package rmiupload;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;

public class FileClient {

	public FileClient() {
		// TODO Auto-generated constructor stub
	}
	
	public static void main(String[] args) {
		try {
			FileDataService fileDataService = (FileDataService) Naming.lookup("rmi://localhost:9001/FileDataService");
			fileDataService.upload("/Users/NeverDie/Documents/test.mp4", new FileClient().fileToByte("/Users/NeverDie/Music/test.mp4"));
		} catch (MalformedURLException | RemoteException | NotBoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
//这个方法比较重要,通过这个方法把一个名为filename的文件转化为一个byte数组
	private byte[] fileToByte(String filename){
		byte[] b = null;
		try {
			File file = new File(filename);
			b = new byte[(int) file.length()];
			BufferedInputStream is = new BufferedInputStream(new FileInputStream(file));
			is.read(b);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return b;
	}
}

FileDataService

<!-- lang: java -->
package rmiupload;

import java.net.URL;
import java.rmi.Remote;
import java.rmi.RemoteException;

public interface FileDataService extends Remote{

	//这里的filename应该是该文件存放在服务器端的地址
	public void upload(String filename, byte[] file) throws RemoteException;
	
}

FileDataService_imp

<!-- lang: java -->
package rmiupload;

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URL;
import java.rmi.RemoteException;
import java.rmi.server.RMIClientSocketFactory;
import java.rmi.server.RMIServerSocketFactory;
import java.rmi.server.UnicastRemoteObject;

public class FileDataService_imp extends UnicastRemoteObject implements FileDataService{

	public FileDataService_imp() throws RemoteException {
		
	}

	@Override
	public void upload(String filename, byte[] fileContent) throws RemoteException{
		File file = new File(filename);
		try {
			if (!file.exists())
				file.createNewFile();
			BufferedOutputStream os = new BufferedOutputStream(new FileOutputStream(file));
			os.write(fileContent);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
;	}

}

FileServer

<!-- lang: java -->
package rmiupload;

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 FileDataService_imp();
			LocateRegistry.createRegistry(9001);
			Naming.rebind("rmi://localhost:9001/FileDataService", fileDataService);
		} catch (RemoteException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (MalformedURLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}

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

	}

}
共有 人打赏支持
粉丝 85
博文 20
码字总数 20066
作品 3
评论 (19)
ccor
大文件能行么?小心OOM……还是用socket简单。
王选易

引用来自“ccor”的评论

大文件能行么?小心OOM……还是用socket简单。

可以分段上传,每次上传1M
achui_1980
分段上传的例子在哪里体现?
夲仒無道
准确性用奇偶校验行不?
王选易

引用来自“achui_1980”的评论

分段上传的例子在哪里体现?

http://www.oschina.net/code/snippet_947482_21676
别人照我的例子改的,你可以参考一下
王选易

引用来自“夲仒無道”的评论

准确性用奇偶校验行不?

可以的,但是增加了复杂程度,而且RMI是基于TCP协议,不大可能出现数据丢失的情况
夲仒無道
你要觉得可能会丢包,那么就校验一下,其实也没增加多少复杂度...毕竟做程序要严谨第一呢,你说呢。
王选易

引用来自“夲仒無道”的评论

你要觉得可能会丢包,那么就校验一下,其实也没增加多少复杂度...毕竟做程序要严谨第一呢,你说呢。

嗯,是呢,一会儿改一下
公孙二狗
挺好的想法,底层都是Socket,与直接用Socket没有本质的区别。
王选易

引用来自“jorneyr”的评论

挺好的想法,底层都是Socket,与直接用Socket没有本质的区别。

嗯,似的,只不过是这样可以让整个应用全是用RMI,比较方便
晒太阳的小猪
好东西!!!
湛蓝的天空
感觉还是用socket靠谱些,rmi主要是用来传对象用的。
温佐镜
用fileToByte方法把大文件读入内存,内存消耗会很严重
飞天遇见猪
记录MD5码,可以校验准确性了~
hy86
如果客户端和服务端在网络上不同的机器上进行模拟,会不会有什么问题,要知道RMI容易遇到防火墙的问题
缪斯的情人
这个mina和netty岂不是更好
王选易

引用来自“缪斯的情人”的评论

这个mina和netty岂不是更好

的确用mina,netty更好,这里只是给出一种简单的解决方案,对于小项目是够用了
起色
好思路,学习了
xiaobao36
不错,马克了
×
王选易
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: