技術めも

負荷試験をやっていると、

他人の状態を保持して、

その状態に応じて処理を行うということがある。

たとえば、

• AさんがBさんに友達の申請をする
• BさんがAさんの友達申請を許可する

という場合など。

これをjmeterで試験する場合、

「BさんがAさんの友達申請を許可する」という処理は、

「AさんがBさんに友達の申請をする」が完了していないと成功しない。

そのためには、BさんはAさんの状態を取得する必要がある。

ここで、

AさんのIDを1

BさんのIDを2

とし、

jmeterのBSF（javascript）を使うと、

＜（PostProcesser）AさんがBさん友達申請をする＞

// 自分のID
var my_id = 1;

// 他人のID
var other_id = 2;

//　レスポンスを取得 して申請が成功しているなら
// Bさんの情報にAさんが申請したことを記録
var key = "appley-to-" + other_id;
var value = my_id;
props.put(key, value);

＜（PreProcesser）BさんがAさんの友達申請を許可する＞

// 自分のID
var my_id = 2;

// 他人のID
var other_id = 1;

// BさんがAさんからの申請状態を取得
var key = "appley-to-" + my_id;
while (true) {
    var value = props.get(key);
    if (value != void(0)) {
        // 申請状態がとれたら、ループを抜ける
        break;
    }
}

// 許可処理を実行

という具合になる。

注意点としては、

jmeterが起動中は、

propsの値は常に保持されるので、

不要になったら、removeしておく必要がある。

もしくは、初期化処理でremoveしてから利用するなど。

もう1つ注意点としては、

永久ループで待機する場合は、

スレッドを停止しても処理が停止しないので、

何回かループしたら止めるとかを入れておいた方がよい。

あとは、カウンタとか、forEachループなどを組み合わせることで、

もっと複雑な処理が可能になる。

以上です。

まあ、小ネタだね。

実行可能warをmavenで作る場合、

warパッケージの直下にmainファイルを配備する必要がある。

しかし、warアプリケーションをpackageすると、

WEB-INF/classes以下にmainファイルも配備されてしまう。

そのため、maven3では、

antrunプラグインを用いて、mainファイルを移動する必要がある。

pom.xmlはこんな感じかな。

      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-antrun-plugin</artifactId>
        <executions>
          <execution>
            <id>move-main</id>
            <phase>prepare-package</phase>
            <configuration>
              <tasks>
                <move todir="target/${project.build.finalName}">
                  <fileset dir="target/classes">
                    <include name="app/AppMain.class" />
                  </fileset>
                </move>
              </tasks>
            </configuration>
            <goals>
              <goal>run</goal>
            </goals>
          </execution>
        </executions>
      </plugin>

これにより、warファイル直下に実行可能クラスが配備される。

また、jettyなどのembedを組み込む場合、

一緒に依存関係も持って行ってやる必要がある。

こんな感じ。

      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-dependency-plugin</artifactId>
        <executions>
          <execution>
            <id>jetty-classpath</id>
            <phase>prepare-package</phase>
            <goals>
              <goal>unpack-dependencies</goal>
            </goals>
            <configuration>
              <includeGroupIds>org.eclipse.jetty,javax.servlet,javax.websocket</includeGroupIds>
              <excludes>META-INF/ECLIPSEF.*</excludes>
              <outputDirectory>${project.build.directory}/${project.build.finalName}</outputDirectory>
            </configuration>
          </execution>
        </executions>
      </plugin>

そして、mainファイルはこんな感じ。

package app;

import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.webapp.WebAppContext;
import org.eclipse.jetty.websocket.jsr356.server.deploy.WebSocketServerContainerInitializer;

import java.net.URL;

public class AppMain {

  public static void main(String[] args) throws Exception {
    // 初期設定
    int port = 8080;
    System.setProperty("prefix", "/");

    // サーバ生成
    Server server = new Server(port);

    // warを読み込むコンテクスト生成
    URL warUrl = AppMain.class.getProtectionDomain().getCodeSource().getLocation();
    String warLocation = warUrl.toExternalForm();
    WebAppContext context = new WebAppContext();
    context.setWar(warLocation);
    context.setContextPath("/");

    // コンテクストにサーバをセットする
    // ※重要
    context.setServer(server);

    // websocketを使えるようにする
    WebSocketServerContainerInitializer.configureContext(context);

    // 開始
    server.setHandler(context);
    server.start();
    server.join();
  }
}

上記が非常に重要。

これで、websocketのendpointをServletContextListener側で指定してやるとうまくいく。

package app;

import websocket.WebsocketIndex;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.websocket.DeploymentException;
import javax.websocket.server.ServerContainer;

public class AppInitializeListener implements ServletContextListener {

  @Override
  public void contextInitialized(ServletContextEvent sce) {
    // embed用のwebsocketの追加
    try {
      ServerContainer wsContainer = (ServerContainer) sce.getServletContext().getAttribute(ServerContainer.class.getName());
      System.out.println(String.format("wsContainer => %s", wsContainer));
      if (wsContainer != null) {
        wsContainer.addEndpoint(WebsocketIndex.class);
      }
    } catch (DeploymentException e) {
      e.printStackTrace();
    }
  }

  @Override
  public void contextDestroyed(ServletContextEvent sce) {
  }
}

実行可能jarでwebsocketを作成する場合、

mainクラス内でendpointを設定してやればよいのだが、

実行可能warの場合、

mainクラスが実際のwebsocketのendpointのクラスの配備位置が異なるため、

クラスのロードが出来ない状態となる。

そのため、上記のような方法で、動的に指定してやることで、

実行可能warにおいて、websocketが利用できる。

【参考】

・実行可能warの生成の詳細がかかれています。

http://qiita.com/k_ui/items/1d3bbbd7993c4c9adf71

・実行可能jarでのwebsocketの設定方法が書かれています。

https://github.com/jetty-project/embedded-jetty-websocket-examples/blob/master/javax.websocket-example/src/main/java/org/eclipse/jetty/demo/EventServer.java

以上