アプリケーションの止め方 その２

その１は以前commons-daemon書いたときの方法だけど
文字列入力する方法は分かりにくいので、（どこに入力するか迷う）
Ctrl + zとした。というかreadLine()がnullの場合。


macだとCtrl + dとか。

public static void main(String[] args) throws IOException {
        // the main routine is only here so I can also run the app from the
        // command line

        BufferedReader stdReader = new BufferedReader(new InputStreamReader(
                System.in));
        System.out.print("Enter 'Ctrl + z' to halt: ");
        while (stdReader.readLine() != null) { // ユーザの入力を待つ
            ;
        }
    }

StringでSOAP通信

wsdlからwsimportを使って自動生成したJavaクラスSayHelloを使って、SOAPメッセージ(xml)をString型で生成し、
そのStringをURLConnectionでHTTP送受信する。
で、レスポンスをStringにして
SOAPMessageに戻す。

SOAPMessageからSOAPEnvelopeの子要素をorg.w3c.dom.Nodeオブジェクトで取得。
最後に、JAXBのUnmarshallでNodeからSayHelloResponse（wsimportで生成されたSOAPの応答のクラス）に変換する。
あとは、いつものSOAPです。


以上！ ソースが汚すぎるから、明日整形しましょうかね。

/**
 * 
 */
package jp.blogspot.tanakanbb;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.StringWriter;
import java.net.URL;
import java.net.URLConnection;

import javax.xml.bind.JAXBContext;
import javax.xml.bind.Marshaller;
import javax.xml.bind.Unmarshaller;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPMessage;
import javax.xml.soap.SOAPPart;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;

import org.w3c.dom.Document;

import com.tanakanbb.sample.soap.SayHello;
import com.tanakanbb.sample.soap.SayHelloResponse;

public class JaxWSExecutor {

 public static void main(String[] args) throws Exception {

  DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
  dbf.setNamespaceAware(true);
  Document doc = dbf.newDocumentBuilder().newDocument();

  JAXBContext context = JAXBContext.newInstance(SayHello.class);
  Marshaller marshaller = context.createMarshaller();
  marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);

  SayHello sayHello = new SayHello();

  sayHello.setName("hoge");

  marshaller.marshal(sayHello, doc);

  // We now have a DOM tree which has been populated by JAX-B
  MessageFactory factory = MessageFactory.newInstance();
  SOAPMessage message = factory.createMessage();
  message.getSOAPBody().addDocument(doc);

  message.saveChanges();

  ByteArrayOutputStream outputStream = new ByteArrayOutputStream();

  message.writeTo(outputStream);

  String xml = outputStream.toString("utf-8");

  // <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"><SOAP-ENV:Header/><SOAP-ENV:Body><sayHello xmlns="http://soap.sample.tanakanbb.com"><name>hoge</name></sayHello></SOAP-ENV:Body></SOAP-ENV:Envelope>
  System.out.println(xml);
  try {
   URL url = new URL(
     "http://localhost:8084/soap_sample/services/Hello");

   URLConnection con = url.openConnection();

   // 送信するよ！指定
   con.setDoOutput(true);

   con.setRequestProperty("Content-Type", "application/soap+xml");
   con.setRequestProperty("SoapAction", "");

   // --------------------
   // 送信する
   // --------------------
   OutputStreamWriter ow1 = new OutputStreamWriter(con
     .getOutputStream());
   BufferedWriter bw1 = new BufferedWriter(ow1);

   // POSTの内容を書き出す
   bw1.write(xml);

   // クローズ
   bw1.close();
   ow1.close();

   // --------------------
   // 受信する
   // --------------------
   InputStreamReader ir1 = new InputStreamReader(con.getInputStream());
   BufferedReader br1 = new BufferedReader(ir1);

   ByteArrayOutputStream ba = new ByteArrayOutputStream();
   // １行ずつ書き出す
   int b;
   while ((b = br1.read()) != -1) {
    ba.write(b);
   }

   String response = ba.toString("utf-8");

   // クローズ
   br1.close();
   ir1.close();
   ba.close();

   // <?xml version="1.0" encoding="UTF-8"?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse></soapenv:Body></soapenv:Envelope>
   System.out.println(response);

   // Create SoapMessage
   MessageFactory msgFactory = MessageFactory.newInstance();
   SOAPMessage message2 = msgFactory.createMessage();
   SOAPPart soapPart = message2.getSOAPPart();

   // Load the SOAP text into a stream source
   byte[] buffer = response.getBytes();
   ByteArrayInputStream stream = new ByteArrayInputStream(buffer);
   StreamSource source = new StreamSource(stream);

   // Set contents of message
   soapPart.setContent(source);

   // -- DONE
   // <?xml version="1.0" encoding="UTF-8"?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse></soapenv:Body></soapenv:Envelope>
   message2.writeTo(System.out);

   System.out.println("");

   org.w3c.dom.Node srcNode = message2.getSOAPPart().getEnvelope()
     .getBody().getFirstChild();

   StringWriter writer = new StringWriter();

   Transformer transformer = TransformerFactory.newInstance()
     .newTransformer();
   transformer.transform(new DOMSource(srcNode), new StreamResult(
     writer));

   // <?xml version="1.0" encoding="UTF-8"?><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse>
   System.out.println(writer.toString());

   JAXBContext context2 = JAXBContext
     .newInstance(SayHelloResponse.class);

   Unmarshaller m = context2.createUnmarshaller();
   Object obj = m.unmarshal(srcNode);
   SayHelloResponse ret = (SayHelloResponse) obj;

   // Hello!, hoge
   System.out.println(ret.getSayHelloReturn());

  } catch (Exception e) {
   e.printStackTrace();
  }

 }
}

commons-daemon 第3回

Windowsでのサービス登録方法 公式ページを参考にしてもどうにも動かないので、ちょっと頑張りが必要でした。 　公式ページ　→　Daemon: Procrun

jarの作成

前回作成したJavaをJarにします。
ここでは面倒なので、Eclipseのエクスポート機能を使います。

成果物：EngineLauncher.jar

場所

とりあず、C:\tmp\test-serviceを作ります。
で、libフォルダにcommons-daemon-1.0.10.jar、commons-logging-1.1.1.jar、log4j-1.2.16.jarを入れ
logsフォルダも作っておきます。
あと、commons-daemon-1.0.10-bin-windows.zipをダウンロードしてあるはずなので、
その中にあるprunsrv.exeもC:\tmp\test-serviceに入れておきます。

C:\tmp\test-service
│  EngineLauncher.jar
│  install.bat
│  prunsrv.exe
│  uninstall.bat
│  
├─lib
│      commons-daemon-1.0.10.jar
│      commons-logging-1.1.1.jar
│      log4j-1.2.16.jar
│      
└─logs
        commons-daemon.2012-04-04.log
        testservice-stderr.2012-04-04.log
        testservice-stdout.2012-04-04.log

サービスへの登録バッチ

--Jvmオプションでjvm.dllの場所を指定するのですが、autoでうまく動かず、直接指定しました。autoのはずだと思うのですが…

set EXEC_DIR=%~dp0
echo %EXEC_DIR%
set CLASSPATH_DIR=%EXEC_DIR%lib
echo %CLASSPATH_DIR%
set CLASSPATH=%EXEC_DIR%EngineLauncher.jar;%CLASSPATH_DIR%\commons-daemon-1.0.10.jar;%CLASSPATH_DIR%\commons-logging-1.1.1.jar;%CLASSPATH_DIR%\log4j-1.2.16.jar;
echo %CLASSPATH%
set JVM_PATH="C:\Program Files\Java\jdk1.6.0_31\jre\bin\server\jvm.dll"

prunsrv //IS//TestService --DisplayName="Test Service" ^
        --Startup=auto ^ --Jvm=%JVM_PATH% --StartMode=jvm --StopMode=jvm ^
        --Classpath=%CLASSPATH% ^
        --StartClass=jp.tanakanbb.blogspot.daemon.service.sample.EngineLauncher --StartParams=start ^
        --StartMethod=windowsService ^
        --StopClass=jp.tanakanbb.blogspot.daemon.service.sample.EngineLauncher --StopParams=stop ^
        --StopMethod=windowsService ^
        --LogPath=%EXEC_DIR%logs --LogLevel=DEBUG ^
        --StdOutput=auto --StdError=auto ^
        
        

pause

サービスへの削除バッチ

prunsrv //DS//TestService

pause

手順

install.batを実行すると、サービスに登録され、管理ツールからサービスを開いて、"Test Service"を開始すればサービスが始まります。
停止すれば止まります。
アンインストールは、uninstall.batです。

--Startup=autoだけど、install.batを実行しても開始されません...

追加で

commons-logging.properties

org.apache.commons.logging.Log=org.apache.commons.logging.impl.Log4JLogger

log4j.xmlはこんなかんじ。/var/log/daemon/application.logにログ出力します。

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">

<log4j:configuration xmlns:log4j='http://jakarta.apache.org/log4j/'>

  <!-- ********************** 標準出力への出力 ********************** -->
  <appender name="STDOUT" class="org.apache.log4j.ConsoleAppender">
    <param name="threshold" value="info"/>

    <!-- レイアウトの指定 -->
    <layout class="org.apache.log4j.PatternLayout">
      <param name="ConversionPattern"
             value=""%d{yyyy/MM/dd HH:mm:ss.SSS}",%p,%c,%M,%L,%m%n" />
    </layout>
  </appender>

  <!-- ********************** ファイルへの出力 ********************** -->
  <appender name="FILE" class="org.apache.log4j.DailyRollingFileAppender">
    <param name="threshold" value="debug"/>

    <!-- ファイル情報 -->
    <param name="file" value="/var/log/daemon/application.log" />

    <param name="append" value="false" />
    <param name="datePattern" value="'.'yyyy-MM-dd" />

    <!-- レイアウトの指定 -->
    <layout class="org.apache.log4j.PatternLayout">
      <param name="ConversionPattern"
             value=""%d{yyyy/MM/dd HH:mm:ss.SSS}",%p,%c,%M,%L,%m%n" />
    </layout>
  </appender>

  <!-- ********************** category定義 ************************* -->
  <category name="jp.tanakanbb.blogspot">
    <priority value="debug" />
    <appender-ref ref="FILE" />
  </category>

  <!-- ********************** root定義 ***************************** -->
  <root>
    <priority value="debug" />
    <appender-ref ref="STDOUT" />
  </root>

</log4j:configuration>

commons-daemon 第2回

まずはjavaソースから。 以下のwikiを参考にしてます。

参考　Daemon - Commons Wiki

ただ、肝心な部分がよく分からなかったので、カスタマイズしてます。 まずは、Daemonインターフェースを実装したクラス。
EngineLauncher クラスが本体で、こいつがEngine（インターフェースを実装した）クラスを起動してメイン処理を実行します。
停止するときも、Engine（インターフェースを実装した）クラスを停止します。

EngineLauncher

Windowsのサービスとして動くときは、windowsServiceを使用します。
procrun.exeは、public staticメソッドしか呼ぶことができません。
そして、実行時には引数を渡すことができますので
開始時には、"start"、停止時には"stop"を渡すことで、それぞれstartWindowsServiceとstopWindowsServiceメソッドを呼び出します。

mainメソッドはおまけです。使用しません。

Linuxで使用するjsvcでは、Daemonインターフェースを実装していると、
最初にinitが呼ばれ、続いてstartメソッドが呼ばれます。
停止するときは、"-stop"オプションをつけてjsvcを実行することでstopメソッドが呼び出されます。

package jp.tanakanbb.blogspot.daemon.service.sample;

import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import jp.tanakanbb.blogspot.daemon.service.sample.impl.SampleEngineImpl;

import org.apache.commons.daemon.Daemon;
import org.apache.commons.daemon.DaemonContext;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

public class EngineLauncher implements Daemon {

    /**
     * ログ
     */
    private static Log LOG = LogFactory.getLog(EngineLauncher.class);

    /**
     * エンジン
     */
    private static Engine engine = null;

    /**
     * エンジン起動
     */
    private static EngineLauncher engineLauncherInstance = new EngineLauncher();

    /**
     * Executor
     */
    private ExecutorService executor = null;

    /**
     * The Java entry point.
     *
     * @param args
     *            Command line arguments, all ignored.
     */
    public static void main(String[] args) {
        // the main routine is only here so I can also run the app from the
        // command line
        engineLauncherInstance.initialize();

        engineLauncherInstance.startWindowsService();

        Scanner sc = new Scanner(System.in);
        // wait until receive stop command from keyboard
        System.out.printf("Enter 'stop' to halt: ");

        while (!sc.nextLine().toLowerCase().equals("stop")) {
            ;
        }

        engineLauncherInstance.stopWindowsService();

    }

    /**
     * Windowsサービスを起動します。<br>
     * サービス登録するときのパラメータは次のようです。
     *
     * <pre>
     * --StartMode=jvm --StartClass=jp.tanakanbb.blogspot.daemon.service.sample.EngineLauncher --StartMethod=windowsService --StartParams=start --StopMode=jvm --StopClass=jp.tanakanbb.blogspot.daemon.service.sample.EngineLauncher --StopMethod=windowsService --StopParams=stop
     * </pre>
     *
     * Windowsサービス、つまりprocrunで起動する場合、実行するメソッドは"public static void"である必要があります。<br>
     * voidでなくてもいいかもしれませんが、戻り値を解釈しないので、voidがいいと思います。
     *
     * @param args
     *            Arguments from prunsrv command line
     **/
    public static void windowsService(String args[]) {
        String cmd = "start";
        if (args.length > 0) {
            cmd = args[0];
        }

        if ("start".equals(cmd)) {
            engineLauncherInstance.startWindowsService();
        } else {
            engineLauncherInstance.stopWindowsService();
        }
    }

    /**
     * Windowsサービスの場合のスタートメソッド。<br>
     * Engine#execute()を起動します。
     */
    public void startWindowsService() {
        if (LOG.isDebugEnabled()) {
            LOG.debug("startWindowsService called");
        }

        initialize();
        // don't return until stopped
        executor.execute(engine);
    }

    /**
     * Windowsサービスを停止します。
     */
    public void stopWindowsService() {
        if (LOG.isDebugEnabled()) {
            LOG.debug("stopWindowsService called");
        }

        terminate();

        executor.shutdown();
    }

    /**
     * Implementing the Daemon interface is not required for Windows but is for
     * Linux<br>
     * jsvcでの起動時に最初に呼ばれます。<br>
     * {@link Daemon#init(DaemonContext)}
     */
    @Override
    public void init(DaemonContext arg0) throws Exception {
        LOG.debug("Daemon init");
    }

    /**
     * jsvcでの起動時に、{@link Daemon#init(DaemonContext)}の次に呼ばれます。
     */
    @Override
    public void start() {
        if (LOG.isDebugEnabled()) {
            LOG.debug("Daemon start");
        }
        initialize();
    }

    /**
     * jsvcでの-stopオプション時に呼ばれます。
     */
    @Override
    public void stop() {
        if (LOG.isDebugEnabled()) {
            LOG.debug("Daemon stop");
        }

        terminate();
    }

    /**
     * {@link Daemon#stop()}後に呼ばれます。
     */
    @Override
    public void destroy() {
        if (LOG.isDebugEnabled()) {
            LOG.debug("Daemon destroy");
        }
    }

    /**
     * Engineを初期化します。<br>
     * WindowsでもLinuxでも、最初にこれを呼ぶ必要があります。 Do the work of starting the engine
     */
    private void initialize() {
        if (engine == null) {
            if (LOG.isInfoEnabled()) {
                LOG.info("Starting the Engine");
            }
            engine = new SampleEngineImpl();
        }

        executor = Executors.newSingleThreadExecutor();
    }

    /**
     * Windowsサービス、デーモンを停止します。 WindowsでもLinuxでも、停止時には、これを呼ぶ必要があります。 Cleanly stop
     * the engine.
     */
    public void terminate() {
        if (engine != null) {
            if (LOG.isInfoEnabled()) {
                LOG.info("Stopping the Engine");
            }

            engine.stop();

            if (LOG.isInfoEnabled()) {
                LOG.info("Engine stopped");
            }
        }
    }

}

Engine

package jp.tanakanbb.blogspot.daemon.service.sample;

public interface Engine extends Runnable {

    public void stop();

    public Boolean isStopped();

}

SampleEngineImpl

package jp.tanakanbb.blogspot.daemon.service.sample.impl;

import jp.tanakanbb.blogspot.daemon.service.sample.Engine;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

public class SampleEngineImpl implements Engine {

    /**
     * ログ
     */
    private static Log LOG = LogFactory.getLog(SampleEngineImpl.class);

    /**
     * 停止フラグ
     */
    private Boolean isStopped = Boolean.FALSE;

    /**
     * スレッドID
     */
    private String id = null;

    @Override
    public void stop() {
        this.isStopped = Boolean.TRUE;
    }

    @Override
    public Boolean isStopped() {
        return isStopped;
    }

    @Override
    public void run() {

        this.id = String.valueOf(Thread.currentThread().getId());

        while (!isStopped()) {
            if (LOG.isInfoEnabled()) {
                LOG.info("[" + id + "]" + "hoge");
            }

            try {
                Thread.sleep(10000);
            } catch (InterruptedException e) {
                isStopped = Boolean.TRUE;
                if (LOG.isErrorEnabled()) {
                    LOG.error(e);
                }
            }
        }
    }

}

さて、第3回では、Windowsサービスへの登録方法とLinuxデーモン化方法を書きたいと思います。

commons-daemon [第1回]

Javaでも常駐プロセスを、つまりデーモンを作りたいときもある。
もしくは、Windowsサービスを作りたいときもある。

そんなとき、やっぱり常駐するだけあって、実績のあるものを使いたい！！（←本音）

ということで選択したのはtomcatでも採用されている「commons-daemon」

しかし、情報が少ない。 日本語も少ないし、英語も少ない（全部読んだわけではないけど）。

というわけで、自分で書いてみる。

第1回目は目標を掲げます。

目標

LinuxでもWindowsでも動くデーモンorサービスを作る

準備

次のサイトからダウンロードします。※1.0.10使います。 Commons Daemon Download

1. [Commons Daemon Binaries] commons-daemon-1.0.10-bin.tar.gz
2. [Browse native binaries download area...] commons-daemon-1.0.10-bin-windows.zip
3. [Commons Daemon Source] commons-daemon-1.0.10-native-src.tar.gz

1番目は実装するときに使います。
2番目はWindowsサービス化で使います。
3番目はLinuxデーモン化で使います。
第2回はいきなりソース公開します。

Javaテンプレートエンジン [Mayaa]

pythonとか使ってて思うことですが、
強力なテンプレートエンジンがあるってことは
その言語の魅力だなーと。

で、Javaには無いのかーってことで
Mayaa

結構気になってたんだけど
なかなか使う機会なく,,,


ちゃんとドキュメント読んだのは初めてですが、
これはいい！と思ったのはレイアウト。

レイアウト共有

JSPだと、各ページ共通のものをincludeでガチガチ書かないとダメですが、
このレイアウトの発想を待ってました！

要は、基本となるlayout.htmlがあって、
各ページで異なる部分をそこにインサートしていく、と。


詳細は次回。

JNDI -JNDIへの登録-

JNDIの2回目

いまいち理解できないので、
ちゃんと流れを追うことにした。

参考：

まず、JNDIを使うには、JNDIへ情報を登録する必要がある。
登録してあって、初めて使うことが出来る。

で、登録の方法。

例としては、
DataSourceオブジェクトの登録
File Systemサービスプロバイダを使用するJNDIへの登録例

1. システムプロパティを取得する
Properties sys_prop = System.getProperties();

2. File Systemサービスプロバイダのプロパティを設定する
sys_prop.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.fscontext.RefFSContextFactory");

3. File Systemサービスプロバイダで使用するディレクトリを設定する (この場合，c:\JNDI_DIRの下に登録される)
sys_prop.put(Context.PROVIDER_URL, "file:c:"+File.separator + "JNDI_DIR");

4. システムプロパティを更新する
System.setProperties(sys_prop);

5. JNDIを初期化する
Context ctx = new InitialContext();

6. DataSourceオブジェクトを，jdbc/TestDataSourceという論理名称でJNDIに登録する
ctx.bind("jdbc" + File.separator + "TestDataSource", ds);

まだ理解が追いつかない...
でも、とりあえず次は情報の取得を調べてみよう。
J2EEコンテナは、設定ファイルで登録できるらしいからなー

JNDI -いまさら-

JNDIをちゃんと勉強しようと思った。

こんなソースを触ってたら、
「やっぱりちゃんと勉強しよう」と。

InitialContext ictx = new InitialContext();
DataSource ds = (DataSource) ictx.lookup("java:comp/env/jdbc/SampleDS");


JNDIを使うと、様々なネーミングサービス、ディレクトリサービスにアクセスすることができるとのこと。
で、ネーミングサービス、ディレクトリサービスとは？

ネーミングサービス

・文字列で表現される名前と特定のオブジェクトとを関連づけるサービス
・名前を指定するとそれに対応するオブジェクトを得ることができる

ディレクトリサービス

・住所録や電話帳などのように、住所や氏名などの様々な情報を効率的に管理し、その情報を更新したり検索したりすることができるようにするサービス
・電話帳で名前から電話番号が探し出せるように、ディレクトリサービスを利用することで簡単にほしい情報を得ることができる

うーん、いまいち分からない。。。
使用の手順は、

手順

1. Propertiesオブジェクトを用意する。


2. PropertiesにINITIAL_CONTEXT_FACTORYをputする。


3. 同様にPROVIDER_URLをputする。


4. Propertiesを引数としてInitialContext（またはInitialDirContext）をnewする。


5. InitialContextやInitialDirContextを利用して、bindしたりlookupしたりする。

やっぱり難しい。
どうやら、InitialContextがポイントになるみたい。
次はInitialContextを調べてみようと思う。