-1

私が作成しているプログラムの内部動作を理解するのに問題があります。プログラムは、サーバーに接続して自身を登録するRMIクライアントであると想定されています。サーバーは、ループ内でクライアントのメソッドを呼び出すことになっています。ただし、リスナーは追加されていません。

出力に注意してください。サーバーにリスナーを追加した後、メソッドは正しいサイズを出力しますが、リストが空のままであるため、サーバーを実行しているスレッドは出力しません。なぜああ、なぜこれが起こっているのですか？

クライアント

public class GameClient extends Thread implements Remote, Client, ModelChangeListener<Client>{
private static final long serialVersionUID = -394039736555035873L;
protected Queue<GameModelEvent> queue = new ConcurrentLinkedQueue<GameModelEvent>(); 


public GameClient(){

}

public static void main(String[] args){
    GameClient client = new GameClient();
    client.start();
}


protected void bind(){
    System.setProperty("java.rmi.server.codebase","file:bin/");
    try {
        Registry registry = LocateRegistry.getRegistry();
        Client c = (Client)UnicastRemoteObject.exportObject(this, 10999);
        Server stub = (Server) registry.lookup("Server");
        stub.registerClient(c);
    } catch (RemoteException | NotBoundException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}



@Override
public void run() {
    super.run();
    bind();
    while(!Thread.interrupted()){
        System.out.print(".");
        GameModelEvent event = queue.poll();
        while(event != null){

            System.out.println(event);


            event = queue.poll();
        }

        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            return;
        }
    }

}

   .....
}

サーバ

public class GameServer extends Thread implements ModelChangeListener<GameServer>, Server{
protected Queue<GameModelEvent> queue = new ConcurrentLinkedQueue<GameModelEvent>(); 
List<Client> clients = Collections.synchronizedList(new ArrayList<Client>());

public static void main(String[] args){
    GameServer server = new GameServer();
    server.start();
}

protected void bind(){
    System.setProperty("java.security.policy","file:policy.policy");
    System.setProperty("java.rmi.server.codebase","file:bin/");

    if (System.getSecurityManager() == null) {
        System.setSecurityManager(new SecurityManager());
    }
    try {
        String name = "Server";
        Server engine = new GameServer();
        Server stub =
            (Server) UnicastRemoteObject.exportObject(engine, 0);
        Registry registry = LocateRegistry.getRegistry();
        registry.rebind(name, stub);
        System.out.println("ComputeEngine bound");
    } catch (Exception e) {
        System.err.println("GameServer exception:");
        e.printStackTrace();
        System.exit(1);
    }
}

public void run() {
    super.run();
    bind();
    while(!Thread.interrupted()){
        System.out.print(clients.size()+ " ");

            try {
                for(Client c : clients)
                c.modifyConnection(null);
            } catch (RemoteException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

        GameModelEvent event = queue.poll();
        while(event != null){

            System.out.println(event);


            event = queue.poll();
        }

        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            return;
        }
    }

}
@Override
public void registerClient(Client client) {
    System.out.println("\nAdded client "+client);
    clients.add(client);
    System.out.println("clients size "+clients.size());     
}
 ...
 }

出力

ComputeEngine bound
0 0 0 0 
Added client Proxy[Client,RemoteObjectInvocationHandler[UnicastRef [liveRef: [endpoint:[10.117.2.88:10999](remote),objID:[5c30c56:13c5dfe5faf:-7fff, 1084850783049542281]]]]]
clients size 1
0 0 0 0 0
4

1 に答える 1

3

GameServerバインドしているインスタンスは、メインメソッドで作成しているインスタンスとは異なるインスタンスです 。

これは、RMI呼び出しを受信するバインドされたインスタンスですが、スレッドによって使用されるメインのメソッドインスタンスです。したがって、2つの異なるクライアントリストがあります。

行GameServerを置き換える：

UnicastRemoteObject.exportObject(engine, 0);

と ：

UnicastRemoteObject.exportObject(this, 0);
于 2013-01-21T17:57:15.533 に答える