12 検索サービス

例4-1 SLP検索サービスの例題クラスServer.java (抜粋1)

 
public class Server { 
   public final static int JMX_DEFAULT_LEASE = 300; 
   public final static String JMX_SCOPE = "DEFAULT"; 
 
   private final MBeanServer mbs; 
   public Server() { 
       mbs = MBeanServerFactory.createMBeanServer(); 
   } 
    
[...] 
 

例4-1では、デフォルトのSLPリースJMX_DEFAULT_LEASEを、URLの登録期間に対応するデフォルト・リース300秒に設定し、MBeanサーバーmbsの初期作成を示しています。

例には示されていないコードでは、次にSLPアドバタイザslpAdvertiserとSLPサービスURL urlを定義します。slpAdvertiserは、SLP検索サービスにサービスURLを登録する場合に使用します。SCOPEとagentNameは、SLPに検索属性として登録されます。

例4-2 SLP検索サービスの例題クラスServer.java (抜粋2)

 
[...] 
 
   public static void register(JMXServiceURL jmxUrl, String name) 
     throws ServiceLocationException { 
     ServiceURL serviceURL = 
          new ServiceURL(jmxUrl.toString(), 
                         JMX_DEFAULT_LEASE); 
     debug("ServiceType is: " + serviceURL.getServiceType()); 
     Vector attributes = new Vector(); 
     Vector attrValues = new Vector(); 
     attrValues.add(JMX_SCOPE); 
     ServiceLocationAttribute attr1 = 
          new ServiceLocationAttribute("SCOPE", attrValues); 
     attributes.add(attr1); 
     attrValues.removeAllElements(); 
     attrValues.add(name); 
     ServiceLocationAttribute attr2 = 
          new ServiceLocationAttribute("AgentName", attrValues); 
     attributes.add(attr2); 
     final Advertiser slpAdvertiser = 
          ServiceLocationManager.getAdvertiser(Locale.US); 
     slpAdvertiser.register(serviceURL, attributes); 
      
   }  
 
[...] 
 

例4-2に、JMXコネクタ・サーバーのURLのSLP検索サービスへの登録を示します。

JMXサービスURL、jmxUrlは、コネクタ・サーバーのアドレスであり、コネクタ・サーバーの起動時にJMXConnectorServerのgetAddress()メソッドを呼び出して取得します。

このとき、スコープやコネクタ・サーバー・アドレスが登録される際のエージェント名(name)などのSLP検索の属性は、SLPクラスServiceLocationAttributeにより指定されます。AgentName属性は必須ですが、ProtocolType、AgentHost、およびPropertyなどのほかのオプション属性もSLP検索サービスに登録できます。

最後に、JMXコネクタ・サーバー・アドレスはAdvertiserインタフェースのregister()メソッドの呼出しによりSLPサービスに登録され、パラメータとしてserviceURLとattributesが渡されます。

例4-3 SLP検索サービスの例題クラスServer.java (抜粋3)

 
[...] 
 
   public JMXConnectorServer rmi(String url) throws 
     IOException, 
     JMException, 
     NamingException, 
     ClassNotFoundException, 
     ServiceLocationException { 
     JMXServiceURL jurl = new JMXServiceURL(url); 
     final HashMap env = new HashMap(); 
     // Environment map attributes 
     [...] 
 
  
     JMXConnectorServer rmis = 
        JMXConnectorServerFactory.newJMXConnectorServer(jurl, env, mbs); 
     final String agentName = System.getProperty("agent.name", 
                                                 "DefaultAgent"); 
     start(rmis, agentName); 
 
     return rmis; 
  } 
[...] 
 

例4-3に、RMIコネクタ・サーバーの作成を示します。JMXサービスURL jurlは、コマンド行でServerを起動するためのコマンドに含まれる文字列urlから構築されます。RMIコネクタ・サーバー、rmisは、環境マップとアドレスjurlで定義されるシステム・プロパティから作成されます。

次にコネクタ・サーバーが起動し、RMIコネクタ・サーバー・アドレスがagentNameの名前でSLP検索サービスに登録されます。

例4-4 SLP検索サービスの例題クラスServer.java (抜粋4)

 
[...] 
 
   public void start(JMXConnectorServer server, String agentName) 
      throws IOException, ServiceLocationException { 
      server.start(); 
      final JMXServiceURL address = server.getAddress(); 
      register(address,agentName); 
   } 
    
[...] 
 

例4-4に、コネクタ・サーバーserverの起動と、指定されたアドレスaddressを使用したserverのSLP検索サービスへの登録を示します。

例4-5 SLP検索サービスの例題クラスClient.java (抜粋1)

 
public class Client { 
 
    public final static String JMX_SCOPE = "DEFAULT"; 
 
    public static Locator getLocator() throws ServiceLocationException { 
      final Locator slpLocator = 
          ServiceLocationManager.getLocator(Locale.US); 
      return slpLocator; 
    } 
     
      public static List lookup(Locator slpLocator, String name) 
          throws IOException, ServiceLocationException { 
 
   
          final ArrayList list = new ArrayList(); 
          Vector scopes = new Vector(); 
 
          scopes.add(JMX_SCOPE); 
          String query =  
              "(&(AgentName=" + ((name!=null)?name:"*") + "))"; 
 
          ServiceLocationEnumeration result = 
              slpLocator.findServices(new ServiceType("service:jmx"), 
                                      scopes, query); 
 
          while(result.hasMoreElements()) { 
                final ServiceURL surl = (ServiceURL) result.next(); 
                 
 
             JMXServiceURL jmxUrl = new JMXServiceURL(surl.toString()); 
             try { 
                  JMXConnector client = 
                     JMXConnectorFactory.newJMXConnector(jmxUrl,null); 
                  if (client != null) list.add(client); 
             } catch (IOException x ) {  
             [...] 
             } 
          } 
      } 
      return list; 
    } 
 

例4-5では、SLPクラスServiceLocationManagerのgetLocatorメソッドを呼び出して、SLPサービスLocatorを取得します。次にClientは、特定のエージェント名または特定のパターンに一致するエージェント名でSLPサービスに登録された、すべてのコネクタ・サーバーを取得します。Clientの起動時にエージェント名が指定されていない場合、すべてのエージェント名が考慮されます。

JMXテクノロジ・サービスURL、jmxUrlは、SLPで取得されたエージェントごとに生成されます。各エージェントのSLPサービスURL、surlはパラメータとしてJMXServiceURLインスタンスに渡されます。URL ,jmxUrl,は、JMXConnectorFactoryのnewJMXConnector()メソッドに渡され、SLPサービスに登録される各エージェントに新しいコネクタ・クライアントclientが作成されます。

取得されたコネクタ・クライアントは、配列リストlistに保存されます。

例4-6 SLP検索サービスの例題クラスClient.java (抜粋2)

 
public static void listMBeans(MBeanServerConnection server) 
     throws IOException { 
 
     final Set names = server.queryNames(null,null); 
     for (final Iterator i=names.iterator(); i.hasNext(); ) { 
          ObjectName name = (ObjectName)i.next(); 
          System.out.println("Got MBean: "+name); 
          try { 
               MBeanInfo info = 
                  server.getMBeanInfo((ObjectName)name); 
               MBeanAttributeInfo[] attrs = info.getAttributes(); 
               if (attrs == null) continue; 
               for (int j=0; j<attrs.length; j++) { 
                    try { 
                         Object o = 
                         server.getAttribute(name,attrs[j].getName()); 
                         System.out.println("\t\t" + attrs[j].getName() + 
                         " = "+o); 
                    } catch (Exception x) { 
                         System.err.println("JmxClient failed to get " + 
                                             attrs[j].getName() + x); 
                         x.printStackTrace(System.err); 
                    } 
     } 
} 
 

例4-6では、SLPサービスに保存されたコネクタ・サーバー・アドレスを使用して作成されたすべてのコネクタ・クライアントに、MBeanServerConnectionの参照が取得されています。すべてのMBeanとその属性のリストが取得されます。

例4-7 SLP検索サービスの例題クラスClient.java (抜粋3)

 
public static void main(String[] args) { 
      try { 
           final String agentName = System.getProperty("agent.name"); 
           final Locator slpLocator = getLocator(); 
           List l = lookup(slpLocator,agentName); 
           int j = 1; 
           for (Iterator i=l.iterator();i.hasNext();j++) { 
                JMXConnector c1 = (JMXConnector) i.next(); 
                if (c1 != null) { 
                    try { 
                         c1.connect(env); 
                    } catch (IOException x) { 
                         System.err.println ("Connection failed: " + x); 
                         x.printStackTrace(System.err); 
                         continue; 
                    } 
 
                    MBeanServerConnection conn = 
                         c1.getMBeanServerConnection(); 
 
                    try { 
                         listMBeans(conn); 
                    } catch (IOException x) { 
                         x.printStackTrace(System.err); 
                    } 
                    try { 
                         c1.close(); 
                    } catch (IOException x) { 
                         x.printStackTrace(System.err); 
                    } 
                } 
           } 
      } catch (Exception x) { 
           x.printStackTrace(System.err); 
      } 
} 
 

例4-7では、agent.nameプロパティはSystemクラスのgetProperty()メソッドを呼び出して取得され、SLP検索サービスはLocatorのgetLocator()メソッドを呼び出して検索されます。

agentNameの名前を持つすべてのエージェントが検索され、検出されたエージェントへの接続が設定されます。エージェントが指定されていない場合、すべてのエージェントが検索されます。Serverで作成されたMBeanサーバーへの接続が設定され、接続が切断される前に、接続内のすべてのMBeanがリストされます。

SLP検索サービスの例題の設定

次の手順は、この例題で実行できる様々なトランスポートのすべてで要求されます。

1. クラスのコンパイルおよび実行が容易になるように、追加で環境変数を定義します。初期設定で設定された共通の環境変数の他に、SLPサービスのパスを追加する必要があります。

   Solarisオペレーティング環境を使用している場合は、次の変数を追加します。

   $ SLPLIB=/usr/share/lib/slp

   別のプラットフォームを使用している場合は、使用しているプラットフォームに合わせてSLPLIBを設定します。

2. classp環境変数を定義し、エクスポートします。この例では、SLPのJavaアーカイブ(JAR)ファイルを含むクラス・パスが必要です:

   $ classp=$SLPLIB/slp.jar

3. 次のコマンドを入力して、例題のClientおよびServerクラスをコンパイルします。

   $ javac -d . -classpath $classp Server.java Client.java

4. SLPデーモンを起動します。

   Solarisオペレーティング環境を使用している場合、次のコマンドを入力しますが、これにはスーパー・ユーザー・パスワードが必要です。

   $ su root -c "java -cp $SLPLIB/slpd.jar com.sun.slp.slpd &"
   Password:[type superuser password]

   Solarisシステムを実行していない場合、使用しているSLPの実装に従ってSLPデーモンを起動します。

サーバーの起動

Serverの起動に使用するコマンドは、使用している外部ディレクトリによって異なります。Clientを起動する前に、Serverの次のインスタンスの1つ以上を起動します。Serverのインスタンスを、各種のトランスポートおよび外部レジストリを使用して、起動できます。

• 外部ディレクトリを使用しないJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

  $ java -classpath .:$classp -Ddebug=true \ 
    -Dagent.name=example-server-a \ 
    -Durl ="service:jmx:rmi://" \ 
    slp.Server & 
  

  コマンドの説明は次のとおりです。

  • debugの値はtrueに設定され、Serverの実行時の画面出力をより詳細なものにします。
  • エージェントの名前はexample-server-aです。
  • サービスURLにより、RMIのデフォルト・トランスポートJRMP上で動作するRMIコネクタの選択が指定されます。

  Serverが起動すると、RMIコネクタの作成、およびそのURLのSLPサービスへの登録を確認するメッセージが表示されます。

• RMIレジストリを外部ディレクトリとして使用するJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

   $ java -classpath .:$classp -Ddebug=true \ 
    -Dagent.name=example-server-b \ 
    -Durl="service:jmx:rmi:///jndi/${jndirmi}/server" \ 
    slp.Server & 
  

  コマンドの説明は次のとおりです。

  • 作成されるエージェントの名前はexample-server-bです。
  • サービスURLは、JRMP上のRMIとして選択されるコネクタを指定し、RMIコネクタ・スタブserverが保存される外部ディレクトリは、初期設定でjndirmiと特定したRMIレジストリです。

  Serverが起動すると、RMIコネクタの作成、およびそのURLのSLPサービスへの登録を確認するメッセージが表示されます。

• LDAPを外部ディレクトリとして使用するJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

   $ java -classpath .:$classp -Ddebug=true \ 
    -Dagent.name=example-server-c \ 
    -Durl="service:jmx:rmi:///jndi/${jndildap}/cn=x,dc=Test" \ 
    -Djava.naming.security.principal="$principal" \ 
    -Djava.naming.security.credentials="$credentials" \ 
    slp.Server & 
  

  コマンドの説明は次のとおりです。

  • 作成されるエージェントの名前はexample-server-cです。
  • サービスURLは、JRMP上のRMIとして選択されるコネクタを指定し、RMIコネクタ・スタブが保存される外部ディレクトリは、初期設定でjndildapと特定したLDAPサーバーです。
  • スタブはLDAPサーバーのTestドメイン・コンポーネントに登録されます。
  • LDAPサーバーにアクセスするため、共通名の属性principalとパスワードcredentialsが与えられます。

  Serverが起動すると、RMIコネクタの作成、およびそのURLがエージェント名example-server-cでSLPサービスに登録されることの確認が表示されます。

クライアントの起動

選択したトランスポートおよび外部ディレクトリを使用してServerを起動した後、Clientを起動します。

$ java -classpath .:$classp -Ddebug=true \ 
     -Djava.naming.security.principal="$principal" \ 
     -Djava.naming.security.credentials="$credentials" \ 
     slp.Client 

Serverで作成され検索サービスに登録されたエージェントの検出を確認する出力が表示されます。また、エージェントに設定された接続の接続名と、接続の確認が表示されます。

特定のエージェントを検索するには、次のコマンドを入力します。

$ java -classpath .:$classp -Ddebug=true \  
     -Djava.naming.security.principal="$principal" \ 
     -Djava.naming.security.credentials="$credentials" \ 
     -Dagent.name="agentName" \ 
    slp.Client 

上に示したこのコマンドで、agentNameは検索するエージェントの名前です。*を使用してエージェント名を部分的に指定することもできます。たとえば、文字xで始まるすべてのエージェント名を検索する場合は、x*と指定します。

例4-8 Jini検索サービスの例題クラスServer.java (抜粋1)

public class Server { 
   private final MBeanServer mbs; 
   private static boolean debug = false; 
   public Server() { 
     mbs = MBeanServerFactory.createMBeanServer(); 
   } 
 
[...] 

例4-8に、MBeanサーバーmbsの作成を示します。SLPの例題の場合と同様に、Serverをコマンド行で起動する場合、JMXサービスのURLとエージェント名がサーバーに渡されます。

例4-9 Jini検索サービスの例題クラスServer.java (抜粋2)

[...] 
 
   public JMXConnectorServer rmi(String url) 
      throws IOException, JMException, ClassNotFoundException { 
      JMXServiceURL jurl = new JMXServiceURL(url); 
      final HashMap env = new HashMap(); 
      // Environment map attributes 
     [...] 
     JMXConnectorServer rmis = 
        JMXConnectorServerFactory.newJMXConnectorServer(jurl, env, mbs); 
 
     final String agentName = System.getProperty("agent.name", 
                                                 "DefaultAgent"); 
 
     start(rmis,env,agentName); 
 
     return rmis; 
   } 
    
[...] 
 

例4-9に、環境マップenvとアドレスjurlで定義されるシステム・プロパティを使用した、RMIコネクタ・サーバーrmisの作成を示します。

RMIコネクタ・サーバーrmisが起動します。RMIコネクタ・サーバーのアドレスは、agentNameの名前でJini検索サービスに登録されます。

例4-10 Jini検索サービスの例題クラスServer.java (抜粋3)

 [...] 
 
   public void start(JMXConnectorServer server, Map env, String agentName) 
      throws IOException, ClassNotFoundException { 
      server.start(); 
      final ServiceRegistrar registrar=getRegistrar(); 
      final JMXConnector proxy = server.toJMXConnector(env); 
      register(registrar,proxy,agentName); 
   } 
    
   public static ServiceRegistrar getRegistrar() 
      throws IOException, ClassNotFoundException, 
         MalformedURLException { 
      final String jurl = 
         System.getProperty("jini.lookup.url","jini://localhost"); 
      final LookupLocator lookup = new LookupLocator(jurl); 
      final ServiceRegistrar registrar = lookup.getRegistrar(); 
      if (registrar instanceof Administrable) 
          debug("Registry is administrable."); 
      return registrar; 
   } 
    
   public static ServiceRegistration register(ServiceRegistrar registrar, 
                                              JMXConnector proxy, String name) 
      throws IOException { 
      Entry[] serviceAttrs = new Entry[] { 
              new net.jini.lookup.entry.Name(name) 
                       }; 
                        
      System.out.println("Registering proxy: AgentName=" + name ); 
      debug("" + proxy); 
      ServiceItem srvcItem = new ServiceItem(null, proxy, serviceAttrs); 
      ServiceRegistration srvcRegistration = 
             registrar.register(srvcItem, Lease.ANY); 
      debug("Registered ServiceID: " + 
                              srvcRegistration.getServiceID().toString()); 
      return srvcRegistration; 
   } 
    
[...] 
 

例4-10に、環境マップenvとサービスURL、jurlを使用した、コネクタ・サーバーserverの作成を示します。コネクタ・サーバーのインスタンス・サーバーは、Jini検索サービス・メソッドLookupLocator.getRegistrar()を呼び出してJini検索サービスのポインタを取得します。

コネクタ・サーバーは、Jini検索サービス・ロケータregistrarと、コネクタ・サーバーが登録される際のエージェント名を使用して、プロキシ形式でJini検索サービスに登録されます。プロキシは実際には、コネクタ・サーバーのクライアント・スタブになり、JMXConnectorServerのtoJMXConnector()メソッドの呼出しにより取得されます。

登録自体は、サービス項目の配列を使用し、Jini検索サービス・クラスServiceRegistrarのregister()メソッドを呼び出して実行されます。

例4-11 Jini検索サービスの例題クラスClient.java

public class Client { 
 
   private static boolean debug = false; 
   public static ServiceRegistrar getRegistrar() 
       throws IOException, ClassNotFoundException, MalformedURLException { 
       final String jurl = 
                  System.getProperty("jini.lookup.url","jini://localhost"); 
       final LookupLocator lookup = new LookupLocator(jurl); 
       final ServiceRegistrar registrar = lookup.getRegistrar(); 
       if (registrar instanceof Administrable) 
               debug("Registry is administrable."); 
       return registrar; 
 } 
 
   public static List lookup(ServiceRegistrar registrar, 
           String name) throws IOException { 
       final ArrayList list = new ArrayList(); 
       final Class[] classes = new Class[] {JMXConnector.class}; 
       final Entry[] serviceAttrs = new Entry[] { 
           new net.jini.lookup.entry.Name(name) 
   }; 
    
   ServiceTemplate template = 
        new ServiceTemplate(null,classes,serviceAttrs); 
   ServiceMatches matches = 
        registrar.lookup(template, Integer.MAX_VALUE); 
   for(int i = 0; i < matches.totalMatches; i++) { 
        debug("Found Service: " + matches.items[i].serviceID); 
        if (debug) { 
           if (matches.items[i].attributeSets != null) { 
                   final Entry[] attrs = matches.items[i].attributeSets; 
                   for (int j = 0; j < attrs.length ; j++) { 
                       debug("Attribute["+j+"]=" + attrs[j]); 
               } 
           } 
        } 
 
 
        if(matches.items[i].service != null) { 
            JMXConnector c = (JMXConnector)(matches.items[i].service); 
            debug("Found a JMXConnector: " + c); 
            list.add(c); 
        } 
   } 
   return list; 
} 
 
[...] 
 

例4-11に、コネクタ・クライアントがlookup.getRegistrar()の呼出しによりJini検索サービスのポインタを取得する方法を示します。クライアントは、次にエージェント名nameを使ってJini検索サービスにエントリとして登録されたコネクタのリストを取得します。SLPの例と異なり、起動時にユーザーがClientに渡したエージェント名は、既存のエージェント名と完全に一致するか、Nullでなければならず、いずれの場合も、Jini検索サービスはすべてのエージェントを検索します。

ここにコードは示されていませんが、コネクタのリストが取得されると、クライアントはServerによって起動したMBeanサーバーに接続し、このサーバーに登録されたすべてのMBeanを示したリストを取得します。

Jini検索サービスの例題の設定

次の手順は、この例題で実行できるすべてのトランスポートで要求されます。

1. 例題クラスのコンパイルおよび実行が容易になるように、追加の環境変数をいくつか定義できます。初期設定で設定した共通の環境変数の他に、Jini検索サービスのパスを追加できます。

   Jiniネットワーキング・テクノロジをインストールしたディレクトリは、jini_dirとして参照されます。

   $ JINI_HOME=jini_dir

   $ JINILIB=$JINI_HOME/lib

2. classp環境変数を定義します。この例では、Jini検索サービスのコアと拡張機能に使用するJARファイルが必要になります。

   $ classp=$JINILIB/jini-core.jar:$JINILIB/jini-ext.jar

3. jini.propertiesファイルを作成します。Solaris、Linux、またはMac OS Xプラットフォーム用のプロパティ・ファイルは、この例のクラスと同じディレクトリ内にあります。Solaris、Linux、またはMac OS Xプラットフォームを実行していない場合、使用しているプラットフォームのプロパティ・ファイルは次のディレクトリで入手できます。

   $JINI_HOME/example/launcher/jini12_platform.properties

4. jini.propertiesファイルを更新して、システムに必要なすべてのパス、ホスト名およびポート番号を含める必要があります。Solaris、Linux、またはMac OS Xプラットフォームを実行していない場合でも、参照としてテンプレートを使用できます。

5. 次のように入力してJiniネットワーキング・テクノロジStartServiceを起動します。

   $ java -cp $JINILIB/jini-examples.jar com.sun.jini.example.launcher.StartService &

   StartServiceグラフィカル・ユーザー・インタフェースが開きます。

6. 「ファイル」、「プロパティ・ファイルを開く」をクリックし、次のディレクトリからプロパティ・ファイルを選択して、jini.propertiesファイルをStartServiceにロードします。

   work_dir/jmx_examples/Lookup/jini.

7. Jini検索サービスを開始するには、「実行」タブをクリックし、次の項目のそれぞれについて「開始」ボタンを押します。

   • RMID
   • WebServer
   • Reggie
   • LookupBrowser

   サービスの実行を確認するメッセージが表示されます。

8. 次のコマンドを入力して、ClientおよびServerクラスをコンパイルします。

   $ javac -d . -classpath $classp Server.java Client.java

サーバーの起動

Serverの起動に使用するコマンドは、使用している外部ディレクトリによって異なります。Clientを起動する前に、各種のトランスポートおよび外部レジストリを使用して、Serverの次のインスタンスの1つ以上を起動できます。

• 外部ディレクトリを使用しないJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

  $ java -classpath .:$classp -Ddebug=true \ 
    -Dagent.name=example-server-a \ 
    -Durl="service:jmx:rmi://" \ 
    -Djava.security.policy=java.policy \ 
    jini.Server & 
  

  コマンドの説明は次のとおりです。

  • debugの値はtrueに設定され、Serverの実行時の画面出力をより詳細なものにします。

  • Jini検索サービスへのアクセスを可能にする、セキュリティ・ポリシーが指定されています。

  • 作成されるエージェントの名前はexample-server-aです。

  • サービスURLにより、RMIのデフォルト・トランスポートJRMP上で動作するRMIコネクタの選択が指定されます。

  Serverが起動すると、RMIコネクタの作成、およびそのURLがJini検索サービスに登録されることの確認が表示されます。

• RMIレジストリを外部ディレクトリとして使用するJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

  $ java -classpath .:$classp -Ddebug=true \ 
    -Dagent.name=example-server-b \ 
    -Durl="service:jmx:rmi:///jndi/${jndirmi}/server" \ 
    -Djava.security.policy=java.policy \ 
    jini.Server &

  コマンドの説明は次のとおりです。

  • Jini検索サービスへのアクセスを可能にする、セキュリティ・ポリシーが指定されています。

  • 作成されるエージェントの名前はexample-server-bです。
  • サービスURLは、JRMP上のRMIとして選択されるコネクタを指定し、RMIコネクタ・スタブserverが保存される外部ディレクトリは、初期設定でjndirmiと特定したRMIレジストリです。

  Serverが起動すると、RMIコネクタの作成、およびそのURLがJini検索サービスに登録されることの確認が表示されます。

• LDAPを外部ディレクトリとして使用するJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

  $ java -classpath .:$classp -Ddebug=true \ 
    -Dagent.name=example-server-c \ 
    -Durl="service:jmx:rmi:///jndi/${jndildap}/cn=x,dc=Test" \ 
    -Djava.security.policy=java.policy \ 
    -Djava.naming.security.principal="$principal" \ 
    -Djava.naming.security.credentials="$credentials" \ 
    jini.Server &

  コマンドの説明は次のとおりです。

  • Jini検索サービスへのアクセスを可能にする、セキュリティ・ポリシーが指定されています。

  • 作成されるエージェントの名前はexample-server-cです。サービスURLは、JRMP上のRMIとして選択されるコネクタを指定し、RMIコネクタ・スタブが保存される外部ディレクトリは、初期設定でjndildapと特定したLDAPサーバーです。

  • スタブはLDAPサーバーのTestドメイン・コンポーネントに登録されます。

  • LDAPサーバーにアクセスするため、共通名の属性principalとパスワードcredentialsが与えられます。

  Serverが起動すると、RMIコネクタの作成、およびそのURLがエージェント名example-server-cでJini検索サービスに登録されることの確認が表示されます。

Serverが起動すると、RMIコネクタの作成、およびそのURLがエージェント名example-server-fでJini検索サービスに登録されることの確認が表示されます。

クライアントの起動

選択したトランスポートおよび外部ディレクトリを使用してServerを起動した後、次のように入力してClientを起動します。

$ java -classpath .:$classp -Ddebug=true \ 
  -Djava.security.policy=java.policy \ 
  jini.Client 

Serverで作成され検索サービスに登録されたエージェントの検出を確認する出力が表示されます。また、エージェントに設定された接続の接続名と、接続の確認が表示されます。

次のコマンドを入力すると、特定のエージェントを検索できます。

$ java -classpath .:$classp -Ddebug=true \ 
  -Djava.security.policy=java.policy \ 
  -Dagent.name=agentName \ 
  jini.Client

前述のコマンドで、agentNameは検索するエージェントの名前です。また、*を使用してエージェント名を部分的に指定することもできます。たとえば、文字xで始まるすべてのエージェント名を検索する場合は、x*と指定します。

例4-12 JNDI/LDAP検索サービスの例題のServer.java (抜粋1)

[...]

public class Server {
   public final static int JMX_DEFAULT_LEASE = 60;
   private static boolean debug = false;
   private final MBeanServer mbs;
   public Server() {
      mbs = MBeanServerFactory.createMBeanServer();
   }

  public static DirContext getRootContext() throws NamingException {
      final Hashtable env = new Hashtable();

      final String factory =
        System.getProperty(Context.INITIAL_CONTEXT_FACTORY,
                           "com.sun.jndi.ldap.LdapCtxFactory");
      final String ldapServerUrl =
        System.getProperty(Context.PROVIDER_URL);
      final String ldapUser =
        System.getProperty(Context.SECURITY_PRINCIPAL,
                           "cn=Directory Manager");
      final String ldapPasswd =
        System.getProperty(Context.SECURITY_CREDENTIALS);
      debug(Context.PROVIDER_URL + "=" + ldapServerUrl);
      debug(Context.SECURITY_PRINCIPAL + "=" + ldapUser);
      if (debug) {
                  System.out.print(Context.SECURITY_CREDENTIALS + "=");
                  final int len = (ldapPasswd==null)?0:ldapPasswd.length();
                  for (int i=0;i<len;i++) System.out.print("*");
                  System.out.println();
      }
      env.put(Context.INITIAL_CONTEXT_FACTORY,factory);
      env.put(Context.SECURITY_PRINCIPAL, ldapUser);
      if (ldapServerUrl != null)
           env.put(Context.PROVIDER_URL, ldapServerUrl);
      if (ldapPasswd != null)
           env.put(Context.SECURITY_CREDENTIALS, ldapPasswd);
      InitialContext root = new InitialLdapContext(env,null);
      return (DirContext)(root.lookup(""));
  }
[...]

例4-12では、MBeanサーバーmbsの初期作成を示し、コネクタ・サーバーのアドレスが登録されるLDAPディレクトリ・ツリーのルート・コンテキストのポインタを取得します。プロバイダURL、LDAPユーザー名、セキュリティ資格などの関連するLDAPアクセス変数はすべてここに指定され、環境マップenvに渡されます。環境マップenvは、この後、InitialLdapContextの呼出しにパラメータとして渡され、これによって初期LDAPコンテキストが取得されます。

例4-13 JNDI/LDAP検索サービスの例題クラスServer.java (抜粋2)

[...]

public static void register(DirContext root,
                           JMXServiceURL jmxUrl,
                           String name)
   throws NamingException, IOException {

   final String mydn = System.getProperty("dn","cn="+name);

   debug("dn: " + mydn );

   Object o = null;
   try {
       o = root.lookup(mydn);
   } catch (NameNotFoundException n) {
       Attributes attrs = new BasicAttributes();
       Attribute objclass = new BasicAttribute("objectClass");
       objclass.add("top");
       objclass.add("javaContainer");
       objclass.add("jmxConnector");
       attrs.put(objclass);
       attrs.put("jmxAgentName", name);
       o = root.createSubcontext(mydn,attrs);
   }
   if (o == null) throw new NameNotFoundException();
   final Attributes attrs = root.getAttributes(mydn);
   final Attribute oc = attrs.get("objectClass");
   if (!oc.contains("jmxConnector")) {
       final String msg = "The supplied node [" + mydn + 
         "] does not contain the jmxConnector objectclass";
       throw new NamingException(msg);
   }
   final Attributes newattrs = new BasicAttributes();
   newattrs.put("jmxAgentName",name);
   newattrs.put("jmxServiceURL",jmxUrl.toString());
   newattrs.put("jmxAgentHost",InetAddress.getLocalHost().getHostName());
   newattrs.put("jmxProtocolType",jmxUrl.getProtocol());
   newattrs.put("jmxExpirationDate",
                getExpirationDate(JMX_DEFAULT_LEASE));
   root.modifyAttributes(mydn,DirContext.REPLACE_ATTRIBUTE,newattrs);
}

[...]

例4-13に、JMXコネクタ・サーバーのサービスURLのLDAPディレクトリへの登録を示します。URLが登録されるDNは、コマンド行でdnシステム・プロパティ(-Ddn=mydn)を使用して渡すことができます。説明は、サーバーの起動に使用されるコマンドを参照してください。dnシステム・プロパティが指定されない場合、DN: cn=nameを使用できます。ここで、nameはagentNameです。ただし、これは必須ではありません。URLが登録される場所は問題ではありません。クライアント・コードで直接そのDNが使用されることはないためです。そのかわり、LDAP検索を実行して、補助的なjmxConnector ObjectClassを含むノードが検索されます。重要なのは、各URLが個々のLDAPノードに登録されるという点です。これらのノードの命名方式は、LDAP管理者、この場合は各ユーザーに委ねられます。この例では、ノードcn=nameの作成が可能なルート・コンテキストを作成することでLDAPサーバーを構成し、このrootコンテキストをContext.PROVIDER_URLプロパティを通じてLDAPの初期コンテキストに渡しているものと仮定しています。例4-12 JNDI/LDAP検索サービスの例題のServer.java (抜粋1)を参照してください。

例4-13のコードでは、サーバーURLを登録するノードが存在するかどうかをチェックしています。存在しない場合は作成を試してください。親ノードが存在しない場合は失敗します。jmxConnector ObjectClassは簡単な補助クラスであり、新しいコンテキストを作成する必要がある場合は、構造化クラスとしてjavaContainer ObjectClassを使用します。これは完全なオプションです。jmxConnector補助クラスを追加できる構造化クラスは何でもかまいません。コードは次にサーバーを登録するノードに、jmxConnector補助クラスがすでに使用されているかどうかをチェックします。使用されていない場合は、例外がスローされます。

この時点で、URLを登録するノードが存在し、適切なjmxConnector補助クラスが指定されていることが確実になります。必要なのは、LDAP検索のためのJMX Remote APIで定義された属性の値を置き換えることのみです。jmx-schema.txtを参照してください。

• jmxServiceUrl: サーバーの起動後にserver.getAddress()により取得されたString形式のサーバーURLが含まれる

• jmxAgentName: JMXエージェント名が含まれる

• jmxProtocolType: jmxUrl.getProtocolType()で返されるJMXプロトコル型が含まれる

• jmxAgentHost: エージェント・ホストの名前が含まれる

• jmxExpirationDate: URLの有効期日が含まれる

例4-14 JNDI/LDAP検索サービスの例題クラスServer.java (抜粋3)

 [...]

   public JMXConnectorServer rmi(String url)
     throws IOException, JMException,
        NamingException, ClassNotFoundException {

     JMXServiceURL jurl = new JMXServiceURL(url);
     final HashMap env = new HashMap();
     // Prepare the environment Map
[...]

     JMXConnectorServer rmis =
JMXConnectorServerFactory.newJMXConnectorServer(jurl, env, mbs)

     final String agentName = System.getProperty("agent.name",
                                                 "DefaultAgent");
     start(rmis,env,agentName);
     return rmis;
   }
[...]

例4-14では、JMXサービスURL jurlと適切なLDAPプロパティが環境マップenvに渡され、rmisという新しいRMIコネクタ・サーバーが作成されています。コネクタ・サーバーrmisが、JMXConnectorServer.start()の呼出しにより起動し、LDAPサーバーに登録されます。

例4-15 JNDI/LDAP検索サービスの例題クラスServer.java (抜粋4)

[...]

    public void start(JMXConnectorServer server, Map env, String agentName)
       throws IOException, NamingException {server.start()
       final DirContext root=getRootContext();
       final JMXServiceURL address = server.getAddress();register(root,address,agentName)
    }
[...]

例4-15では、JMXコネクタ・サーバーserverを作成し、LDAPサーバーのルート・ディレクトリrootへのポインタを取得し、addressという名前のサーバーのURLを作成します。ルート・ディレクトリ、URL、およびエージェント名は、パラメータとしてregister()に渡され、LDAPサーバーに登録されます。

コード例4-16 JNDI/LDAP検索サービスの例題クラスClient.java

[...]

public class Client {

   private static boolean debug = false;

   public static void listAttributes(DirContext root, String dn)
     throws NamingException {
     final Attributes attrs = root.getAttributes(dn);
     System.out.println("dn: " + dn);
     System.out.println("attributes: " + attrs);
   }
   public static DirContext getRootContext() throws NamingException {
      final Hashtable env = new Hashtable();
      // Prepare environment map
      [...]
      InitialContext root = new InitialLdapContext(env,null);
      return (DirContext)(root.lookup(""));
   }
   // Confirm URL has not expired 
  [...] 

   public static List lookup(DirContext root, String protocolType,
                             String name)
      throws IOException, NamingException {
      final ArrayList list = new ArrayList();
      String queryProtocol =
         (protocolType==null)?"":"(jmxProtocolType="+protocolType+")";
      String query =
          "(&" + "(objectClass=jmxConnector) " +
          "(jmxServiceURL=*) " +
          queryProtocol +
          "(jmxAgentName=" + ((name!=null)?name:"*") + "))";

      SearchControls ctrls = new SearchControls();
      ctrls.setSearchScope(SearchControls.SUBTREE_SCOPE);
      final NamingEnumeration results = root.search("", query, ctrls);
      while (results.hasMore()) { 
           final SearchResult r = (SearchResult) results.nextElement();
           debug("Found node: " + r.getName());
           final Attributes attrs = r.getAttributes();
           final Attribute attr = attrs.get("jmxServiceURL");
           if (attr == null) continue;
           final Attribute exp = attrs.get("jmxExpirationDate");
           if ((exp != null) && hasExpired((String)exp.get())) {
               System.out.print(r.getName() + ": ");
               System.out.println("URL expired since: " + exp.get());
               continue;}
           final String urlStr = (String)attr.get();
           if (urlStr.length() == 0) continue;

           debug("Found URL: "+ urlStr);

           final JMXServiceURL url = new JMXServiceURL(urlStr);
           final JMXConnector conn =
               JMXConnectorFactory.newJMXConnector(url,null);
           list.add(conn);
           if (debug) listAttributes(root,r.getName());
      }

      return list;
}
}

コード例4-16では、ClientはまずLDAPディレクトリDirContextのポインタrootを返し、次にこのディレクトリでjmxConnector型のオブジェクト・クラスを検索します。jmxConnectorオブジェクト・クラスのサービスURLと有効期日属性、attrとexpが取得され、expのチェックによりURLが有効期限内であることが確認され、JMXConnectorFactoryの呼出しにより新しいコネクタconnが作成されます。コネクタconnがコネクタのリストに追加され、MBeanサーバー内のServerで作成されたMBeanへのアクセスに使用されます。

JNDI/LDAP検索サービスの例題の設定

次の手順は、この例題で実行できる各種のコネクタ/トランスポートのすべての組合せで要求されます。

1. 初期設定で起動したLDAPサーバーを停止します。

2. JMXテクノロジのスキーマを、使用しているLDAPサーバーのschemaディレクトリにコピーします。

3. LDAPサーバーを再起動します

4. ServerがそのサービスURLを登録するルートを定義します。初期設定で作成したドメイン・コンポーネント・サフィックスdc=TestへのパスをServerに指定する必要があります。

   $ provider="ldap://$ldaphost:$ldapport/dc=Test"

5. 次のコマンドを入力して、例題のClientおよびServerクラスをコンパイルします。

   $ javac -d . -classpath $classp Server.java Client.java

サーバーの起動

Serverの起動に使用するコマンドは、使用している外部ディレクトリによって異なります。Clientを起動する前に、各種のトランスポートおよび外部レジストリを使用して、Serverの次のインスタンスの1つまたは複数を起動できます。

ここに示すトランスポートと外部ディレクトリの組合せは次のとおりです。

• 外部ディレクトリを使用しないJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

  $ java -classpath . -Ddebug=true \
    -Dagent.name=example-server-a \
    -Durl="service:jmx:rmi://" \
    -Djava.naming.provider.url="$provider" \
    -Djava.naming.security.principal="$principal" \
    -Djava.naming.security.credentials="$credentials" \
    jndi.Server &

  コマンドの説明は次のとおりです。

  • 　

    debug,はtrueに設定され、Serverの実行時の画面出力をより詳細なものにします。

  • 作成されるエージェントの名前はexample-server-aです。

  • エージェントが登録されるドメイン・コンポーネントのサフィックスを示すURL、providerが与えられます。

  • LDAPサーバーにアクセスするため、共通名の属性principalとパスワードcredentialsが与えられます。

  • サービスURLにより、RMIのデフォルトのJRMPトランスポート上で動作するRMIコネクタの選択が指定されます

  Serverが起動すると、RMIコネクタの作成、およびそのURLのJNDI/LDAP検索サービスへの登録を確認するメッセージが表示されます。

• RMIレジストリを外部ディレクトリとして使用するJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

  $ java -classpath . -Ddebug=true \ 
    -Dagent.name=example-server-b \ 
    -Durl="service:jmx:rmi:///jndi/${jndirmi}/server" \ 
    -Djava.naming.provider.url="$provider" \ 
    -Djava.naming.security.principal="$principal" \ 
    -Djava.naming.security.credentials="$credentials" \ 
    jndi.Server &

  コマンドの説明は次のとおりです。

  • 作成されるエージェントの名前はexample-server-bです。

  • エージェントが登録されるドメイン・コンポーネントのサフィックスを示すURL、providerが与えられます。

  • LDAPサーバーにアクセスするため、共通名の属性principalとパスワードcredentialsが与えられます。

  • サービスURLは、JRMP上のRMIとして選択されるコネクタを指定し、RMIコネクタ・スタブserverが保存される外部ディレクトリは、初期設定でjndirmiと特定したRMIレジストリです。

  Serverが起動すると、RMIコネクタの作成、およびそのURLのJNDI/LDAP検索サービスへの登録を確認するメッセージが表示されます。

• LDAPを外部ディレクトリとして使用するJRMP上のRMIコネクタ: 次のコマンドを入力してServerを起動します。

  $ java -classpath . -Ddebug=true \ 
    -Dagent.name=example-server-c \ 
    -Durl="service:jmx:rmi:///jndi/${jndildap}/cn=x,dc=Test" \ 
    -Djava.naming.provider.url="$provider" \ 
    -Djava.naming.security.principal="$principal" \ 
    -Djava.naming.security.credentials="$credentials" \ 
    jndi.Server &

  コマンドの説明は次のとおりです。

  • 作成されるエージェントの名前はexample-server-cです。

  • エージェントが登録されるドメイン・コンポーネントのサフィックスを示すURL、providerが与えられます。

  • LDAPサーバーにアクセスするため、共通名の属性principalとパスワードcredentialsが与えられます。

  • サービスURLは、RMI over JRMPとして選択されるコネクタを指定し、RMIコネクタ・スタブserverが保存される外部ディレクトリは、初期設定でjndildap と特定したRMIレジストリです。

  Serverが起動すると、RMIコネクタの作成、およびそのURLがエージェント名example-server-cでJNDI/LDAP検索サービスに登録されることの確認が表示されます。

クライアントの起動

選択したトランスポートおよび外部ディレクトリを使用してServerを起動した後、次のコマンドを入力してClientを起動します。

$ java -classpath . -Ddebug=true \ 
  -Djava.naming.provider.url="$provider" \ 
  -Djava.naming.security.principal="$principal" \ 
  -Djava.naming.security.credentials="$credentials" \ 
  jndi.Client

Serverで作成され検索サービスに登録されたエージェントの検出を確認する出力が表示されます。また、エージェントに設定された接続の接続名と、接続の確認が表示されます。

特定のエージェントを検索するには、次のコマンドを入力します。

$ java -classpath . -Ddebug=true \ 
  -Djava.naming.provider.url="$provider" \ 
  -Djava.naming.security.principal="$principal" \ 
  -Djava.naming.security.credentials="$credentials" \ 
  -Dagent.name=agentName \ 
  jndi.Client 

前述のコマンドで、agentNameは検索するエージェントの名前です。また、*;を使用してエージェント名を部分的に指定することもできます。たとえば、文字xで始まるすべてのエージェント名を検索する場合は、 x*と指定します。