package wrox.ch12.jmx;
import java.util.Iterator;
import java.util.Set;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.Query;
import javax.management.QueryExp;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
public class RemoteClient {
MBeanServerConnection connection = null;
public RemoteClient() throws Exception {
JMXServiceURL url = new JMXServiceURL(
"service:jmx:rmi:///jndi/rmi://localhost:9999/server");
JMXConnector connector = JMXConnectorFactory.connect(url);
connection = connector.getMBeanServerConnection();
}
void deploy() throws Exception {
connection.createMBean("wrox.ch12.jmx.Worker",
new ObjectName("wrox.ch12.jmx:type=Worker,number=1"));
connection.createMBean("wrox.ch12.jmx.Worker",
new ObjectName("wrox.ch12.jmx:type=Worker,number=2"));
connection.createMBean("wrox.ch12.jmx.Worker",
new ObjectName("wrox.ch12.jmx:type=Worker,number=3"));
}
void lookup() throws Exception {
ObjectName on = new ObjectName("wrox.ch12.jmx:*");
Set set = connection.queryNames(on, null);
for (Iterator iter = set.iterator(); iter.hasNext();) {
ObjectName bean = (ObjectName) iter.next();
System.out.println("deployed..=" + bean.toString());
}
}
void checkRunning() throws Exception {
ObjectName on = new ObjectName("wrox.ch12.jmx:*");
QueryExp exp = Query.eq(Query.attr("Running"), Query.value(true));
Set set = connection.queryNames(on, exp);
for (Iterator iter = set.iterator(); iter.hasNext();) {
ObjectName bean = (ObjectName) iter.next();
System.out.println("running.. MBean =" + bean.toString());
}
}
void remove() throws Exception {
ObjectName on = new ObjectName("wrox.ch12.jmx:*");
Set set = connection.queryNames(on, null);
for (Iterator iter = set.iterator(); iter.hasNext();) {
ObjectName bean = (ObjectName) iter.next();
System.out.println("removing..=" + bean.toString());
connection.unregisterMBean(bean);
}
}
public void addMonitor( ) throws Exception {
connection.createMBean("javax.management.monitor.StringMonitor", new ObjectName("wrox.ch12.jmx:name=WorkMonitor"));
}
public static void main(String[] args) throws Exception {
RemoteClient rc = new RemoteClient();
rc.remove();
rc.deploy();
rc.lookup();
rc.checkRunning();
rc.addMonitor();
}
}
java高级编程jdk6源代码.rar （33个子文件） 
wrox-ch12 bin 
jndi.properties 174B wrox ch12 jmx RemoteClient.class 4KB Worker.class 1KB RemoteAgent.class 1KB Agent.class 1KB WorkerMBean.class 274B jms PurchaseOrder.class 421B JMSAgent.class 1KB JMSWorker.class 3KB JMSWorkerMBean.class 311B PurchaseOrderAggregate.class 949B RequestReply.class 3KB Split.class 2KB MessageClient.class 2KB jbi Simple.class 389B jbossmq-destinations-service.xml 5KB src jndi.properties 174B wrox ch12 jmx Agent.java 577B RemoteAgent.java 701B WorkerMBean.java 284B RemoteClient.java 2KB Worker.java 723B jms JMSWorkerMBean.java 269B RequestReply.java 2KB JMSAgent.java 645B MessageClient.java 1KB PurchaseOrderAggregate.java 471B JMSWorker.java 2KB PurchaseOrder.java 179B jbossmq-destinations-service.xml 5KB .project 385B .classpath 294B lib 
jbossall-client.jar 3.14MB资源评论
