JMeterカスタムサンプラー - 複数のrunTestと同じ接続を共有

Question

AbstractJavaSamplerClientを拡張してカスタムサンプラーの作成に成功しました。サンプラーの実装では、JMS接続を作成してメッセージをキューに送信しています。これは素晴らしい作品です。ランプグループ1をランプアップ1で100に設定すると、サンプラーは100個のメッセージをプッシュしています。

私がやりたかったのは、JMeterの起動時に一度だけ接続を作成してから、同じ接続を再利用して実行ごとにメッセージを送信することでした。

誰でもJMeterの起動時に接続を作成し、サンプラーと同じ接続を共有する方法を説明できます。

注：JMSにメッセージを公開する時間を計算するだけでなく、さまざまなアプリケーションイベントに基づいて応答時間を計算したいので、既存のJMSパブリッシャーを使用することはできません。

ありがとうございます。

Answer 1

testStarted methodを使用すると、すべてのスレッドの接続を初期化できます。このメソッドは、スレッドがクローンされる前に一度だけ実行されるので、testStartedには接続プールが必要です。スレッドはそれから取得できます。たとえば、非常にプリミティブな接続プールは、キーと接続オブジェクトのいくつかのシーケンシャルIDを持つマップになります。各スレッドは、スレッドの数に基づいて、そのプールからの接続を1つ取る：

をので、このようなシンプルなプールのように初期化することができます。

@Override 
public void testStarted() 
{ 
    int maxConnections = getThreadContext().getThreadGroup().getNumThreads(); 

    ConcurrentMap<Integer, Object> connections = new ConcurrentHashMap<Integer, Object>(); 

    for(int i = 0; i < maxConnections; i++) 
    { 
     Object connection = //... whatever you need to do to connect 
     connections.put(new Integer(i), connection); 
    } 

    // Put in the context of thread group 
    JMeterContextService.getContext().getVariables().putObject("MyConnections", connections); 
} 

（接続オブジェクトは、あなたのニーズに基づいて、より具体的なタイプとすることもできます） 。私は単純にスレッド実行時に返される数値と私は、接続の初期化のために使用される初期シーケンシャル整数間の完全なマッピングを想定し

ここ

// Get connections pool from context 
ConcurrentMap<Integer, Object> connections = (ConcurrentHashMap<Integer, Object>) JMeterContextService.getContext().getVariables().getObject("MyConnections"); 
// Find connection by thread ID, so each thread goes to a different connection 
connections.get(getThreadContext().getThreadNum()); 

：

後で、sample方法でそれを使用することができます。最良の仮定ではなく、改善することができますが、有効な出発点です。

testEnded methodで接続を閉じて削除できます。この方法は、また、一度実行しますので、我々はすべての接続を閉じる：

@Override 
public void testEnded() 
{ 
    for(Entry<Integer, Object> connection : connections.entrySet()) 
    { 
     connection.close(); // or do whatever you need to close it 
     connections.remove(connection.getKey()); 
    } 
} 

またはすべての接続が閉じているときにだけconnections.clear()を呼び出すことができます。

開示：私はこの回答のコードを直接テストしませんでしたが、過去に同様のコードの断片を使用して、この質問に答えるために再利用しました。問題が見つかった場合は、この回答を更新してください。