利用JBossMX开发标准MBean(经典!转)

2023-10-19 13:32

本文主要是介绍利用JBossMX开发标准MBean(经典!转),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

原文(http://www.ebook520.com/showbooktext.asp?id=2090&backcolor=E7F4FE&backsize=15)  

JBoss 服务器是建立在 JBoss JMX 实现工具( JBossMX )基础上的,访问 JBoss 网站( http://www.jboss.org )可以下载到独立的 JBoss JMX 实现工具软件包 。将下载到的 jbossmx-1.1.2.zip 压缩包解压之后,把下列 jar 文件添加到 CLASSPATH 中:

jbossmx-1.1.2/jbossmx-1.1.2/lib/jboss-jmx.jar

jbossmx-1.1.2/jbossmx-1.1.2/lib/jboss-jmx-core.jar

JBOSS_HOME/client/gnu-regexp.jar

JBOSS_HOME/client/jbossall-client.jar

标准

MBean JBoss 中使用范围最广, JBoss 中的许多组件都是利用标准 MBean 开发的。

1 .计数器 MBean

下面是一个计数器 MBean 的开发示例。

1 )确定 MBean 的接口。

分析计数器的功能,确定了两个方法, add() get() add() 负责加数, get() 责加数并取回总数:

package com.liuyang.jmx.mbeans.counter;

public interface CounterMBean {

    public void add(int num);

    public int get(int num);   

}

从代码中可以看到,开发标准 MBean MBean 接口和开发普通接口除了需要在 MBean 类名称后面加上“ MBean ”之外,没有其他区别。

2 )实现 MBean 接口。

CounterMBean 是一个标准 MBean ,所以 MBean 实现类的名称必须和 MBean 接口 之间遵守标准 MBean 的命名规范,所以 CounterMBean 的实现类 Counter CounterMBean 少了尾部的 MBean 部分,下面是 Counter 的实现代码:

package com.liuyang.jmx.mbeans.counter;

public class Counter implements CounterMBean {

                    int sum = 0;

public void add(int num) {

sum+=num;

}

public int get(int num) {

sum+=num;

return sum;

}

}

从代码中也可以看到,标准 MBean 实现类与普通的 Java 程序也没什么区别。

3 )利用 JMX API 编写调用 CounterMBean 的程序。

JMX API Sun 公司为 JMX 技术所设计的一套用来开发 JMX 应用的编程接口,通过 JMX API 可以管理和控制前面开发的 CounterMBean 资源。下面是利用 JMX API 编写调用 CounterMBean 的程序代码:

package com.liuyang.jmx.mbeans.counter;

import javax.management.MBeanServer;

import javax.management.MBeanServerFactory;

import javax.management.ObjectName;

public class CounterServer {

     public static void main(String[] args) throws Exception {

MBeanServer server = MBeanServerFactory.createMBeanServer();

ObjectName name = new ObjectName("book.liuyang:service=Counter");

server.registerMBean(new Counter(), name);   

String[] sig1 = {"int"};

Object[] opArgs1 = {new Integer(3)};

Object result1 = server.invoke(name, "add", opArgs1, sig1);

System.out.println(result1);     

 

String[] sig2 = {"int"};

Object[] opArgs2 = {new Integer(0)};

Object result2 = server.invoke(name, "get", opArgs2, sig2);

System.out.println(result2);             

}

}

2 ObjectName

ObjectName 代表一个 MBean 对象的名,创建一个 ObjectName 需要符合 MBean 的命名规范,例如:

ObjectName name = new ObjectName("book.liuyang:service=Counter");

3 MBeanServer

CounterServer 程序中,首先创建的 MBeanServer 这个对象代表前文中介绍的 MBean 服务器,它负责管理 MBean 资源,每个 MBean 资源可以被注册到 MBeanServer 之中:

server.registerMBean(new Counter(), name);

通过 MBeanServer invoke 方法还可以调用一个 MBean ,在调用时需要传递一些与调用有关的参数:

Object result1 = server.invoke(name, "add", opArgs1, sig1);

其中:

name 是被调用对象的对象名。

"add" 要求 调用被调对象的方法名称。

opArgs1 是一个数组,包含着的每个数据将被作为参数传递到被调方法。

sig1 一个数组,包含着将被作为参数传递的每个数据的数据类型。

调用之后返回的对象包含着执行的结果。

4 MBeanServerFactory

MBeanServerFactory 是产生 MBeanServer 的工厂类,使用的 JMX 实现工具不同,通过 MBeanServerFactory 创建的 MBeanServer 实现对象也不同。如果 MBeanServer 已经被创建了,那么可以通过下面的方法获取:

MBeanServer server = MBeanServerFactory.newMBeanServer();

通过这个实例,可以了解到使用 MBeanServer 来控制 MBean 的基本方法,下面的 用户查询 MBean 将进一步介绍通过 MBeanServer MBean 的属性进行查询的方法。

5 .用户查询 MBean

首先,确定 MBean 的接口。

用户查询 MBean 中的用户是这个 MBean 所代表的对象,这个设计的用户包括名称和角色,在这个例子中将对这两个属性进行监控,这是 JMX 为开发者提供的一种机制,所有被管理的 MBean 都在 MBeanServer 的控制之中,这个控制不仅包括上个计数器实例中所演示的方法调用功能,也包含对这些 MBean 的相关信息进行考察的功能。

package com.liuyang.jmx.mbeans.user;

public interface UserMBean {

    public String getName();

    publicvoid setName(String name);

    public String getRole();

    public void setRole(String string);

}

UserMBean 中被设定了两个属性: name role ,并遵照 Java Bean 的规则为它们提供了 get() set() 方法。通过这两个方法可以设定 UserMBean 的两个属性。

package com.liuyang.jmx.mbeans.user;

public class User implements UserMBean  {

    private String name = "";

    private String password  = "";

    private String role  = "";

    public String getName() {

    return name;

    }

    publicvoid setName(String name) {

        this.name = name;

    }

public String getRole() {

return role;

}

public void setRole(String string) {

role = string;

}

}

User 这个类只是以最简单的方式实现了 UserMBean 接口。

UserQueries 演示了 通过 MBeanServer MBean 的属性进行查询的方法,代码如下:

package com.liuyang.jmx.mbeans.user;

import java.util.Iterator;

import java.util.Set;

import javax.management.Attribute;

import javax.management.MBeanServer;

import javax.management.MBeanServerFactory;

import javax.management.ObjectName;

import javax.management.Query;

import javax.management.QueryExp;

public class UserQueries {

  publicstaticvoid main(String[] args) throws Exception {

    MBeanServer server = MBeanServerFactory.createMBeanServer();

    ObjectName user1 = new ObjectName("book.liuyang:Name=user1");

    ObjectName user2 = new ObjectName("book.liuyang:Name=user2");

    server.createMBean("com.liuyang.jmx.mbeans.user.User", user1);

    server.createMBean("com.liuyang.jmx.mbeans.user.User", user2);

    server.setAttribute(user1, new Attribute("Name", "user1"));

    server.setAttribute(user2, new Attribute("Name", "user2"));

    server.setAttribute(user1, new Attribute("Role", "code"));

    server.setAttribute(user2, new Attribute("Role", "test"));

QueryExp exp = Query.match(Query.attr("Name"),Query.value("user1"));

ObjectName scope = new ObjectName("book.liuyang:*");   

Set set      = server.queryNames(scope, exp);   

Iterator it  = set.iterator();

System.out.println(" 下列 MBean 的名字是: user1");

while (it.hasNext()) {

  System.out.println(it.next());   

}

scope = new ObjectName("book.liuyang:*");   

exp = Query.initialSubString(Query.attr("Role"),Query.value("t"));

set   = server.queryNames(scope, exp);   

it    = set.iterator();

System.out.println(" 下列 MBean 的角色是: test");

while (it.hasNext()) {

  System.out.println(it.next());

}

}

}

UserQueries 中创建了两个 MBean 对象:

server.createMBean("com.liuyang.jmx.mbeans.user.User", user1);

这是 MBeanServer 通过 MBean 类的名称创建 MBean 实例的方法。

然后分别设置它们的属性:

server.setAttribute(user1, new Attribute("Name", "user1"));

一个 Attribute 对象代表一个属性。

JMX API 为查询服务建立标准的接口方法,第一步是建立查询表达式:

QueryExp exp = Query.match(Query.attr("Name"),Query.value("user1"));

这个查询表达式是以全匹配的方式进行的, JMX 还支持部分模糊查询的功能:

exp = Query.initialSubString(Query.attr("Role"),Query.value("t"));

initialSubString 建立的查询方法只会匹配名称的开始部分,在这里只要以“ t ”开头的值都会被匹配。

然后,通过一个 MBean 名称对象来代表查询范围:

ObjectName scope = new ObjectName("book.liuyang:*");

最后,通过 MBeanServer 执行查询表达式的操作,得到结果:

Set set = server.queryNames(scope, exp);  

运行 UserQueries 可以得到查询结果。

 

这篇关于利用JBossMX开发标准MBean(经典!转)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/240120

相关文章

SpringBoot开发中十大常见陷阱深度解析与避坑指南

《SpringBoot开发中十大常见陷阱深度解析与避坑指南》在SpringBoot的开发过程中,即使是经验丰富的开发者也难免会遇到各种棘手的问题,本文将针对SpringBoot开发中十大常见的“坑... 目录引言一、配置总出错?是不是同时用了.properties和.yml?二、换个位置配置就失效?搞清楚加

Python中对FFmpeg封装开发库FFmpy详解

《Python中对FFmpeg封装开发库FFmpy详解》:本文主要介绍Python中对FFmpeg封装开发库FFmpy,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录一、FFmpy简介与安装1.1 FFmpy概述1.2 安装方法二、FFmpy核心类与方法2.1 FF

基于Python开发Windows屏幕控制工具

《基于Python开发Windows屏幕控制工具》在数字化办公时代,屏幕管理已成为提升工作效率和保护眼睛健康的重要环节,本文将分享一个基于Python和PySide6开发的Windows屏幕控制工具,... 目录概述功能亮点界面展示实现步骤详解1. 环境准备2. 亮度控制模块3. 息屏功能实现4. 息屏时间

Python实例题之pygame开发打飞机游戏实例代码

《Python实例题之pygame开发打飞机游戏实例代码》对于python的学习者,能够写出一个飞机大战的程序代码,是不是感觉到非常的开心,:本文主要介绍Python实例题之pygame开发打飞机... 目录题目pygame-aircraft-game使用 Pygame 开发的打飞机游戏脚本代码解释初始化部

使用Python开发一个现代化屏幕取色器

《使用Python开发一个现代化屏幕取色器》在UI设计、网页开发等场景中,颜色拾取是高频需求,:本文主要介绍如何使用Python开发一个现代化屏幕取色器,有需要的小伙伴可以参考一下... 目录一、项目概述二、核心功能解析2.1 实时颜色追踪2.2 智能颜色显示三、效果展示四、实现步骤详解4.1 环境配置4.

Python使用smtplib库开发一个邮件自动发送工具

《Python使用smtplib库开发一个邮件自动发送工具》在现代软件开发中,自动化邮件发送是一个非常实用的功能,无论是系统通知、营销邮件、还是日常工作报告,Python的smtplib库都能帮助我们... 目录代码实现与知识点解析1. 导入必要的库2. 配置邮件服务器参数3. 创建邮件发送类4. 实现邮件

基于Python开发一个有趣的工作时长计算器

《基于Python开发一个有趣的工作时长计算器》随着远程办公和弹性工作制的兴起,个人及团队对于工作时长的准确统计需求日益增长,本文将使用Python和PyQt5打造一个工作时长计算器,感兴趣的小伙伴可... 目录概述功能介绍界面展示php软件使用步骤说明代码详解1.窗口初始化与布局2.工作时长计算核心逻辑3

python web 开发之Flask中间件与请求处理钩子的最佳实践

《pythonweb开发之Flask中间件与请求处理钩子的最佳实践》Flask作为轻量级Web框架,提供了灵活的请求处理机制,中间件和请求钩子允许开发者在请求处理的不同阶段插入自定义逻辑,实现诸如... 目录Flask中间件与请求处理钩子完全指南1. 引言2. 请求处理生命周期概述3. 请求钩子详解3.1

如何基于Python开发一个微信自动化工具

《如何基于Python开发一个微信自动化工具》在当今数字化办公场景中,自动化工具已成为提升工作效率的利器,本文将深入剖析一个基于Python的微信自动化工具开发全过程,有需要的小伙伴可以了解下... 目录概述功能全景1. 核心功能模块2. 特色功能效果展示1. 主界面概览2. 定时任务配置3. 操作日志演示

go rate 原生标准限速库的使用

《gorate原生标准限速库的使用》本文主要介绍了Go标准库golang.org/x/time/rate实现限流,采用令牌桶算法控制请求速率,提供Allow/Reserve/Wait方法,具有一定... 目录介绍安装API介绍rate.NewLimiter:创建限流器limiter.Allow():请求是否