It’s really easy to create a MBean, export it with the platform MBean server and access the bean with Groovy.
Here’s how (it’s more or less an extended rewrite of this post).
The main trick is to implement ApplicationContextAware, which let Spring call the setApplicationContext method with the prepared application context (not tried, could be even shorter: is autowiring with the type “ApplicationContext” possible as well?)
Java part
The ManagementFactory lets you register your MBean in the platform MBean server (used to serve the application context).
Important: The easiest way to access the MBean remotely is by providing -Dcom.sun.management.jmxremote.port=6666 -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false as System parameters (VM arguments in Eclipse) – obviously, this is not very secure.
package com.commons.blog;
import java.lang.management.ManagementFactory;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.management.InstanceAlreadyExistsException;
import javax.management.MBeanRegistrationException;
import javax.management.MalformedObjectNameException;
import javax.management.NotCompliantMBeanException;
import javax.management.ObjectName;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
public class AppCtxGlobalExporter implements AppCtxGlobalExporterMBean, ApplicationContextAware {
private ApplicationContext appCtx;
public AppCtxGlobalExporter() {}
public void setApplicationContext(ApplicationContext appCtx) throws BeansException {
this.appCtx = appCtx;
initMBeanServer();
}
private void initMBeanServer() {
try {
ManagementFactory.getPlatformMBeanServer().
registerMBean(this, new ObjectName("jmxsample:type=AppCtxGlobalMBeanExporter"));
} catch (InstanceAlreadyExistsException e) {
Logger.getLogger(AppCtxGlobalExporter.class.getName()).log(Level.SEVERE, null, e);
} catch (MBeanRegistrationException e) {
Logger.getLogger(AppCtxGlobalExporter.class.getName()).log(Level.SEVERE, null, e);
} catch (NotCompliantMBeanException e) {
Logger.getLogger(AppCtxGlobalExporter.class.getName()).log(Level.SEVERE, null, e);
} catch (MalformedObjectNameException e) {
Logger.getLogger(AppCtxGlobalExporter.class.getName()).log(Level.SEVERE, null, e);
} catch (NullPointerException e) {
Logger.getLogger(AppCtxGlobalExporter.class.getName()).log(Level.SEVERE, null, e);
}
}
public String[] getBeanNames() {
return appCtx.getBeanDefinitionNames();
}
}
with the interface:
package com.commons.blog;
public interface AppCtxGlobalExporterMBean {
String[] getBeanNames();
}
Here the main class:
package com.commons.blog;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class AppCtxRegistry {
public static void main(String[] args) {
ApplicationContext app = new ClassPathXmlApplicationContext("beans.xml");
SampleBean sample = (SampleBean) app.getBean("sample");
System.out.println(sample);
while(true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
the sample bean is left out, it’s not important and could even be empty.
The important part is the applicationContext.xml, the bean which implements ApplicationContextAware must just be instantiated, the Method setApplicationContext is called with the appropriate appcontext on startup.
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"> <beans> <bean class="com.commons.blog.AppCtxGlobalExporter"/> <bean id="sample" class="com.commons.blog.SampleBean"/> </beans>
Now comes the fun (Groovy!) part:
import javax.management.ObjectName
import javax.management.remote.JMXConnectorFactory as JmxFactory
import javax.management.remote.JMXServiceURL as JmxUrl
class JmxClient {
def jmx() {
def serverUrl = 'service:jmx:rmi:///jndi/rmi://localhost:6666/jmxrmi'
def server = JmxFactory.connect(new JmxUrl(serverUrl)).MBeanServerConnection
def mbean = new GroovyMBean(server, "jmxsample:type=AppCtxGlobalMBeanExporter")
mbean.BeanNames.each {
println it
}
}
public static void main(String[] args) {
new JmxClient().jmx()
}
}
