0

我有两个程序，第一个是制作人：

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();
        }
}

第二个是消费者：

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 回答