static JmxConnector init(Properties props) throws IOException { Integer port = Integer.decode(props.getProperty(JMXEndpoint.JMX_RMI_PORT_PROPERTY)); if (!JmxConnectors.isPortAvailable(port)) return null; String name = "com.devexperts.qd.monitoring:type=RmiServer,port=" + port; RMIJRMPServerImpl srvImpl = new RMIJRMPServerImpl(port, null, null, null); RMIConnectorServer rmiServer = new RMIConnectorServer( new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:" + port + "/jmxrmi"), null, srvImpl, ManagementFactory.getPlatformMBeanServer()); ConnectorImpl connector = new ConnectorImpl(name, rmiServer); if (!JmxConnectors.addConnector(port, connector)) return null; // port is already taken LocateRegistry.createRegistry(port); connector.setRegistration(Management.registerMBean(rmiServer, null, name)); rmiServer.start(); QDLog.log.info("RMI management port is " + port); return connector; }
public static void main(String[] args) throws Exception { // Create RMIJRMPServerImpl // System.out.println("Create RMIJRMPServerImpl"); RMIServer server = new RMIJRMPServerImpl(0, null, null, null); // Get the JMX Remote impl version from RMIServer // System.out.println("Get JMX Remote implementation version from RMIServer"); String full_version = server.getVersion(); System.out.println("RMIServer.getVersion() = "+ full_version); String impl_version = full_version.substring( full_version.indexOf("java_runtime_")+"java_runtime_".length()); // Display JMX Remote impl version and Java Runtime version // System.out.println("JMX Remote implementation version = " + impl_version); System.out.println("Java Runtime implementation version = " + args[0]); // Check JMX Remote impl version vs. Java Runtime version // if (!impl_version.equals(args[0])) { // Test FAILED throw new IllegalArgumentException( "***FAILED: JMX Remote and Java Runtime versions do NOT match***"); } // Test OK! System.out.println("JMX Remote and Java Runtime versions match."); System.out.println("Bye! Bye!"); }
public void testSslStub() throws Exception { File keyStoreFile = File.createTempFile("keystore", "ks"); keyStoreFile.deleteOnExit(); decodeHexToFile(keyStoreFile, keyStoreHex); System.setProperty("javax.net.ssl.keyStore", keyStoreFile.getAbsolutePath()); System.setProperty("javax.net.ssl.keyStorePassword", "password"); File trustStoreFile = File.createTempFile("truststore", "ks"); trustStoreFile.deleteOnExit(); decodeHexToFile(trustStoreFile, trustStoreHex); System.setProperty("javax.net.ssl.trustStore", trustStoreFile.getAbsolutePath()); System.setProperty("javax.net.ssl.trustStorePassword", "trustword"); // System.setProperty("javax.net.debug", "all"); RMIClientSocketFactory csf = new SslRMIClientSocketFactory(); RMIServerSocketFactory ssf = new SslRMIServerSocketFactory(); Registry reg = LocateRegistry.createRegistry(0, csf, ssf); int port = getRegistryPort(reg); System.out.println("Port is " + port); // Server Map<String, Object> env = new HashMap<String, Object>(); env.put(RMIConnectorServer.RMI_CLIENT_SOCKET_FACTORY_ATTRIBUTE, csf); env.put(RMIConnectorServer.RMI_SERVER_SOCKET_FACTORY_ATTRIBUTE, ssf); MBeanServer mbs = ManagementFactory.getPlatformMBeanServer(); JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///"); RMIServerImpl rmiServerImpl = new RMIJRMPServerImpl(port, csf, ssf, null); RMIConnectorServer cs = new RMIConnectorServer(url, null, rmiServerImpl, mbs); cs.start(); reg.bind("jmxrmi", rmiServerImpl); // Client Registry creg = LocateRegistry.getRegistry( InetAddress.getLocalHost().getHostAddress(), port, csf); RMIServer rmiServerStub = (RMIServer) creg.lookup("jmxrmi"); assertEquals(RMIServerImpl_Stub.class, rmiServerStub.getClass()); SObject sstub = (SObject) SerialScan.examine(rmiServerStub); List<SEntity> annots = sstub.getAnnotations(); /* The annotations consist of the data written for a UnicastRef2 * before the client socket factory; the client socket factory; * and the data written after the factory. */ assertEquals(3, annots.size()); SObject factory = (SObject) annots.get(1); assertEquals(SslRMIClientSocketFactory.class.getName(), factory.getType()); }
