10

小さな RMI ベースのチャット アプリケーションを作成しています。

アイデアは、クライアントが自分自身をサーバーに登録し、サーバーがクライアントからメッセージを受信するたびに、このメッセージを他のすべてのクライアントにプッシュするというものです。

しかし、私は NotSerializableException を受け取りますが、メソッドのパラメーターとして渡しているオブジェクトは、Remote インターフェイスを実装しています。

ここにいくつかのコードがあります: (問題のある部分は(ClientChat 実装)の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 は既に Remote であるにもかかわらず、なぜこの種の Exception が発生するのか疑問に思います。

あなたが私を助けてくれることを願っています:)

4

3 に答える 3

16

パラメーターとして渡されるオブジェクトまたはリモート メソッドの結果は、次のいずれかである必要があります。

  1. シリアル化可能（または外部化可能）、または

  2. エクスポートされたリモート オブジェクト。

あなたのものはどちらでもありません。ただし、Remote インターフェイスを実装しているため、明らかに意図したとおりです (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 に答える