Java 参考
JMX 消息协议 (JMXMP) 连接器是通用连接器的配置,其中传输协议基于 TCP,对象包装是本机 Java 序列化。安全性比 RMI 连接器更先进。安全性基于 Java 安全套接字扩展 (JSSE)、Java 身份验证和授权服务 (JAAS) 以及简单身份验证和安全层 (SASL)。
通用连接器及其 JMXMP 配置是可选的,这意味着它们并不总是包含在 JMX Remote API 的实现中。J2SE 平台不包括可选的通用连接器。
注 – 如果您想使用 JMXMP 连接器,请从http://java.sun.com/products/JavaManagement/download.html下载 JSR 160 参考实现,并将 jmxremote_optional.jar 文件添加到您的类路径中。
jmxremote_optional.jar
您是否在服务器和客户端类路径中包含文件?
我没有使用 JMXMP 连接器方法的经验,我遵循 JMX 文档并尝试通过编写以下示例进行验证,它可以工作。
JMX MBean 接口
SystemConfigMBean.java
package jmx.learning;
public interface SystemConfigMBean {
public void setThreadCount(int noOfThreads);
public int getThreadCount();
public void setSchemaName(String schemaName);
public String getSchemaName();
// any method starting with get and set are considered
// as attributes getter and setter methods, so I am
// using do* for operation.
public String doConfig();
}
一个实现 JMX MBean 接口的类
SystemConfig.java
package jmx.learning;
public class SystemConfig implements SystemConfigMBean {
private int threadCount;
private String schemaName;
public SystemConfig(int numThreads, String schema){
this.threadCount=numThreads;
this.schemaName=schema;
}
@Override
public void setThreadCount(int noOfThreads) {
this.threadCount=noOfThreads;
}
@Override
public int getThreadCount() {
return this.threadCount;
}
@Override
public void setSchemaName(String schemaName) {
this.schemaName=schemaName;
}
@Override
public String getSchemaName() {
return this.schemaName;
}
@Override
public String doConfig(){
return "No of Threads="+this.threadCount+" and DB Schema Name="+this.schemaName;
}
}
使用 JMXMP 连接器在 MBean 服务器中创建和注册 MBean
系统配置管理.java
package jmx.learning;
import java.io.IOException;
import javax.management.InstanceAlreadyExistsException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.MalformedObjectNameException;
import javax.management.NotCompliantMBeanException;
import javax.management.ObjectName;
import javax.management.remote.JMXConnectorServer;
import javax.management.remote.JMXConnectorServerFactory;
import javax.management.remote.JMXServiceURL;
public class SystemConfigManagement {
private static final int DEFAULT_NO_THREADS = 10;
private static final String DEFAULT_SCHEMA = "default";
public static void main(String[] args) throws MalformedObjectNameException,
InterruptedException, InstanceAlreadyExistsException,
MBeanRegistrationException, NotCompliantMBeanException, IOException {
// Instantiate the MBean server
MBeanServer mbs = MBeanServerFactory.createMBeanServer();
// Create a JMXMP connector server
JMXServiceURL url = new JMXServiceURL("jmxmp", null, 5555);
JMXConnectorServer cs = JMXConnectorServerFactory
.newJMXConnectorServer(url, null, mbs);
cs.start();
// register the MBean
SystemConfig mBean = new SystemConfig(DEFAULT_NO_THREADS,
DEFAULT_SCHEMA);
ObjectName name = new ObjectName("jmx.learning:type=SystemConfig");
mbs.registerMBean(mBean, name);
do {
Thread.sleep(3000);
System.out.println("Thread Count=" + mBean.getThreadCount()
+ " Schema Name=" + mBean.getSchemaName());
} while (mBean.getThreadCount() != 0);
}
}
JMXMP 连接器客户端
SystemConfigManagementClient.java
package jmx.learning;
import java.io.IOException;
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 SystemConfigManagementClient {
public static void main(String[] args) {
JMXConnector jmxc = null;
try {
// Create a JMXMP connector client
System.out.println("\nCreate a JMXMP connector client");
JMXServiceURL url = new JMXServiceURL(
"service:jmx:jmxmp://localhost:5555");
jmxc = JMXConnectorFactory.connect(url, null);
// get MBeanServerConnection
MBeanServerConnection serverConn = jmxc.getMBeanServerConnection();
ObjectName objectName = new ObjectName(
"jmx.learning:type=SystemConfig");
// Executing doConfig() method
String value = (String) serverConn.invoke(objectName, "doConfig",
new Object[] {}, new String[] {});
System.out.println(value);
} catch (Exception e) {
e.printStackTrace();
} finally {
if (jmxc != null) {
try {
jmxc.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
注意:我已经下载jmxremote_optional.jar
了文件并保存在项目类路径中。
执行:
服务器输出:
d:\Java\jdk1.8.0_261\bin\java.exe -cp .;d:\External_Library\jmxremote_optional.jar jmx.learning.SystemConfigManagement
Thread Count=10 Schema Name=default
Thread Count=10 Schema Name=default
客户端输出:
d:\Java\jdk1.8.0_261\bin\java.exe -cp .;d:\External_Library\jmxremote_optional.jar jmx.learning.SystemConfigManagementClient
Create a JMXMP connector client
No of Threads=10 and DB Schema Name=default
我不确定您编写的服务器代码,看起来该代码需要 RMIConnector。因此,从客户端使用 RMI 连接器 Java 远程方法协议 (JRMP) 的连接尝试正在工作。
即使你已经通过了属性-Dcom.sun.management.jmxremote.port=portNum
这个属性表明,portNum 是你想要通过它来启用 JMX RMI 连接的端口号。
注意:出于演示目的,我没有在实际代码中展示安全处理的东西,这些东西需要到位。