JMX コネクタ

ここには示していませんが、呼び出しが行われるのは、mbeanObjectName MBean のコンストラクタ、操作、および通知に関する情報を取得するためです。

[...] 
 
private static void manageSimpleMBean(MBeanServer mbs, 
                                        ObjectName mbeanObjectName, 
                                        String mbeanClassName) { 
        try { 
            printSimpleAttributes(mbs, mbeanObjectName); 
 
            Attribute stateAttribute = new Attribute("State", 
                                                     "new state"); 
            mbs.setAttribute(mbeanObjectName, stateAttribute); 
 
            printSimpleAttributes(mbs, mbeanObjectName); 
	     
            echo("\n    Invoking reset operation..."); 
            mbs.invoke(mbeanObjectName, "reset", null, null); 
 
            printSimpleAttributes(mbs, mbeanObjectName); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 
 
    private static void printSimpleAttributes( 
                                        MBeanServer mbs, 
                                        ObjectName mbeanObjectName) { 
        try { 
            String State =  
               (String) mbs.getAttribute(mbeanObjectName, "State"); 
            Integer NbChanges = 
               (Integer) mbs.getAttribute(mbeanObjectName, 
                                          "NbChanges"); 
        } catch (Exception e) { 
            echo(	"!!! Could not read attributes !!!"); 
            e.printStackTrace(); 
        } 
   } 
 
[...]

コード例 3-5 は簡単な MBean を管理するための方法を示しています。

まず、manageSimpleMBean() メソッドが、Server でも定義される printSimpleAttributes() メソッドを呼び出します。

printSimpleAttributes() メソッドは、MBean mbeanObjectName から state という MBean 属性と、NbChanges というもう 1 つの MBean 属性を取得します。これらの属性はいずれも、「3.1.1.3 SimpleStandard.java」に示すように、SimpleStandard クラスで定義されます。


最後に MBeanServer の invoke() メソッドに呼び出すことで、mbeanObjectName MBean の reset 操作が起動します。reset

操作は、SimpleStandard クラスで定義されます。

3.1.1.2 SimpleStandardMBean.java

SimpleStandardMBean.java クラスは、MBean SimpleStandard の簡単な JMX 仕様の管理インタフェースです。このインタフェースは、JMX エージェントからの管理のために SimpleStandard で定義された 4 つの操作を公開します。

3.1.1.3 SimpleStandard.java

 
public class SimpleStandard 
    extends NotificationBroadcasterSupport 
    implements SimpleStandardMBean { 
    public String getState() { 
       return state; 
    } 
    public void setState(String s) { 
       state = s; 
       nbChanges++; 
    } 
     
    public int getNbChanges() { 
        return nbChanges; 
    } 
     
    public void reset() { 
       AttributeChangeNotification acn =  
           new AttributeChangeNotification(this, 
                                          0, 
                                          0, 
                                          "NbChanges reset", 
                                          "NbChanges", 
                                          "Integer", 
                                          new Integer(nbChanges), 
                                          new Integer(0)); 
       state = "initial state"; 
       nbChanges = 0; 
       nbResets++; 
       sendNotification(acn); 
    } 
     
    public int getNbResets() { 
       return nbResets; 
    } 
 
    public MBeanNotificationInfo[] getNotificationInfo() { 
        return new MBeanNotificationInfo[] { 
	  new MBeanNotificationInfo( 
	  new String[] { 
	    AttributeChangeNotification.ATTRIBUTE_CHANGE }, 
	    AttributeChangeNotification.class.getName(), 
	    "This notification is emitted when the reset()  
	     method is called.") 
	}; 
    } 
     
    private String state = "initial state"; 
    private int nbChanges = 0; 
    private int nbResets = 0; 
 
}

SimpleStandard クラスは、簡単な JMX 仕様の標準 MBean を定義します。

SimpleStandard MBean は、「3.1.1.2 SimpleStandardMBean.java」に示すように、対応する SimpleStandardMBean インタフェースを実装することで、管理のための操作と属性を開示します。

リセット操作により発行される通知は、クラス AttributeChangeNotification のインスタンスであり、リセットの呼び出し前に State 属性で実行された変更数に関する情報を収集します。送信される通知の内容は、MBeanNotificationInfo インスタンスで定義されます。

3.1.1.4 SimpleDynamic.java

SimpleDynamic の動的 MBean では、DynamicMBean インタフェースを実装することで、実行時に管理用の属性と操作を開示する方法を示します。ここでは、まず、MBean に関する情報を動的に取得するためのメソッド buildDynamicMBeanInfo() の定義から開始します。buildDynamicMBeanInfo() メソッドは、動的 MBean に MBeanInfo を構築します。

SimpleDynamic の他のコードは、DynamicMBean インタフェースの実装に対応しています。開示される属性、操作、通知は、SimpleStandard MBean で開示されるものと同じです。

3.1.1.5 ClientListener.java

ClientListener クラスは、簡単な JMX 仕様の通知リスナを実装します。

通知が受領されると、NotificationListener インタフェースの handleNotification() メソッドが呼び出され、通知の受領を確認するためのメッセージが印刷されます。

3.1.1.6 Client.java

 
public class Client { 
 
  public static void main(String[] args) { 
    try { 
      // Create an RMI connector client 
      // 
      JMXServiceURL url = new JMXServiceURL( 
         "service:jmx:rmi:///jndi/rmi://localhost:9999/server"); 
      JMXConnector jmxc = JMXConnectorFactory.connect(url, null); 
      ClientListener listener = new ClientListener(); 
      MBeanServerConnection mbsc = jmxc.getMBeanServerConnection(); 
      waitForEnterPressed();       
       
      // Get domains from MBeanServer 
      // 
      String domains[] = mbsc.getDomains(); 
      for (int i = 0; i < domains.length; i++) { 
          System.out.println("Domain[" + i + "] = " + domains[i]); 
      } 
      waitForEnterPressed();       
 
      String domain = mbsc.getDefaultDomain();       
   
      // Create SimpleStandard MBean  
      ObjectName mbeanName =  
             new ObjectName(domain +":type=SimpleStandard,name=2"); 
      mbsc.createMBean("SimpleStandard", stdMBeanName, null, null); 
      waitForEnterPressed();       
             
      // Create SimpleDynamic MBean 
      ObjectName dynMBeanName = 
          new ObjectName(domain +":type=SimpleDynamic,name=2"); 
      echo("\nCreate SimpleDynamic MBean..."); 
      mbsc.createMBean("SimpleDynamic", dynMBeanName, null, null); 
      waitForEnterPressed(); 
       
      // Get MBean count 
      echo("\nMBean count = " + mbsc.getMBeanCount()); 
 
      // Query MBean names 
      echo("\nQuery MBeanServer MBeans:"); 
      Set names = mbsc.queryNames(null, null); 
      for (Iterator i = names.iterator(); i.hasNext(); ) { 
      echo(	"ObjectName = " + (ObjectName) i.next()); 
      } 
      waitForEnterPressed(); 
       
      mbsc.setAttribute(stdMBeanName, 
                        new Attribute("State", "changed state")); 
 
      SimpleStandardMBean proxy = JMX.newMBeanProxy( 
          mbsc, stdMBeanName, SimpleStandardMBean.class, true); 
      echo("\nState = " + proxy.getState()); 
 
      ClientListener listener = new ClientListener(); 
      mbsc.addNotificationListener(stdMBeanName, listener, null, null); 
 
      mbsc.invoke(stdMBeanName, "reset", null, null); 
 
      mbsc.removeNotificationListener(stdMBeanName, listener); 
      mbsc.unregisterMBean(stdMBeanName); 
       
      [...] 
       
      jmxc.close(); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } 
  } 
} 
[...]

Client.java クラスは、RMI コネクタクライアントを作成します。このクライアントは、Server.java で作成される RMI コネクタサーバーへの接続用に設定されます。

Client.java は Server.java で定義されるのと同じサービス URL、url を定義します。これによって、コネクタクライアントは、ローカルホストのポート 9999 で動作する RMI レジストリから RMI コネクタサーバースタブ server を取得し、RMI コネクタサーバーに接続することができます。

RMI レジストリがこのように特定された後、コネクタクライアントを作成できます。コネクタクライアント jmxc は、JMXConnectorFactory の connect() メソッドにより作成されたインタフェース JMXConnector のインスタンスです。connect() メソッドは、呼び出されると、パラメータ url と null 環境マップが渡されます。

またクライアントは、「3.1.1.5 ClientListener.java」に示すように、ClientListener のインスタンスを作成して通知を待機します。

次に、JMXConnector インスタンス jmxc の getMBeanServerConnection() メソッドを呼び出して、JMX 仕様 MBeanServerConnection のインスタンス mbsc が作成されます。

これによってコネクタクライアントは Server.java で作成された MBean サーバーに接続され、両端への接続が完全に透過的な状態にあれば MBean の登録と MBean での操作が可能になります。

クライアントは、MBeanServerConnection の createMBean() メソッドを呼び出して、MBean サーバーに SimpleStandard MBean と SimpleDynamic MBean を作成および登録します。そして、SimpleStandard と SimpleDynamic で定義された操作を、ローカル JMX 仕様の MBean 操作とまったく同様に実行します。


SimpleDynamic

で実行される各操作は、SimpleStandard で実行されるものと同じであるため、ここでは操作のコードを記載していません。

最後に、クライアントは SimpleStandard MBean の登録を解除し、接続を終了します。最後の removeNotificationListener は省略可能です。これはリモートクライアントで登録されたリスナは、そのクライアントの終了時に削除されるためです。

3.1.2 MBean の例題の実行

クラスの例題を検証した後、今度は例題を実行します。例題を実行するには、次の手順に従うか、README ファイルを参照します。

Java クラスをコンパイルします。

$ javac *.java

ローカルホストのポート 9999 で RMI レジストリを起動します。

RMI レジストリは、Server によって RMI コネクタスタブの登録に使用されます。

$ rmiregistry 9999 &

Server クラスを起動します。

$ java -classpath .サーバー

MBean サーバーの作成、および MBean サーバーでの SimpleStandard MBean の作成を確認するプロンプトが表示されます。次に SimpleStandard MBean に関する情報を取得し、この MBean で操作を実行する場合は、Enter キーを押すように要求されます。

SimpleStandard での操作が終了すると、SimpleDynamic MBean について、同じプロセスが繰り返されます。

標準および動的 MBean が作成され、各 MBean 上での操作が実行された後、RMI コネクタサーバーの作成が表示されます。このサーバーを使用すると、リモート Client から MBeans 上で操作を実行できます。

別の端末ウィンドウで Client クラスを起動します。

$ java -classpath .クライアント

RMI コネクタの作成、およびコネクタサーバーとの接続の作成の確認が表示されます。ドメイン名と、SimpleStandard および SimpleDynamic の MBean の作成と登録についても通知されます。クライアントは次に、SimpleStandard と SimpleDynamic の両 MBean で操作を実行し、その後、両 MBean の登録を解除します。

目次 | 前の項目 | 次の項目

Java Management Extensions (JMX) テクノロジのチュートリアル
Java Management Extensions (JMX), Java Platform, Standard Edition 6

第 3 章