10

我正在编写一个基于 RMI 的小型聊天应用程序。

思路是：Client在Server上注册自己，每次Server收到一个client发来的消息，他都会把这个消息推送给其他所有的client。

但是我收到了 NotSerializableException，尽管我作为方法参数传递的对象实现了 Remote 接口。

这是一些代码：（有问题的部分是（ClientChat Implementation）中的this参数）this.chatServ.registriereClient(this);

(ClientChat) 界面：

public interface ChatClient extends Remote
{

}

(ClientChat)实现：

public class ChatClientImpl implements ChatClient
{

    ChatServer chatServ;
    String clientName;

    public ChatClientImpl(String clientName, ChatServer chatServ) {
        this.chatServ = chatServ;
        this.clientName = clientName;
        try {
            this.chatServ.registriereClient(this);
        } catch (RemoteException e) {
            e.printStackTrace();
        }
    }
}

(ServerChat) 接口

public interface ChatServer extends Remote
{
        void registriereClient(ChatClient client) throws RemoteException;

}

(ServerChat) 实现

public class LobbyChatServerImpl implements ChatServer
{

    ArrayList<ChatClient> clientListe = null;

    @Override
    public void registriereClient(ChatClient client) {
        System.out.println("Client registriert");
        this.clientListe.add(client);
    }
}

客户：

  public static void main(String[] args) {
        ChatServer lobbyChatServer = null;
        try {
            Registry registry = LocateRegistry.getRegistry(Server.RMI_PORT);
            lobbyChatServer = (ChatServer) registry.lookup("LobbyChatServer");

        } catch (RemoteException e) {
            e.printStackTrace();
        } catch (NotBoundException e) {
            e.printStackTrace();
        }

        ChatClient lobbyChat = new ChatClientImpl(name, lobbyChatServer);
  }

服务器：

    public static void main(String[] args) {
        try {
            if (System.getSecurityManager() == null) {
                System.setSecurityManager(new RMISecurityManager());
            }

            Registry registry = LocateRegistry.getRegistry(RMI_PORT);

            ChatServer lobbyChatStub = (ChatServer)UnicastRemoteObject.exportObject(new LobbyChatServerImpl(), 0);
            registry.bind("LobbyChatServer", lobbyChatStub);

        } catch (RemoteException e) {
            e.printStackTrace();
        } catch (AlreadyBoundException e) {
            e.printStackTrace();
        }
    }

例外：

java.rmi.MarshalException: error marshalling arguments; nested exception is: 
    java.io.NotSerializableException: de.XX.Chat.ChatClientImpl
    at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:156)
    at java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(RemoteObjectInvocationHandler.java:194)
    at java.rmi.server.RemoteObjectInvocationHandler.invoke(RemoteObjectInvocationHandler.java:148)
    at $Proxy0.registriereClient(Unknown Source)
    at de.XX.Chat.ChatClientImpl.<init>(ChatClientImpl.java:19)
    at de.XX.Client.main(Client.java:49)
Caused by: java.io.NotSerializableException: de.XX.Chat.ChatClientImpl
    at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1180)
    at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:346)
    at sun.rmi.server.UnicastRef.marshalValue(UnicastRef.java:292)
    at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:151)
    ... 5 more

如前所述，我想知道为什么我会得到这种异常，尽管 ChatClientImpl 已经是远程的。

希望你能帮我：）

4

3 回答 3

16

作为远程方法的参数或结果传递的对象必须是：

  1. 可序列化（或可外部化），或

  2. 导出的远程对象。

你的也不是。但是，由于它显然实现了您想要的远程接口 (2)。扩展的对象UnicastRemoteObject在构造时自动导出。不必显式导出的对象，通过UnicastRemoteObject.exportObject().

于 2012-06-15T11:49:25.697 回答
1

您可以做的是设置一个回调对象。这是一个扩展 UnicastRemoteObject 的对象，当您传递它时，它会变成一个回调。

http://www.cs.swan.ac.uk/~csneal/InternetComputing/RMIChat.html

远程不可序列化。您不能以这种方式传递代理对象。即使您将其设为可序列化，它也会发送服务器上存在的对象的副本。不会调用客户端上的对象副本。

为了让您的“服务器”向您的“客户端”发送消息，您必须在“客户端”上创建一个服务以使其成为服务器。

您可能会发现使用 JMS 等消息传递解决方案更适合这种情况。JMS 服务器具有您可以发布和订阅的主题。一个简单的 JMS 服务器是 Active MQ。

于 2012-06-15T11:30:10.253 回答
1

看起来您可能忘记在接口实现上“扩展 UnicastRemoteObject”：

public class ChatClientImpl extends UnicastRemoteObject implements ChatClient{
}

和

public class LobbyChatServerImpl extends UnicastRemoteObject  implements ChatServer{
}
于 2014-12-21T13:29:01.967 回答