Использование Spring Framework для RabbitMQ снижает производительность

Question

Я создал продюсера, который использовал com.rabbitmq.client.connectionFactory и отправлял 1 000 000 сообщений (40 байт) за 100 секунд.

Но теперь я хочу весеннюю абстракцию. Я не смог использовать com.rabbitmq.client.connectionFactory, скорее, мне пришлось использовать org.springframework.amqp.rabbit.connection.SingleConnectionFactory. При использовании этой фабрики соединений брокеру за 100 секунд отправляется только 100 000 сообщений (40 байт).

Есть ли у кого-нибудь опыт, почему производительность снижается так сильно (около 90%).

Код с использованием «import com.rabbitmq.client.ConnectionFactory;» это ->

package Multiple_queues_multiple_consumers;
import java.io.IOException;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class Producer {
    private static Connection myConnection;
    private static Channel myChannel;
    public static String myQueueName;

    public static void main(String[] args) throws IOException {
        long startTime=0;
        int count=0;
        ConnectionFactory myFactory=new ConnectionFactory();
        myFactory.setHost("localhost");
        try {
            myConnection = myFactory.newConnection();
            myChannel = myConnection.createChannel();
            String myExchange = "wxyzabc";
            String myBody = "This is a message : message numberxxxxxx";
            String myRoutingKey = "RoutingKey";
            myQueueName = "new_Queue";
            myChannel.exchangeDeclare(myExchange, "direct", true, false, null);
            myChannel.queueDeclare(myQueueName, true, false, false, null);
            myChannel.queueBind(myQueueName, myExchange, myRoutingKey);
            startTime=System.currentTimeMillis();
            AMQP.BasicProperties properties = new AMQP.BasicProperties();
            properties.setDeliveryMode(2);
            startTime=System.currentTimeMillis();
            while(count++<=10000){
                myChannel.basicPublish(myExchange, myRoutingKey, true, true, properties, myBody.getBytes() );
            }
            System.out.println(System.currentTimeMillis()-startTime);
        } catch (Exception e){
            System.exit(0);
        }
    }
}

Код с использованием SpringFramework: ->

Producer1.java

import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Producer1 {
    public static void main(String[] args) {

        ConfigurableApplicationContext context = new         ClassPathXmlApplicationContext("Producer1.xml");
    AmqpAdmin amqpAdmin = context.getBean(RabbitAdmin.class);
    Queue queue = new Queue("sampleQueue");
    DirectExchange exchange = new DirectExchange("myExchange");
    Binding binding = new Binding(queue, exchange, "");
    amqpAdmin.declareQueue(queue);
    amqpAdmin.declareExchange(exchange);
    amqpAdmin.declareBinding(binding);
    RabbitTemplate rabbitTemplate = context.getBean(RabbitTemplate.class);
    String routingKey = "";
    String myBody = "This is a message : message numberxxxxxx";
    Message Msg = new Message(myBody.getBytes(), null);
    int count=0;
    long CurrTime = System.currentTimeMillis();
    while(count++<=10000){
        rabbitTemplate.send(routingKey, Msg);
        //System.out.println("Message Sent");
    }
    System.out.println(System.currentTimeMillis()-CurrTime);
}
}

Producer1.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" 
xmlns:p="http://www.springframework.org/schema/p" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context" 
xsi:schemaLocation="http://www.springframework.org/schema/beans     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">


<!-- Define a connectionFactory -->
<bean id="rabbitConnectionFactory" class="com.rabbitmq.client.ConnectionFactory">
<property name="host" value="localhost" />
</bean>

<bean id="connectionFactory"         class="org.springframework.amqp.rabbit.connection.SingleConnectionFactory">
<constructor-arg ref="rabbitConnectionFactory"/>
</bean>

<!-- Tell the Admin bean about that connectionFactory and initialize it, create a     queue and an exchange on Rabbit Broker using the RabbitTemplate provided by Spring framework-Rabbit APIs -->
<bean id="Admin" class="org.springframework.amqp.rabbit.core.RabbitAdmin">
<constructor-arg ref="connectionFactory" />
</bean>

<bean id="rabbitTemplate" class="org.springframework.amqp.rabbit.core.RabbitTemplate"
p:connectionFactory-ref="connectionFactory"
p:routingKey="myRoutingKey"
p:exchange="myExchange" />

</beans>

Answer 1

Вы уверены, что использовали одного и того же брокера Rabbit MQ? Может быть, вы используете брокера на другом сервере или обновленную / пониженную версию RabbitMQ?

Другая вещь, на которую стоит обратить внимание, это ваш jvm. Возможно ли, что у вас недостаточно настроенной памяти, и теперь сборщик мусора работает? Запустите top и посмотрите, близко ли использование памяти jvm к сконфигурированному объему памяти.

Используете ли вы старую версию RabbitMQ. Многие дистрибутивы Linux включают RabbitMQ 1.7.2, которая является старой версией, которая имеет проблемы с большим количеством сообщений. Большой определить сложно, потому что он зависит от вашей оперативной памяти, но RabbitMQ не любит использовать более 40% оперативной памяти, поскольку ему необходимо скопировать журнал транзакций постоянного хранения, чтобы обработать его и очистить для переноса журнала. Это может привести к сбою RabbitMQ, и, конечно, обработка больших журналов замедлит его. RabbitMQ 2.4.1 намного лучше обрабатывает сохраняемые журналы, небольшими порциями, а также имеет гораздо более быстрый код маршрутизации сообщений.

Это все еще звучит для меня как проблема Java, либо Spring просто поросенок и ужасно неэффективен, либо вы не дали достаточно памяти jvm, чтобы избежать частых запусков gc. Какие настройки вы используете для -Xmx?

Answer 2

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">

<!-- Define a connectionFactory -->
<bean id="connectionFactory" class="com.rabbitmq.client.connectionFactory">
<constructor-arg value="localhost" />
<property name="username" value="guest" />
<property name="password" value="guest" />
</bean>

<bean id="Admin" class="org.springframework.amqp.rabbit.core.RabbitAdmin">
<constructor-arg ref="connectionFactory" />
</bean>

</beans> 

При использовании этого XML-файла появляется сообщение об ошибке, говорящее, что org.springframework.amqp.rabbit.core.RabbitAdmin не может привести com.rabbitmq.client.connectionFactory для bean-компонента фабрики соединений.Точная ошибка: «вложенное исключение - java.lang.IllegalStateException: невозможно преобразовать значение типа [com.rabbitmq.client.ConnectionFactory] в требуемый тип [org.springframework.amqp.rabbit.core.RabbitTemplate]: нет соответствующих редакторов илинайдена стратегия конвертации ".

Следовательно, мне нужно использовать bean:

<bean id="connectionFactory"
class="org.springframework.amqp.rabbit.connection.SingleConnectionFactory">
</bean>