0

私は2つのプログラムを持っています.1つ目はプロデューサーです:

public class Producer {
    public static void main(String[] args) throws Exception {
        final ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://localhost:12345");
        final Connection c = cf.createConnection();
        final Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);
        final TextMessage msg = s.createTextMessage("rho " + new Date().toString());
        final MessageProducer p = s.createProducer(new ActiveMQQueue("rmannibucau"));
        p.send(msg);
        p.close();
        s.close();
        c.close();
        }
}

2 つ目は消費者です。

public class Listener {
    public static void main(String[] args) throws Exception {
        final ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://localhost:12345");
        final Connection c = cf.createConnection();
        final Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);
        s.createConsumer(s.createQueue("rmannibucau")).setMessageListener(new MessageListener() {

        @Override
        public void onMessage(Message message) {
            System.out.println(message.toString());
        }
    });

    c.start();
    s.run();
    }
}

私は ActiveMQ、java、jms を使用しており、Jmetter を使用してテストして、消費者が 1 分間に消費できるメッセージの量を知りたいと思っています。助けてください。

4

1 に答える 1

2

ある種のカスタム Java サンプラーを作成する必要があります。これらのいずれかを作成するときは、内部からコードを呼び出したり、開始/終了タイマーを設定したり、リクエストが成功/失敗した場合などに使用したりできます。次に、この jar を JMeter に配置すると、Java サンプラーとして表示されます。ここから、JMeter のすべての機能を使用して、ユーザー、リクエスト、時間制限などを指定できます。

これがあなたを助けるのに十分な出発点であることを願っています.

于 2012-06-18T21:45:20.863 に答える