下面是实现 RMI 的片段
以下是我的服务器类
package com.queryExecutor.actionclass;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.server.UnicastRemoteObject;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ExecutorServer extends UnicastRemoteObject implements executorInterface
{
public ExecutorServer()throws RemoteException
{
System.out.println("Server is in listening mode");
}
public void executeJob(String req_id,String usrname,String pwd,String driver,String url)throws RemoteException
{
System.out.println("Inside executeJob...");
acQueryExecutor a=new acQueryExecutor(req_id,usrname,pwd,driver,url);
ExecutorService threadExecutor = Executors.newCachedThreadPool();
threadExecutor.execute(a); // start task1
threadExecutor.shutdown(); // shutdown worker threads
}
public void killJob(String req_id)throws RemoteException{}
public int getJobStatus(String req_id)throws RemoteException{return 1;}
public void restart(String req_id)throws RemoteException{}
public static void main(String arg[])
{
try{
//Registry registry = LocateRegistry.getRegistry("10.155.1.159",1099);
LocateRegistry.createRegistry(2005);
ExecutorServer p=new ExecutorServer();
Naming.rebind("//127.0.0.1:2005/exec",p);
}catch(Exception e)
{
System.out.println("Exception occurred : "+e.getMessage());
}
}
@Override
public void executeJob(String req_id, String usrname, String pwd)
throws RemoteException {
// TODO Auto-generated method stub
System.out.println("Inside executeJob...");
acQueryExecutor a=new acQueryExecutor(req_id,usrname,pwd,"driver","url");
ExecutorService threadExecutor = Executors.newCachedThreadPool();
threadExecutor.execute(a); // start task1
threadExecutor.shutdown(); // shutdown worker threads
}
}
界面
package com.queryExecutor.actionclass;
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface executorInterface extends Remote
{
public void executeJob(String req_id,String usrname,String pwd)throws RemoteException;
public void killJob(String req_id)throws RemoteException;
public int getJobStatus(String req_id)throws RemoteException;
public void restart(String req_id)throws RemoteException;
}
package com.queryExecutor.actionclass;
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface executorInterface extends Remote
{
public void executeJob(String req_id,String usrname,String pwd)throws RemoteException;
public void killJob(String req_id)throws RemoteException;
public int getJobStatus(String req_id)throws RemoteException;
public void restart(String req_id)throws RemoteException;
}
客户
package com.queryExecutor.actionclass;
import java.rmi.Naming;
public class testClient {
public static void main(String args[])
{
try{
executorInterface p=(executorInterface)Naming.lookup("//127.0.0.1:2005/exec");
p.executeJob("1", "abc", "abc");
}
catch(Exception e)
{
System.out.println("Exception occurred : "+e.getMessage());
}
}
}
当我运行客户端代码时,我在 Eclipse 控制台标头中没有得到任何输出,而是在其写入的 javaw.exe 终止。我的问题是为什么我的客户端程序没有访问服务器。