activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Anthrope ...@anthrope.com>
Subject Re: [jira] Resolved: (AMQ-1137) Transactional, non persistent queing very slow under Linux
Date Thu, 31 May 2007 00:52:06 GMT

Works when you use simple tcp://host:port URL, but not if you use failover
URL.



JIRA jira@apache.org wrote:
> 
> 
>      [
> https://issues.apache.org/activemq/browse/AMQ-1137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
> ]
> 
> james strachan resolved AMQ-1137.
> ---------------------------------
> 
>     Resolution: Duplicate
> 
> The workaround is to use the URI...
> 
> {code}
> ?socket.tcpNoDelay=true
> {code}
> 
>> Transactional, non persistent queing very slow under Linux
>> ----------------------------------------------------------
>>
>>                 Key: AMQ-1137
>>                 URL: https://issues.apache.org/activemq/browse/AMQ-1137
>>             Project: ActiveMQ
>>          Issue Type: Bug
>>          Components: Broker
>>    Affects Versions: 4.1.0
>>            Reporter: Helmut Janknecht
>>
>> h2. USE CASE
>> # Take 4.1.0 Release from
>> http://people.apache.org/repo/m2-incubating-repository/org/apache/activemq/apache-activemq/4.1.0-incubator/apache-activemq-4.1.0-incubator.zip
>> and unzip on a Linux box (SuSE 10.1, Kernel 2.6.16 with 2GB RAM and 
>> Xeon(TM) CPU 2.80GHz
>> # Edit {{conf/activemq.xml}} and disable ssl and stomp transport
>> # Start broker: {{apache-activemq-4.1.0-incubator/bin> java -jar
>> run.jar}}
>> # Edit {{example/build.xml}} and set max=1000 (send 1000 messages to
>> queue) and *transacted=true*
>> # Run producer: {{ant producer}}
>> h2. Results
>> {code:title=broker logfile}
>> ACTIVEMQ_HOME: /home/janknecht/tmp/apache-activemq-4.1.0-incubator
>> Loading message broker from: xbean:activemq.xml
>> INFO  BrokerService                  - ActiveMQ 4.1.0-incubator JMS
>> Message Broker (localhost) is starting
>> INFO  BrokerService                  - For help or more information
>> please see: http://incubator.apache.org/activemq/
>> INFO  ManagementContext              - JMX consoles can connect to
>> service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
>> INFO  JDBCPersistenceAdapter         - Database driver recognized:
>> [apache_derby_embedded_jdbc_driver]
>> INFO  DefaultDatabaseLocker          - Attempting to acquire the
>> exclusive lock to become the Master broker
>> INFO  DefaultDatabaseLocker          - Becoming the master on dataSource:
>> org.apache.derby.jdbc.EmbeddedDataSource@14627a
>> INFO  JournalPersistenceAdapter      - Journal Recovery Started from:
>> Active Journal: using 5 x 20.0 Megs at:
>> /home/janknecht/tmp/apache-activemq-4.1.0-incubator/activemq-data/journal
>> INFO  JournalPersistenceAdapter      - Journal Recovered: 0 message(s) in
>> transactions recovered.
>> INFO  TransportServerThreadSupport   - Listening for connections at:
>> tcp://acxlin.wu.ssn:61616
>> INFO  TransportConnector             - Connector openwire Started
>> INFO  NetworkConnector               - Network Connector default-nc
>> Started
>> INFO  BrokerService                  - ActiveMQ JMS Message Broker
>> (localhost, ID:acxlin.wu.ssn-60609-1169619821670-1:0) started
>> {code} 
>> {code:title=producer output}
>> producer:
>>      [echo] Running producer against server at $url =
>> tcp://localhost:61616 for subject $subject = TEST.FOO
>>      [java] Connecting to URL: tcp://localhost:61616
>>      [java] Publishing a Message with size 1000 to queue: TEST.FOO
>>      [java] Using non-persistent messages
>>      [java] Sleeping between publish 0 ms
>>      [java] Sending message: Message: 0 sent at: Wed Jan 24 07:28:14 CET
>> 2007  ...
>>      [java] Sending message: Message: 1 sent at: Wed Jan 24 07:28:14 CET
>> 2007  ...
>>      [java] Sending message: Message: 2 sent at: Wed Jan 24 07:28:14 CET
>> 2007  ...
>>      [java] Sending message: Message: 3 sent at: Wed Jan 24 07:28:15 CET
>> 2007  ...
>>      [java] Sending message: Message: 4 sent at: Wed Jan 24 07:28:15 CET
>> 2007  ...
>>      [java] Sending message: Message: 5 sent at: Wed Jan 24 07:28:15 CET
>> 2007  ...
>> ...
>>      [java] Sending message: Message: 998 sent at: Wed Jan 24 07:28:55
>> CET 2007...
>>      [java] Sending message: Message: 999 sent at: Wed Jan 24 07:28:55
>> CET 2007...
>>      [java] Done.
>>      [java] connection {
>>      [java]   session {
>>      [java]     messageCount{ count: 1000 unit: count startTime:
>> 1169620094893 lastSampleTime: 1169620135606 description: Number of
>> messages exchanged }
>>      [java]     messageRateTime{ count: 1000 maxTime: 126 minTime: 4
>> totalTime: 40688 averageTime: 40.688 averageTimeExMinMax:
>> 40.63927855711423 averagePerSecond: 24.57727093983484
>> averagePerSecondExMinMax: 24.606736032348735 unit: millis startTime:
>> 1169620094893 lastSampleTime: 1169620135606 description: Time taken to
>> process a message (thoughtput rate) }
>>      [java]     pendingMessageCount{ count: 0 unit: count startTime:
>> 1169620094893 lastSampleTime: 1169620094893 description: Number of
>> pending messages }
>>      [java]     expiredMessageCount{ count: 0 unit: count startTime:
>> 1169620094893 lastSampleTime: 1169620094893 description: Number of
>> expired messages }
>>      [java]     messageWaitTime{ count: 0 maxTime: 0 minTime: 0
>> totalTime: 0 averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond:
>> 0.0 averagePerSecondExMinMax: 0.0 unit: millis startTime: 1169620094893
>> lastSampleTime: 1169620094893 description: Time spent by a message before
>> being delivered }
>>      [java]     durableSubscriptionCount{ count: 0 unit: count startTime:
>> 1169620094893 lastSampleTime: 1169620094893 description: The number of
>> durable subscriptions }
>>      [java]     producers {
>>      [java]       producer queue://TEST.FOO {
>>      [java]         messageCount{ count: 1000 unit: count startTime:
>> 1169620094918 lastSampleTime: 1169620135606 description: Number of
>> messages processed }
>>      [java]         messageRateTime{ count: 1000 maxTime: 126 minTime: 4
>> totalTime: 40688 averageTime: 40.688 averageTimeExMinMax:
>> 40.63927855711423 averagePerSecond: 24.57727093983484
>> averagePerSecondExMinMax: 24.606736032348735 unit: millis startTime:
>> 1169620094918 lastSampleTime: 1169620135606 description: Time taken to
>> process a message (thoughtput rate) }
>>      [java]         pendingMessageCount{ count: 0 unit: count startTime:
>> 1169620094918 lastSampleTime: 1169620094918 description: Number of
>> pending messages }
>>      [java]         messageRateTime{ count: 1000 maxTime: 126 minTime: 4
>> totalTime: 40688 averageTime: 40.688 averageTimeExMinMax:
>> 40.63927855711423 averagePerSecond: 24.57727093983484
>> averagePerSecondExMinMax: 24.606736032348735 unit: millis startTime:
>> 1169620094918 lastSampleTime: 1169620135606 description: Time taken to
>> process a message (thoughtput rate) }
>>      [java]         expiredMessageCount{ count: 0 unit: count startTime:
>> 1169620094918 lastSampleTime: 1169620094918 description: Number of
>> expired messages }
>>      [java]         messageWaitTime{ count: 0 maxTime: 0 minTime: 0
>> totalTime: 0 averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond:
>> 0.0 averagePerSecondExMinMax: 0.0 unit: millis startTime: 1169620094918
>> lastSampleTime: 1169620094918 description: Time spent by a message before
>> being delivered }
>>      [java]       }
>>      [java]     }
>>      [java]     consumers {
>>      [java]     }
>>      [java]   }
>>      [java] }
>> {code} 
>> As you can see very bad performace, ot took about 40s to send this 1000
>> transacted queue messages :-(
> 
> -- 
> This message is automatically generated by JIRA.
> -
> You can reply to this email to add a comment to the issue online.
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/-jira--Resolved%3A-%28AMQ-1137%29-Transactional%2C-non-persistent-queing-very-slow-under-Linux-tf3402298s2354.html#a10885531
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.


Mime
View raw message