// 遠(yuǎn)程接口定義
package rmi.server;
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface Service extends Remote {
public void hello() throws RemoteException;
public void runThread(Runnable thread) throws RemoteException;
}
// 遠(yuǎn)程接口實(shí)現(xiàn),main方法作為服務(wù)器
package rmi.server;
import java.rmi.Naming;
import java.rmi.RMISecurityManager;
import java.rmi.RemoteException;
import java.rmi.server.RemoteStub;
import java.rmi.server.UnicastRemoteObject;
import java.security.Permission;
public class ServiceImpl implements Service {
private RemoteStub stub;
private int count;
public ServiceImpl() throws RemoteException {
stub = UnicastRemoteObject.exportObject(this);
count = 0;
}
public void hello() throws RemoteException {
System.out.println("Hello World: count = " + (++count));
}
public void runThread(Runnable thread) throws RemoteException {
Thread t = new Thread(thread);
t.start();
}
public RemoteStub getStub() {
return stub;
}
public static void main(String[] args) {
System.setProperty("java.rmi.server.ignoreStubClasses", "true");
System.setProperty("java.rmi.server.codebase",
"file:///E:\\\\bahamut\\\\JavaWorkspace\\\\rmiserver\\\\classes\\\\");
if (System.getSecurityManager() == null) {
System.setSecurityManager(new RMISecurityManager() {
public void checkPermission(Permission p) {
}
});
}
try {
ServiceImpl service = new ServiceImpl();
Naming.rebind("service", service);
System.out.println("Server ready");
} catch (Exception e) {
e.printStackTrace();
}
}
}
// 客戶(hù)端
package rmi.client;
import java.rmi.Naming;
import java.rmi.RMISecurityManager;
import java.security.Permission;
import rmi.server.Service;
public class ServiceClient {
/**
* @param args
*/
public static void main(String[] args) {
System.setProperty("java.rmi.server.codebase",
"file:///E:\\\\bahamut\\\\JavaWorkspace\\\\rmiclient\\\\classes\\\\");
if (System.getSecurityManager() == null) {
System.setSecurityManager(new RMISecurityManager() {
public void checkPermission(Permission p) {
}
});
}
try {
Service service = (Service) Naming.lookup("service");
service.hello();
Runnable runner = new Runner();
service.runThread(runner);
} catch (Exception e) {
e.printStackTrace();
}
}
}
package rmi.client;
import java.io.Serializable;
public class Runner implements Runnable, Serializable {
public void run() {
System.out.println("i'm runner");
}
}
服務(wù)器端生成stub并放在classpath中,codebase設(shè)置為能找到stub的路徑,運(yùn)行rmiregistry,
運(yùn)行服務(wù)器。
客戶(hù)端只需要Service類(lèi)在classpath中,設(shè)置codebase為能找到Runner的路徑,運(yùn)行客戶(hù)端。
客戶(hù)端會(huì)從服務(wù)器下載stub,服務(wù)器會(huì)從客戶(hù)端下載Runner。Runner可以執(zhí)行任何操作甚至破壞
服務(wù)器上的數(shù)據(jù)。
多次運(yùn)行客戶(hù)端可以發(fā)現(xiàn)count在增長(zhǎng),也就是說(shuō)對(duì)于export出的遠(yuǎn)程對(duì)象,狀態(tài)是始終保存的
聯(lián)系客服