java使用rmi传输大文件示例分享

更新时间：2014年01月03日 11:18:32 作者：

由于在rmi中无法传输文件流，可以先用FileInputStream将文件读到一个Byte数组中，然后把这个Byte数组作为参数传进RMI的方法中，然后在服务器端将Byte数组还原为outputStream，这样就能通过RMI 来传输文件了，下面我们来看实例

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

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

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

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

FileClient

复制代码代码如下:

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

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

复制代码代码如下:

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

复制代码代码如下:

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(); 

        } 

    } 
    

您可能感兴趣的文章:

Java里得到00:00:00格式的时分秒的Timestamp
Java里如何得到00:00:00格式的时分秒的Timestamp ，下面是具体的实现代码，需要的朋友可以参考下。
2009-09-09
Java实现生成Excel树形表头完整代码示例
这篇文章主要介绍了Java实现生成Excel树形表头完整代码示例，具有一定借鉴价值，需要的朋友可以参考下。
2017-12-12
Spring对静态变量无法注入的解决方案
这篇文章主要介绍了使用Spring对静态变量无法注入的解决方案，具有很好的参考价值，希望对大家有所帮助。
2021-07-07
微信小程序之搜索分页功能的实现代码
这篇文章主要介绍了微信小程序之搜索分页功能的实现代码，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2020-06-06
SpringBoot临时属性设置方法
这篇文章主要介绍了SpringBoot临时属性设置方法，SpringBoot工程可以基于java环境独立进行jar文件启动服务,文中给大家提到了命令行启动常见问题以及解决方案，需要的朋友可以参考下
2022-09-09
Springboot整个Quartz实现动态定时任务的示例代码
这篇文章主要介绍了Springboot整个Quartz实现动态定时任务的示例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-09-09
Java基础篇之反射机制详解
本文详细讲解了Java基础篇之反射机制，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-01-01
jar包加密方案分享
如何对jar包进行加密呢？其实没有想象中的那么困难，有一款开源工具已经提供了较为完善的加密方案，这款开源工具的名字叫做xjar。接下来我们就看一下使用xjar工具给jar包加密有多么的容易。
2021-06-06
Flink流处理引擎零基础速通之数据的抽取篇
今天不分享基础概念知识了，来分享一个马上工作需要的场景，要做数据的抽取，不用kettle，想用flink。实际就是flink的sql、table层级的api
2022-05-05
Java实战花店商城系统的实现流程
只学书上的理论是远远不够的，只有在实战中才能获得能力的提升，本篇文章手把手带你用java+Springboot+Maven+mybatis+Vue+Mysql实现一个花店商城系统,大家可以在过程中查缺补漏，提升水平
2022-01-01