Springboot?MBean使用示例解析

更新時間：2023年06月14日 15:05:51 作者：SparkOnly

這篇文章主要為大家介紹了Springboot?MBean使用示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

正文

MBean，managed bean，被管理的bean，也就是一個被管理的Java對象。

它暴露了一個管理接口，可以包含以下內容：

一系列可讀或可寫的屬性
一系列可調用的操作
自我描述

SpringApplicationAdminMXBean

Springboot里默認有暴露出SpringApplicationAdminMXBean，通過源碼可以看出，是在afterPropertiesSet方法注冊了mbean，destroy方法取消注冊

@Override
public void afterPropertiesSet() throws Exception {
    MBeanServer server = ManagementFactory.getPlatformMBeanServer();
    server.registerMBean(new SpringApplicationAdmin(), this.objectName);
    if (logger.isDebugEnabled()) {
        logger.debug("Application Admin MBean registered with name '" + this.objectName + "'");
    }
}
@Override
public void destroy() throws Exception {
    ManagementFactory.getPlatformMBeanServer().unregisterMBean(this.objectName);
}

該bean本身暴露了兩個屬性(Ready, EmbeddedWebApplication)，兩個方法(getProperty, shutdown)

private class SpringApplicationAdmin implements SpringApplicationAdminMXBean {
        @Override
        public boolean isReady() {
            return SpringApplicationAdminMXBeanRegistrar.this.ready;
        }
        @Override
        public boolean isEmbeddedWebApplication() {
            return SpringApplicationAdminMXBeanRegistrar.this.embeddedWebApplication;
        }
        @Override
        public String getProperty(String key) {
            return SpringApplicationAdminMXBeanRegistrar.this.environment.getProperty(key);
        }
        @Override
        public void shutdown() {
            logger.info("Application shutdown requested.");
            SpringApplicationAdminMXBeanRegistrar.this.applicationContext.close();
        }
    }

通過jvisualvm，可以看到具體mbean的信息

jvisualvm-Admin

自己實現

我們自己也可以仿照Admin類，自己實現一個MBean

代碼如下，定義了一個MBean: cn.ye:type=Hello

public interface HelloMBean {
    public void sayHello();
    public int add(int x, int y);
    public String getName();
    public int getCacheSize();
    public void setCacheSize(int size);
}
public class Hello implements HelloMBean {
    private final String name = "Reginald";
    private int cacheSize = DEFAULT_CACHE_SIZE;
    private static final int DEFAULT_CACHE_SIZE = 200;
    @Override
    public void sayHello() {
        System.out.println("hello, world");
    }
    @Override
    public int add(int x, int y) {
        return x + y;
    }
    @Override
    public String getName() {
        return this.name;
    }
    @Override
    public int getCacheSize() {
        return this.cacheSize;
    }
    @Override
    public synchronized void setCacheSize(int size) {
        this.cacheSize = size;
        System.out.println("Cache size now " + this.cacheSize);
    }
}

啟動類里，注冊MBean

public class Application {
    public static void main(String[] args) throws MalformedObjectNameException, NotCompliantMBeanException, InstanceAlreadyExistsException, MBeanRegistrationException {
        SpringApplication.run(Application.class, args);
        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
        ObjectName name = new ObjectName("cn.ye:type=Hello");
        Hello mbean = new Hello();
        mbs.registerMBean(mbean, name);
    }
}

啟動jvisualvm，可以發(fā)現mbean已經注冊上去了

其中CacheSize可修改，Name只讀