Solaris Bandwidth Manager 1.6 の開発

独自の m-bean の記述

ポリシーエージェントは、Solaris Bandwidth Manager プラグインによってリモートの .jar ファイルから m-bean を取得できます。Java API をこのように使用することは、アプリケーションがポリシーエージェントに完全に統合され、アプリケーションがポリシーエージェントの動作方法を変更することを意味します。この節では、m-bean の起動時および停止時におけるポリシーエージェントの動作方法の概要と、新しい m-bean がポリシーエージェントと正しく連動するか確認する上で必要な作業の要約を示します。

この節に示されているコード例は、/opt/SUNWconn/ba/html/examples ディレクトリに入っています。

ポリシーエージェントの操作

Solaris Bandwidth Manager のポリシーエージェントは、多数のタスクを自動的に実行します。この節では、これらのタスクについて説明します。

m-bean の初期化と起動

m-bean の初期化と起動を行う場合に、ポリシーエージェントは次のタスクを実行します。

/opt/SUNWconn/ba/html/beans/*.html ディレクトリに入っている m-let テキストファイルを読み込む
m-bean を初期化する。

ポリシーエージェントは、BeanName.zip と BeanName.class ファイルを読み込み、initCmf() メソッドを呼び出すことによってこのタスクを実行します。実行内容は次のとおりです。
- m-bean をフレームワークに登録する
- 外部で定義された m-bean への参照を回復する
- m-let タグ内に定義されたパラメータを読み込む
Solaris Bandwidth Manager の設定の読み込みと起動を行う
m-bean を起動する

このタスクは、performStart() メソッド (com.sun.jaw.reference.agent.services.ActivatableIf インタフェースに定義されている、Java Dynamic Management Kit の一部) を使用して実行されます。

m-bean の停止

m-bean を停止する場合、ポリシーエージェントは次のタスクを実行します。

performStop() メソッド (com.sun.jaw.reference.agent.services.ActivatableIf インタフェースに定義されている、Java Dynamic Management Kit の一部) を呼び出す
Solaris Bandwidth Manager を停止する
deleteCmf() メソッドを呼び出して m-bean インスタンスを削除する

開発の概要

m-bean を記述する場合、以下の作業を行う必要があります。

m-let テキストファイルを作成する。

各 m-bean の情報は、MLET タグと呼ばれる単一のタグインスタンス内で指定します。m-let テキストファイルが読み込まれる時点で、このファイル内に指定された各 m-bean のインスタンスが作成されます。たとえば、QDatabaseAccounting m-bean の m-let テキストファイルを次のように作成し、QDatabaseAccounting.html に入れることができます。

<MLET
       CODE=com.sun.ba.beans.QDatabaseAccounting
       ARCHIVE="qdatabaseaccounting.jar, dbaccess.jar
>
<PARAM NAME=jdbcDriverName VALUE=com.sun.jdbc.SimpleText.SimpleTextDriver>
<PARAM NAME=jdbcURLName VALUE=jdbc:SimpleText:/var/opt/SUNWconn/ba>
</MLET>

この例で使用されている属性の内容は次のとおりです。

CODE: m-bean の完全な Java クラス名
ARCHIVE: QDataBaseAccounting m-bean によって使用される m-bean などのリソースが入ったファイル。この例では、qdatabaseaccounting.jar ファイルには必要なクラスが含まれ、dbaccess.jar には、データベースドライバが含まれます。
PARAM: QDataBaseAccounting m-bean に必要なパラメータのリスト。これらは、initCmf() メソッドに変更リストとして渡されます。

initCmf() メソッドを実装する。initCmf() メソッドのプロトタイプは、次のような形式をとる必要があります。

.
.
.
public void initCmf(Framework cmf, ObjectName name, boolean db, ModificationList list)
.
.
.

MLET タグ内で定義されたパラメータのリストを含めるために、ModificationList パラメータが必要です。

また、m-bean の bean 名とクラス名を指定して初期化も行えます。

.
.
.
ObjectName statsName = new ObjectName(cmf.getDomain(), beanName);
                stats = (className) cmf.retrieveObject(statsName);
.
.
.

次に、QDatabaseAccounting.java ファイル内の initCmf() メソッドの例を示します。

.
.
.
public void initCmf(Framework cmf, ObjectName name, boolean db, ModificationList list)
   throws InstanceNotFoundException, InstanceAlreadyExistException, ServiceNotFoundException
   {
      this.cmf = cmf;
 
      if (name == null) {
         name = new ObjectName(cmf.getDomain(), getClass().getName());
      }
      if (db) {
         cmf.addDBObject(this, name);
      } else {
         cmf.addObject(this, name);
      }
      this.name = name;
 
      ObjectName statsName = new ObjectName(cmf.getDomain(), statsMOName);
      stats = (QStatsInterface) cmf.retrieveObject(statsName);
 
      String jdbcDriverName = null;
 
      Enumeration enum = list.elements();
      while (enum.hasMoreElements()) {
         Modification modif = (Modification) enum.nextElement();
         String property = modif.getProperty();
         String value = (String) modif.getValue();
         if (property.equalsIgnoreCase("jdbcDriverName")) {
            jdbcDriverName = value;
         } else if (property.equalsIgnoreCase("jdbcUrlName")) {
            jdbcUrlName = value;
         } else if (property.equalsIgnoreCase("jdbcUserName")) {
            jdbcUserName = value;
         } else if (property.equalsIgnoreCase("jdbcPassword")) {
            jdbcPassword = value;
         } else if (property.equalsIgnoreCase("jdbcTableName")) {
            jdbcTableName = value;
         }
      }
 
      try {
         Class.forName(jdbcDriverName);
      } catch (ClassNotFoundException e) {
         throw new ServiceNotFoundException("cannot load JDBC driver " + jdbcDriverName);
      }
 
 }
.
.
.

m-bean の宣言が ActivatableIf インタフェースを実装していることを確認する。
. . . public class QDatabaseAccounting implements QConstants, QFlowAccountingListener, ActivatableIf { . . .
これにより、performStart() と performStop() メソッドが使用できるようになります。

performStart() メソッドを実装する。QDatabaseAccounting m-bean の場合、performStart() メソッドはフローアカウンティングのイベントリスナーを起動するメソッドを呼び出しています。

.
.
.
public void performStart()
   {
    if (!isActive()) {
     try {
      jdbcConnection = DriverManager.getConnection(jdbcUrlName, jdbcUserName, jdbcPassword);
      flowTable = new QFlowTable(jdbcConnection, jdbcTableName);
 
      stats.addQFlowAccountingListener(this);
               } catch (SQLException e) {
                  e.printStackTrace();
               }
    }
   }
.
.
.

performStop() メソッドを実装する。次に、QDatabaseAccounting m-bean の場合の performStop() メソッドの例を示します。

.
.
.
public void performStop()
   {
      if (isActive()) {
         stats.removeQFlowAccountingListener(this);
 
         try {
            jdbcConnection.commit();
            jdbcConnection.close();
            jdbcConnection = null;
            flowTable = null;
         } catch (SQLException e) {
            e.printStackTrace();
         }
      }
   }
.
.
.

isActive() メソッドを実装する。

.
.
.
public boolean isActive()
{
 
   return (jdbcConnection != null && flowTable != null);
}
.
.
.