JMX RMI简介

2024-09-01 00:58
文章标签 简介 jmx rmi

本文主要是介绍JMX RMI简介，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

连接器概念：

JMX规范定义了连接器的概念(Connectors),连接器位于JMX的3层构架中的分布式服务层。连接器负责建立MBean服务器和管理应用之间的通信。连接器由一个驻留在代理层的连接器服务器(connector server)和管理应用的连接器客户端(connector client)构成。连接器服务端(connector server)连接到MBean服务器并监听来自客户端(connector client)的请求。一个connector client负责与connector server建立连接。connnector client通常与connector server在不同的JVM里并且通常运行在不同的机器上。


1.连接器类型(Connector type)

connnector client通过给定协议与connector server建立连接，远程访问MBean服务器。JMX API允许使用不同类型的连接器来连接MBean服务器。
* JMX API定义了一个标准连接器 - RMI Connector,它支持通过RMI协议远程访问一个MBeanServer
* JMX API定义了一个可选的连接器 - JMXMP Connector.它实现了JMXMP协议(JMX Message Protocol).作为一个可选连接器，它不集成在JavaSE平台中，若需要，从Sun官方      下载jar
* 用户自定义连接器协议


2.连接器服务器地址

通常，一个connector server有一个地址，由类JMXServiceURL表示，这个类的实例是不可变的。使用不同的连接器，会有不同的JMXServiceURL编写方式。
格式看起来如下：
service:jmx:protocol:sap
说明：
service:jmx: 这个是JMX URL的标准前缀，所有的JMX URL都必须以该字符串开头。
protocol是指定连接连接器服务器(connector server)的传输协议
方括号中的部分为可选部分
sap是连接器服务器的地址，sap的语法格式：//[host[:port]][url-path]
host表示主机名，port是十进制的端口号
host和port可以省略，但没有host时，不能出现port
url-path 开始于一个"/"符号
参考JMX API : http://docs.Oracle.com/javase/8/docs/api/index.html?javax/management/remote/rmi/package-summary.html

参考：http://www.l99.com/EditText_view.action?textId=480750


3. RMI连接器

JMX API定义了一个标准连接器 - RMI Connector,它支持通过RMI远程访问一个MBeanServer

RMI连接器服务器的地址示例如下：
service:jmx:rmi://localhost:1099/jndi/rmi://localhost:8899/myname
说明：
在这个JMXServiceURL中，第一个rmi指的是rmi连接器，表示用连接器使用RMI传输协议，第二个rmi指定RMI注册RMI连服务接器存储存根
localhost:1099: 这个是connector server的IP和端口，该部分是一个可选项，可以被省略掉。如果省略的话，则connector server会随机任意选择一个可用的端口
/jndi/rmi://localhost:8899/myname: 这个是connector server的路径，表示Connector server的stud是使用JNDI API绑定在rmi://localhost:8899/myname这个地址上

创建一个RMI connector server

通常是提供一个RMI connector server的连接器地址，用JMXConnectorServerFactory.newJMXConnectorServer方法来创建RMI connector cerver

参考JMX API：http://docs.oracle.com/javase/8/docs/api/index.html?javax/management/remote/rmi/package-summary.html


下面是使用RMI连接器远程管理程序的例子：

Step 1.MBean接口定义

[java] view plain copy print?
  1. package com.jmx.demo9;  
  2.   
  3. import java.io.Serializable;  
  4.   
  5. public interface HelloMBean extends Serializable {  
  6.     public void setName(String name);  
  7.   
  8.     public String getName();  
  9.   
  10.     public void sayHello();  
  11.   
  12. }  
package com.jmx.demo9;import java.io.Serializable;public interface HelloMBean extends Serializable {public void setName(String name);public String getName();public void sayHello();}

Step 2.MBean接口实现类
[java] view plain copy print?
  1. package com.jmx.demo9;  
  2.   
  3. import java.io.Serializable;  
  4.   
  5. public class Hello implements HelloMBean, Serializable {  
  6.   
  7.     private String name;  
  8.   
  9.     public synchronized void setName(String name) {  
  10.         this.name = name;  
  11.     }  
  12.   
  13.     public synchronized String getName() {  
  14.         return name;  
  15.     }  
  16.   
  17.     public synchronized void sayHello() {  
  18.         System.out.println("Hello," + name);  
  19.     }  
  20.   
  21. }  
package com.jmx.demo9;import java.io.Serializable;public class Hello implements HelloMBean, Serializable {private String name;public synchronized void setName(String name) {this.name = name;}public synchronized String getName() {return name;}public synchronized void sayHello() {System.out.println("Hello," + name);}}

Step 3.服务端
[java] view plain copy print?
  1. package com.jmx.demo9;  
  2.   
  3. import java.rmi.registry.LocateRegistry;  
  4. import java.util.HashMap;  
  5.   
  6. import javax.management.MBeanServer;  
  7. import javax.management.MBeanServerFactory;  
  8. import javax.management.ObjectInstance;  
  9. import javax.management.ObjectName;  
  10. import javax.management.remote.JMXAuthenticator;  
  11. import javax.management.remote.JMXConnectorServer;  
  12. import javax.management.remote.JMXConnectorServerFactory;  
  13. import javax.management.remote.JMXServiceURL;  
  14. import javax.security.auth.Subject;  
  15.   
  16. public class JMXAgent {  
  17.     /** 
  18.      * @param args 
  19.      *            the command line arguments 
  20.      */  
  21.     public static void main(String[] args) throws Exception {  
  22.         System.out.println("--------------JMX Agent----------- ");  
  23.         LocateRegistry.createRegistry(1099);  
  24.         MBeanServer server = MBeanServerFactory.createMBeanServer();  
  25.         ObjectName helloName = new ObjectName("com.jmx.demo9:name=Hello");  
  26.         Hello hello = new Hello();  
  27.         HashMap<String, Object> prop = new HashMap<String, Object>();  
  28.         prop.put(JMXConnectorServer.AUTHENTICATOR, new JMXAuthenticator() {  
  29.             public Subject authenticate(Object credentials) {  
  30.                 if (credentials instanceof String) {  
  31.                     if (credentials.equals("Hello")) {  
  32.                         return new Subject();  
  33.                     }  
  34.                 }  
  35.                 throw new SecurityException("not authicated");  
  36.             }  
  37.         });  
  38.         JMXConnectorServer cserver = JMXConnectorServerFactory  
  39.                 .newJMXConnectorServer(new JMXServiceURL(  
  40.                         "service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi"),  
  41.                         prop, server);  
  42.         cserver.start();  
  43.         server.registerMBean(hello, helloName);  
  44.         for (ObjectInstance object : server.queryMBeans(null, null)) {  
  45.             System.out.println(object.getObjectName());  
  46.         }  
  47.         System.out.println(hello);  
  48.         System.out.println("start.....");  
  49.         System.out.println("\n");  
  50.     }  
  51. }  
package com.jmx.demo9;import java.rmi.registry.LocateRegistry;
import java.util.HashMap;import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.ObjectInstance;
import javax.management.ObjectName;
import javax.management.remote.JMXAuthenticator;
import javax.management.remote.JMXConnectorServer;
import javax.management.remote.JMXConnectorServerFactory;
import javax.management.remote.JMXServiceURL;
import javax.security.auth.Subject;public class JMXAgent {/*** @param args*            the command line arguments*/public static void main(String[] args) throws Exception {System.out.println("--------------JMX Agent----------- ");LocateRegistry.createRegistry(1099);MBeanServer server = MBeanServerFactory.createMBeanServer();ObjectName helloName = new ObjectName("com.jmx.demo9:name=Hello");Hello hello = new Hello();HashMap<String, Object> prop = new HashMap<String, Object>();prop.put(JMXConnectorServer.AUTHENTICATOR, new JMXAuthenticator() {public Subject authenticate(Object credentials) {if (credentials instanceof String) {if (credentials.equals("Hello")) {return new Subject();}}throw new SecurityException("not authicated");}});JMXConnectorServer cserver = JMXConnectorServerFactory.newJMXConnectorServer(new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi"),prop, server);cserver.start();server.registerMBean(hello, helloName);for (ObjectInstance object : server.queryMBeans(null, null)) {System.out.println(object.getObjectName());}System.out.println(hello);System.out.println("start.....");System.out.println("\n");}
}

note:ObjectName对象标识符命名规则参考JMX API:http://docs.oracle.com/javase/8/docs/api/javax/management/ObjectName.html

Step 4.客户端(管理应用程序)

[java] view plain copy print?
  1. package com.jmx.demo9;  
  2.   
  3. import java.util.HashMap;  
  4.   
  5. import javax.management.JMX;  
  6. import javax.management.MBeanServerConnection;  
  7. import javax.management.ObjectName;  
  8. import javax.management.remote.JMXConnector;  
  9. import javax.management.remote.JMXConnectorFactory;  
  10. import javax.management.remote.JMXServiceURL;  
  11.   
  12. public class Client {  
  13.   
  14.     public static void main(String[] args) throws Exception {  
  15.           
  16.         HashMap<String, Object> prop = new HashMap<String, Object>();  
  17.         prop.put(JMXConnector.CREDENTIALS, "Hello");  
  18.         JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi");  
  19.         JMXConnector conn = JMXConnectorFactory.connect(url, prop);  
  20.         MBeanServerConnection mbsc = conn.getMBeanServerConnection();  
  21.         ObjectName mbeanName = new ObjectName("com.jmx.demo9:name=Hello");  
  22.         HelloMBean hello = JMX.newMBeanProxy(mbsc, mbeanName,HelloMBean.class);  
  23.         hello.setName("World!");  
  24.         hello.sayHello();  
  25.   
  26.     }  
  27. }  
package com.jmx.demo9;import java.util.HashMap;import javax.management.JMX;
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) throws Exception {HashMap<String, Object> prop = new HashMap<String, Object>();prop.put(JMXConnector.CREDENTIALS, "Hello");JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi");JMXConnector conn = JMXConnectorFactory.connect(url, prop);MBeanServerConnection mbsc = conn.getMBeanServerConnection();ObjectName mbeanName = new ObjectName("com.jmx.demo9:name=Hello");HelloMBean hello = JMX.newMBeanProxy(mbsc, mbeanName,HelloMBean.class);hello.setName("World!");hello.sayHello();}
}

测试结果：

先启动JMXAgent,在启动Client

[java] view plain copy print?
  1. --------------JMX Agent-----------   
  2. JMImplementation:type=MBeanServerDelegate  
  3. com.jmx.demo9:name=Hello  
  4. com.jmx.demo9.Hello@47eaec  
  5. start.....  
  6.   
  7.   
  8. Hello,world  
--------------JMX Agent----------- 
JMImplementation:type=MBeanServerDelegate
com.jmx.demo9:name=Hello
com.jmx.demo9.Hello@47eaec
start.....Hello,world

转载自：http://blog.csdn.net/java_huashan/article/details/36199603


这篇关于JMX RMI简介的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1125496。

相关文章

ASIO网络调试助手之一：简介

ASIO网络调试助手之一：简介

多年前，写过几篇《Boost.Asio C++网络编程》的学习文章，一直没机会实践。最近项目中用到了Asio，于是抽空写了个网络调试助手。 开发环境： Win10 Qt5.12.6 + Asio(standalone) + spdlog 支持协议： UDP + TCP Client + TCP Server 独立的Asio（http://www.think-async.com）只包含了头文件，不依
阅读更多...
业务协同平台--简介

业务协同平台--简介

一、使用场景         1.多个系统统一在业务协同平台定义协同策略，由业务协同平台代替人工完成一系列的单据录入         2.同时业务协同平台将执行任务推送给pda、pad等执行终端，通知各人员、设备进行作业执行         3.作业过程中，可设置完成时间预警、作业节点通知，时刻了解作业进程         4.做完再给你做过程分析，给出优化建议         就问你这一套下
阅读更多...
容器编排平台Kubernetes简介

容器编排平台Kubernetes简介

目录 什么是K8s 为什么需要K8s 什么是容器(Contianer) K8s能做什么？ K8s的架构原理  控制平面(Control plane)         kube-apiserver         etcd         kube-scheduler         kube-controller-manager         cloud-controlle
阅读更多...
【Tools】AutoML简介

【Tools】AutoML简介

摇来摇去摇碎点点的金黄 伸手牵来一片梦的霞光 南方的小巷推开多情的门窗 年轻和我们歌唱 摇来摇去摇着温柔的阳光 轻轻托起一件梦的衣裳 古老的都市每天都改变模样                      🎵 方芳《摇太阳》 AutoML（自动机器学习）是一种使用机器学习技术来自动化机器学习任务的方法。在大模型中的AutoML是指在大型数据集上使用自动化机器学习技术进行模型训练和优化。
阅读更多...
SaaS、PaaS、IaaS简介

SaaS、PaaS、IaaS简介

云计算、云服务、云平台……现在“云”已成了一个家喻户晓的概念，但PaaS, IaaS 和SaaS的区别估计还没有那么多的人分得清，下面就分别向大家普及一下它们的基本概念： SaaS 软件即服务 SaaS是Software-as-a-Service的简称，意思是软件即服务。随着互联网技术的发展和应用软件的成熟， 在21世纪开始兴起的一种完全创新的软件应用模式。 它是一种通过Internet提供
阅读更多...
LIBSVM简介

LIBSVM简介

LIBSVM简介 支持向量机所涉及到的数学知识对一般的化学研究者来说是比较难的，自己编程实现该算法难度就更大了。但是现在的网络资源非常发达，而且国际上的科学研究者把他们的研究成果已经放在网络上，免费提供给用于研究目的，这样方便大多数的研究者，不必要花费大量的时间理解SVM算法的深奥数学原理和计算机程序设计。目前有关SVM计算的相关软件有很多，如LIBSVM、mySVM、SVMLight等，这些
阅读更多...
urllib与requests爬虫简介

urllib与requests爬虫简介

urllib与requests爬虫简介 – 潘登同学的爬虫笔记 文章目录 urllib与requests爬虫简介 -- 潘登同学的爬虫笔记第一个爬虫程序 urllib的基本使用Request对象的使用urllib发送get请求实战-喜马拉雅网站 urllib发送post请求 动态页面获取数据请求 SSL证书验证伪装自己的爬虫-请求头 urllib的底层原理伪装自己的爬虫-设置代理爬虫coo
阅读更多...
新一代车载(E/E)架构下的中央计算载体---HPC软件架构简介

新一代车载(E/E)架构下的中央计算载体---HPC软件架构简介

老规矩，分享一段喜欢的文字，避免自己成为高知识低文化的工程师： 屏蔽力是信息过载时代一个人的特殊竞争力，任何消耗你的人和事，多看一眼都是你的不对。非必要不费力证明自己，无利益不试图说服别人，是精神上的节能减排。 无人问津也好,技不如人也罢,你都要试着安静下来,去做自己该做的事.而不是让内心的烦躁、焦虑、毁掉你本就不多的热情和定力。 时间不知不觉中，快要来到夏末秋初。一年又过去了一大半，成
阅读更多...
AI学习指南深度学习篇-带动量的随机梯度下降法简介

AI学习指南深度学习篇-带动量的随机梯度下降法简介

AI学习指南深度学习篇 - 带动量的随机梯度下降法简介 引言 在深度学习的广阔领域中，优化算法扮演着至关重要的角色。它们不仅决定了模型训练的效率，还直接影响到模型的最终表现之一。随着神经网络模型的不断深化和复杂化，传统的优化算法在许多领域逐渐暴露出其不足之处。带动量的随机梯度下降法（Momentum SGD）应运而生，并被广泛应用于各类深度学习模型中。 在本篇文章中，我们将深入探讨带动量的随
阅读更多...
OpenGL ES学习总结：基础知识简介

OpenGL ES学习总结：基础知识简介

什么是OpenGL ES? OpenGL ES (为OpenGL for Embedded System的缩写） 为适用于嵌入式系统的一个免费二维和三维图形库。 为桌面版本OpenGL 的一个子集。 OpenGL ES管道(Pipeline) OpenGL ES 1.x 的工序是固定的，称为Fix-Function Pipeline,可以想象一个带有很多控制开关的机器，尽管加工
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2