0

私たちのアーキテクチャには、いくつかのサーバー側コンポーネントがあります。各コンポーネントは、JMX を使用してさまざまな内部属性を公開します。初期化は次のように行われます。

try {       
        Registry registry = null;
        for(int i = _serverInfo.getJMXStartPort(); i <= _serverInfo.getJMXEndPort(); i++) {         
            try {
                registry = LocateRegistry.createRegistry(i);
                if(registry != null) {
                    _statusPort = i;
                    logger.info("Using JMX port: "+_statusPort);
                    break;
                }
            } catch (Exception e) {
                _statusPort++;
            }
        }                               

        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();

        _abstractServiceController = new AbstractServiceController(this);
        ObjectName mbeanName = new ObjectName("MyServer:name=MyServer Service");

        mbs.registerMBean(_abstractServiceController, mbeanName);

        JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://:"+_statusPort+"/jmxrmi");
        JMXConnectorServer cs = JMXConnectorServerFactory.newJMXConnectorServer(url, System.getenv(), mbs);
        cs.start();

    } catch (Throwable e) {
        logger.error("Unable to register MBean with JMX");
        e.printStackTrace();
    }

2つの質問があると思います。

  1. これは正しく見えますか?

  2. より大きな問題は、これは Java 1.6 では正常に動作しますが (ポートが使用できない場合は LocateRegistry.createRegistry(i) が例外をスローするため、ホスト上の後続の各サーバーは次に使用可能なポートを使用します)、1.7 ではそうではありません。その結果、2 番目のサーバーが JMXConnectorServer.start() を試行すると、次の例外が発生します。createRegistry の動作が変更されたかどうかは誰にもわかりますか? もしそうなら、私たちがすべきことは他にありますか?

    2013-02-07 15:34:28,451 INFO  [main] Using JMX port: 9500
    2013-02-07 15:34:28,929 ERROR [main] Unable to register MBean with JMX
    java.io.IOException: Cannot bind to URL [rmi://:9500/jmxrmi]: javax.naming.NameAlreadyBoundException: jmxrmi [Root exception is java.rmi.AlreadyBoundException: jmxrmi]
            at javax.management.remote.rmi.RMIConnectorServer.newIOException(RMIConnectorServe.java:826)
    at javax.management.remote.rmi.RMIConnectorServer.start(RMIConnectorServer.java:431)
    at com.theatre.services.framework.AbstractService.run(AbstractService.java:306)
    at com.theatre.services.reporttree.TreeServerImpl.run(TreeServerImpl.java:690)
    at com.theatre.services.framework.Launcher.main(Launcher.java:99)
    Caused by: javax.naming.NameAlreadyBoundException: jmxrmi [Root exception is java.rmi.AlreadyBoundException: jmxrmi]
    at com.sun.jndi.rmi.registry.RegistryContext.bind(RegistryContext.java:139)
    at com.sun.jndi.toolkit.url.GenericURLContext.bind(GenericURLContext.java:226)
    at javax.naming.InitialContext.bind(InitialContext.java:419)
    at javax.management.remote.rmi.RMIConnectorServer.bind(RMIConnectorServer.java:643)
    at javax.management.remote.rmi.RMIConnectorServer.start(RMIConnectorServer.java:426)
    ... 3 more
    Caused by: java.rmi.AlreadyBoundException: jmxrmi
    at sun.rmi.registry.RegistryImpl.bind(RegistryImpl.java:131)
    at sun.rmi.registry.RegistryImpl_Skel.dispatch(Unknown Source)
    at sun.rmi.server.UnicastServerRef.oldDispatch(UnicastServerRef.java:390)
    at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:248)
    at sun.rmi.transport.Transport$1.run(Transport.java:159)
    at java.security.AccessController.doPrivileged(Native Method)
    at sun.rmi.transport.Transport.serviceCall(Transport.java:155)
    at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:535)
    at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:790)
    at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:649)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
    at sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteCall.java:273)
    at sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:251)
    at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:377)
    at sun.rmi.registry.RegistryImpl_Stub.bind(Unknown Source)
    at com.sun.jndi.rmi.registry.RegistryContext.bind(RegistryContext.java:137)
    ... 7 more
    
4

1 に答える 1

0

これは正しく見えますか?

  • いいえ。レジストリの作成は、ポートが使用されているという理由だけでなく、いくつかの理由で失敗する可能性があります。
  • registryの後で null にすることはできないcreateRegistry()ため、テストしても意味がありません。
  • 空いているポートを見つけようとしている場合ServerSocket(). それが機能した場合は、そのポートにレジストリを作成します。

より大きな問題は、これは Java 1.6 では正常に動作しますが (ポートが使用できない場合は LocateRegistry.createRegistry(i) が例外をスローするため、ホスト上の後続の各サーバーは次に使用可能なポートを使用します)、1.7 ではそうではありません。

上記を参照。任意の JDK で、そのポートで既に実行されているレジストリがある場合、レジストリの作成も失敗する可能性があります。以前の JDK では、同じ JVM のいずれかのポートで実行されているものがあると失敗していました。

于 2013-02-08T00:34:32.293 に答える