java - 使用 Jmeter 对消费者和生产者进行测试

Question

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

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测试一下，了解consumer在1分钟内可以消费多少消息，请帮助我。

Answer 1

您将需要创建某种 Custom Java Sampler.创建其中之一时，您可以从内部调用代码，设置开始/结束计时器，请求是否成功/失败等。然后，将此 jar 放入 JMeter 中，它将显示为 Java Sampler。从这里，您可以使用 JMeter 的所有功能来指定用户、请求、时间限制等。

我希望这足以为您提供帮助。