iteye_17867 2012-09-10 09:10
浏览 299
已采纳

RMI中参数为Input出现的问题

在JDK 的RMI中我有个方法需要传参数,参数为InputStream,在远程调用的的时候报错,
这是我客户端代码

[code="java"]
try {

ICheckServer rmi = (ICheckServer) Naming.lookup("rmi://127.0.0.1:2012/checkserver");

InputStream in = new Thread().getContextClassLoader().getResourceAsStream("jolt-config.xml");

         rmi.initTuxedoConnect(in);
    } catch (Exception e) {  
        // TODO Auto-generated catch block  
        e.printStackTrace();  
    }  

[/code]

错误信息:
java.rmi.MarshalException: error marshalling arguments; nested exception is:
java.io.NotSerializableException: java.io.BufferedInputStream
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:138)
at java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(RemoteObjectInvocationHandler.java:178)
at java.rmi.server.RemoteObjectInvocationHandler.invoke(RemoteObjectInvocationHandler.java:132)
at $Proxy0.initTuxedoConnect(Unknown Source)
at test.Test.main(Test.java:18)
Caused by: java.io.NotSerializableException: java.io.BufferedInputStream
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1156)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:326)
at sun.rmi.server.UnicastRef.marshalValue(UnicastRef.java:274)
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:133)

  • 写回答

3条回答 默认 最新

  • iteye_5246 2012-09-10 11:28
    关注

    楼上哥们说的都对
    在实际工作中,由于io stream 不支持序列化功能,所以不能直接传递到客户端
    送一个类
    [code="java"]
    import java.io.ByteArrayInputStream;
    import java.io.ByteArrayOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.io.Serializable;
    @SuppressWarnings("serial")
    public class DataSet implements Serializable{
    private transient InputStream is;
    public DataSet(InputStream is){
    this.is = is;
    }

    public InputStream getInputStream(){
        return is;
    }
    
    private void writeObject(ObjectOutputStream out) throws IOException {
        out.defaultWriteObject();
        int c = -1;
        byte[] buff = new byte[1024];
        while((c = is.read(buff, 0, 1024)) != -1){
            out.write(buff, 0, c);
        }
    }
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException {
        in.defaultReadObject();
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        int c = -1;
        byte[] buf = new byte[1024];
        while((c = in.read(buf, 0, 1024)) != -1){
            bos.write(buf, 0, c);
        }
    
        //recreate the input stream here.
        is = new ByteArrayInputStream(bos.toByteArray());
    }
    

    }
    [/code]

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题?

悬赏问题

  • ¥15 MATLAB代码补全插值
  • ¥15 Typegoose 中如何使用 arrayFilters 筛选并更新深度嵌套的子文档数组信息
  • ¥15 前后端分离的学习疑问?
  • ¥15 stata实证代码答疑
  • ¥50 husky+jaco2实现在gazebo与rviz中联合仿真
  • ¥15 dpabi预处理报错:Error using y_ExtractROISignal (line 251)
  • ¥15 在虚拟机中配置flume,无法将slave1节点的文件采集到master节点中
  • ¥15 husky+kinova jaco2 仿真
  • ¥15 zigbee终端设备入网失败
  • ¥15 金融监管系统怎么对7+4机构进行监管的