2012-06-18 2 views
0

У меня есть две программы, первый производитель:тест с Jmeter для потребителя и производителя

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 минуту, помогите мне пожалуйста.

ответ

2

Вам понадобится создать какой-то Custom Java Sampler. При создании одного из них вы можете вызвать свой код изнутри, установить таймеры запуска/завершения, если запрос был успешным/неудачным и т. Д. Затем вы помещаете это jar в JMeter, и он появится как Java Sampler. Отсюда вы можете использовать все функции JMeter для указания пользователей, запросов, временных ограничений и т. Д.

Надеюсь, этого достаточно, чтобы помочь вам.

Смежные вопросы