*** 作系统：CentOS 64bit (Linux)
步骤（代码省略）：
1.创建Socket远程服务器
2.创建客户端
配置：
#查找对象stub端口
RMI_PORT=9902
#服务端口
RMI_SERV_RMI_PORT=9903
#注册服务地址端口要和查找对象stub端口一致
RMI_URL=rmi://192.168.0.118:9902/MongoServer
#绑定IP
RMI_IP=192.168.0.118
#检查内存shell
RMI_MEMQUERY_COMMAND=sh /home/test/BI/smartshow14/MongoDBRMIServer/memquery.sh
#释放内存shell
RMI_MEMFREE_COMMAND=sh /home/test/BI/smartshow14/MongoDBRMIServer/memclear.sh
#释放内存容量阀值,单位M
RMI_MEM_CAPACITY_LIMIT=3000
3.启动服务器
客户端线程通过 rmi://192.168.0.118:9902/MongoServer 访问时出现异常：
--定时扫描MONGODB内存线程--：开始运行！
java.rmi.UnmarshalException: error unmarshalling returnnested exception is:
java.lang.ClassNotFoundException: com.linkage.iface.IMongoDBScan (no security manager: RMI class loader disabled)
at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source)
at java.rmi.Naming.lookup(Naming.java:84)
at com.linkage.querytool.QueryRMICaller.ramCapacityScan(QueryRMICaller.java:87)
at com.linkage.querytool.MongoDBARMScanThread$TimerWorkTask.run(MongoDBARMScanThread.java:94)
at java.util.TimerThread.mainLoop(Timer.java:512)
at java.util.TimerThread.run(Timer.java:462)
Caused by: java.lang.ClassNotFoundException: com.linkage.iface.IMongoDBScan (no security manager: RMI class loader disabled)
at sun.rmi.server.LoaderHandler.loadProxyClass(LoaderHandler.java:535)
at java.rmi.server.RMIClassLoader$2.loadProxyClass(RMIClassLoader.java:628)
at java.rmi.server.RMIClassLoader.loadProxyClass(RMIClassLoader.java:294)
at sun.rmi.server.MarshalInputStream.resolveProxyClass(MarshalInputStream.java:238)
at java.io.ObjectInputStream.readProxyDesc(ObjectInputStream.java:1530)
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1492)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1731)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:350)
... 6 more
--定时扫描MONGODB内存线程--：处理结束！
=======================================================================================================
--定时扫描MONGODB内存线程--：开始运行！
java.security.AccessControlException: access denied (java.net.SocketPermission 192.168.0.118:9902 connect,resolve)
at java.security.AccessControlContext.checkPermission(AccessControlContext.java:374)
at java.security.AccessController.checkPermission(AccessController.java:546)
at java.lang.SecurityManager.checkPermission(SecurityManager.java:532)
at java.lang.SecurityManager.checkConnect(SecurityManager.java:1034)
at java.net.Socket.connect(Socket.java:524)
at java.net.Socket.connect(Socket.java:478)
at java.net.Socket.<init>(Socket.java:375)
at java.net.Socket.<init>(Socket.java:189)
at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(RMIDirectSocketFactory.java:22)
at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(RMIMasterSocketFactory.java:128)
at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:595)
at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:198)
at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:184)
at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:322)
at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source)
at java.rmi.Naming.lookup(Naming.java:84)
at com.linkage.querytool.QueryRMICaller.ramCapacityScan(QueryRMICaller.java:89)
at com.linkage.querytool.MongoDBARMScanThread$TimerWorkTask.run(MongoDBARMScanThread.java:94)
at java.util.TimerThread.mainLoop(Timer.java:512)
at java.util.TimerThread.run(Timer.java:462)
--定时扫描MONGODB内存线程--：处理结束！
============================================================================================================
--定时扫描MONGODB内存线程--：开始运行！
java.security.AccessControlException: access denied (java.lang.RuntimePermission createSecurityManager)
at java.security.AccessControlContext.checkPermission(AccessControlContext.java:374)
at java.security.AccessController.checkPermission(AccessController.java:546)
at java.lang.SecurityManager.checkPermission(SecurityManager.java:532)
at java.lang.SecurityManager.<init>(SecurityManager.java:282)
at java.rmi.RMISecurityManager.<init>(RMISecurityManager.java:45)
at com.linkage.querytool.QueryRMICaller.ramCapacityScan(QueryRMICaller.java:88)
at com.linkage.querytool.MongoDBARMScanThread$TimerWorkTask.run(MongoDBARMScanThread.java:94)
at java.util.TimerThread.mainLoop(Timer.java:512)
at java.util.TimerThread.run(Timer.java:462)
--定时扫描MONGODB内存线程--：处理结束！
==========================================================================================================
以上异常都有可能出现，通过以下方式可解除问题：
1.在客户端程序前打开安全管理器：
try {
System.setSecurityManager(new java.rmi.RMISecurityManager())
mds = (IMongoDBScan) Naming.lookup(urlStr)
} catch (MalformedURLException e) {
//..........
}
2.修改/usr/java/jdk1.6.0_21/jre/lib/security/java.policy后重启
grant {
permission java.security.AllPermission
}
Java 远程处理Java远程方法调用(RMI)提供了Java程序语言的远程通讯功能,这种特性使客户机上运行的程序可以调用远程服务器上的对象,使Java编程人员能够在网络环境中分布 *** 作。
创建一个简单的Java分布式远程方法调用程序可以按以下几个步骤 *** 作,
一、定义远程接口：
在 Java 中，远程对象是实现远程接口的类的实例, 远程接口声明每个要远程调用的方法。在需要创建一个远程对象的时候，我们通过传递一个接口来隐藏基层的实施细节，客户通过接口句柄发送消息即可。
远程接口具有如下特点：
1) 远程接口必须为public属性。如果不这样，除非客户端与远程接口在同一个包内，否则 当试图装入实现该远程接口的远程对象时，调用会得到错误结果。
2) 远程接口必须扩展接口java.rmi.Remote。
3) 除与应用程序本身特定的例外之外，远程接口中的每个方法都必须在自己的throws从句中 声明java.rmi.RemoteException。（或 RemoteException 的父类）。
4) 作为参数或返回值传递的一个远程对象(不管是直接，还是本地对象中嵌入)必须声明为远 程接口，而不应声明为实施类。
下面是远程接口的定义
[java] view plaincopy
package test
import java.rmi.Remote
import java.rmi.RemoteException
import java.math.BigInteger
public interface Fib extends Remote {
public int getFib(int n) throws RemoteException
//public BigInteger getFib(BigInteger n) throws RemoteException
}
二、实现远程接口：
远程对象实现类必须扩展远程对象java.rmi.UnicastRemoteObject类，并实现所定义的远程接口。远程对象的实现类中包含实现每个远程接口所指定的远程方法的代码。这个类也可以含有附加的方法，但客户只能使用远程接口中的方法。因为客户是指向接口的一个句柄，而不是它的哪个类。必须为远程对象定义构造函数，即使只准备定义一个默认构造函数，用它调用基础类构造函数。因为基础类构造函数可能会抛出 java.rmi.RemoteException，所以即使别无它用必须抛出java.rmi.RemoteException例外。
以下是远程对象实现类的声明：
[java] view plaincopy
package test
import java.math.BigInteger
import java.rmi.*
import java.rmi.server.UnicastRemoteObject
public class FibImp extends UnicastRemoteObject implements Fib {
public FibImp() throws RemoteException {
super()
}
public int getFib(int n) throws RemoteException {
return n+2
}
}
三、编写服务器类:
包含 main 方法的类可以是实现类自身，也可以完全是另一个类。下面通过RmiSampleServer 来创建一个远程对象的实例，并通过java.rmi.registry.LocateRegistry类的createRegistry 方法从指定端口号启动注册服务程序，也可以通过执行 rmiregistry 命令启动注册服务程序，注册服务程序的缺省运行端口为 1099。必须将远程对象名字绑定到对远程对象的引用上： Naming.rebind("//localhost:8808/SAMPLE-SERVER" , Server)
以下是服务器类的声明：
[java] view plaincopy
package test
import java.net.MalformedURLException
import java.rmi.Naming
import java.rmi.RemoteException
import java.rmi.registry.LocateRegistry
public class FibonacciServer {
/**
* @param args
*/
public static void main(String[] args) {
try {
LocateRegistry.createRegistry(8804)
FibImp f = new FibImp()
// 注册到 registry 中
Naming.rebind("//localhost:8804/SAMPLE-SERVER", f)
System.out.println("fib server ready")
} catch (RemoteException re) {
System.out.println("Exception in FibonacciImpl.main: " + re)
} catch (MalformedURLException e) {
System.out.println("MalformedURLException " + e)
}
}
}
四、编写使用远程服务的客户机类:
客户机类的主要功能有两个，一是通过Naming.lookup方法来构造注册服务程序 stub 程序实例，二是调用服务器远程对象上的远程方法。
以下是客户端类的声明：
[java] view plaincopy
package testClient
import test.Fib
import java.math.BigInteger
import java.net.MalformedURLException
import java.rmi.Naming
import java.rmi.NotBoundException
import java.rmi.RemoteException
public class FibClient {
/**
* @param args
*/
public static void main(String[] args) {
String url = "//localhost:8804/SAMPLE-SERVER"
try {
Fib calc = (Fib) Naming.lookup(url)
for (int i = 0i <10++i) {
int f = calc.getFib(i)
System.out.println(f)
}
} catch (MalformedURLException e) {
e.printStackTrace()
} catch (RemoteException e) {
e.printStackTrace()
} catch (NotBoundException e) {
e.printStackTrace()
}
}
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）