自己依照已有的源代碼,主要是在JMX框架下,實現了RMI遠程調用的一個簡單的例子,主要是為了驗證RMI調用時文件的配置情況。
主要有forPlay類及對應的MBean,Server端以及client端,其中,clint端是和其他文件異地配置的,在同一臺機子上更沒問題了。通過RMI遠程連接,我們可以實現一個瘦客戶端的,即主要的MBean是放在Server端,客戶端使用相應的類時,只需要通過RMI調用就行了,另外,MBean只需和服務器同包放置或者服務器能夠找到的位置,無須顯式的注冊,這是我實現這個程序的主要目的。
server端的源代碼和JMX下RMI遠程調用的入門(環境變量的設置)里面的Server.java文件是一樣的,涉及到環境變量以及如何運行,這篇文章里也有詳細介紹。這里只給出我今天寫的一段代碼
整個程序一共有四個文件
forReplay.java、forReplayMBean.java、Client.java以及前面說到的Server.java,這里給出前三個文件的代碼:
***********************************************************
forReplay.java
***************************************
public class forReplay
implements forReplayMBean{
private String State="待調用";
public void play(){
System.out.println("play函數調用成功!");
}
public String getState() {
return State;
}
public void setState(String s) {
State=s;
}
}
***********************************************************
***********************************************************
forReplayMBean.java
***************************************
public interface forReplayMBean {
public String getState();
public void setState(String s);
public void play();
}
***********************************************************
***********************************************************
Client.java
***************************************
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
public class Client {
public static void main(String[] args) {
try {
// 創建RMI連接客戶端到RMI連接服務器
JMXServiceURL url = new JMXServiceURL(
"service:jmx:rmi:///jndi/rmi://localhost:9999/server");
JMXConnector jmxc = JMXConnectorFactory.connect(url, null);
// 獲得一個MBean服務器連接
MBeanServerConnection mbsc = jmxc.getMBeanServerConnection();
//創建一個forPlay類
ObjectName mbeanName = new ObjectName("chengang:name=forReplay");
mbsc.createMBean("forReplay", mbeanName, null, null);
System.out.println("\nMBean數量為" + mbsc.getMBeanCount());// 獲得Mbean的數量
mbsc.invoke(mbeanName,"play", null, null);//調用forPlay類中的play()函數
Thread.sleep(2000);//掛起2000毫秒,等待服務器反應.
mbsc.unregisterMBean(mbeanName); //注銷MBean的注冊,不是必要的
jmxc.close();// 關閉連接,不是必要的
} catch (Exception e) {
e.printStackTrace();
}
}
}
***********************************************************
***********************************************************