Author: aco
Date: Fri Jun 2 01:11:40 2006
New Revision: 411084
URL: http://svn.apache.org/viewvc?rev=411084&view=rev
Log:
Added initial spike for the measurement sampler.
Added:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurementTool.java
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerformanceSampler.java
Modified:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsPerfClientSupport.java
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsProducerClient.java
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurable.java
Modified:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsPerfClientSupport.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsPerfClientSupport.java?rev=411084&r1=411083&r2=411084&view=diff
==============================================================================
---
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsPerfClientSupport.java
(original)
+++
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsPerfClientSupport.java
Fri Jun 2 01:11:40 2006
@@ -16,12 +16,14 @@
*/
package org.apache.activemq.tool;
+import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicLong;
+
import java.util.Map;
import java.util.HashMap;
public class JmsPerfClientSupport extends JmsConfigurableClientSupport
implements PerfMeasurable {
- protected long throughput = 0;
+ protected AtomicLong throughput = new AtomicLong(0);
protected PerfEventListener listener = null;
@@ -30,19 +32,19 @@
}
public long getThroughput() {
- return throughput;
+ return throughput.get();
}
- public synchronized void setThroughput(long val) {
- this.throughput = val;
+ public void setThroughput(long val) {
+ throughput.set(val);
}
- public synchronized void incThroughput() {
- throughput++;
+ public void incThroughput() {
+ throughput.incrementAndGet();
}
- public synchronized void incThroughput(long val) {
- throughput += val;
+ public void incThroughput(long val) {
+ throughput.addAndGet(val);
}
public void setPerfEventListener(PerfEventListener listener) {
@@ -68,5 +70,9 @@
settings.putAll(getMessageSettings());
return settings;
+ }
+
+ public String getClientName() {
+ return getClientID();
}
}
Modified:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsProducerClient.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsProducerClient.java?rev=411084&r1=411083&r2=411084&view=diff
==============================================================================
---
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsProducerClient.java
(original)
+++
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsProducerClient.java
Fri Jun 2 01:11:40 2006
@@ -242,9 +242,41 @@
}
public static void main(String[] args) throws Exception {
- JmsProducerClient prod = new
JmsProducerClient("org.apache.activemq.ActiveMQConnectionFactory",
"tcp://localhost:61616", "topic://TEST.FOO");
- prod.setPerfEventListener(new PerfEventAdapter());
- prod.createProducer();
- prod.sendTimeBasedMessages(2000);
+ final long duration = 1 * 60 * 1000;
+ long rampUpTime = 5 * 1000;
+ long rampDownTime = 5 * 1000;
+ long interval = 1000;
+
+ PerfMeasurementTool tool = new PerfMeasurementTool();
+ tool.setDuration(duration);
+ tool.setInterval(interval);
+ tool.setRampUpTime(rampUpTime);
+ tool.setRampDownTime(rampDownTime);
+
+ JmsProducerClient[] client = new JmsProducerClient[10];
+ for (int i=0; i<10; i++) {
+ client[i] = new
JmsProducerClient("org.apache.activemq.ActiveMQConnectionFactory",
"tcp://localhost:61616", "topic://TEST.FOO");
+ client[i].addConfigParam("factory.asyncSend", "true");
+ client[i].setPerfEventListener(new PerfEventAdapter());
+ client[i].createProducer();
+ tool.registerClient(client[i]);
+ }
+
+ tool.startSampler();
+
+ for (int i=0; i<10; i++) {
+ final JmsProducerClient p = client[i];
+ Thread t = new Thread(new Runnable() {
+ public void run() {
+ try {
+ p.sendTimeBasedMessages(duration);
+ } catch (JMSException e) {
+ e.printStackTrace();
+ }
+ }
+ });
+ t.start();
+
+ }
}
}
Modified:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurable.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurable.java?rev=411084&r1=411083&r2=411084&view=diff
==============================================================================
---
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurable.java
(original)
+++
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurable.java
Fri Jun 2 01:11:40 2006
@@ -20,6 +20,7 @@
public interface PerfMeasurable {
public void reset();
+ public String getClientName();
public long getThroughput();
public Map getClientSettings();
public void setPerfEventListener(PerfEventListener listener);
Added:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurementTool.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurementTool.java?rev=411084&view=auto
==============================================================================
---
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurementTool.java
(added)
+++
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfMeasurementTool.java
Fri Jun 2 01:11:40 2006
@@ -0,0 +1,144 @@
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.tool;
+
+import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
+import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
+
+import javax.jms.JMSException;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Iterator;
+
+public class PerfMeasurementTool implements PerfEventListener, Runnable {
+ private long duration = 5 * 60 * 1000; // 5 mins by default test
duration
+ private long interval = 1000; // 1 sec sample interval
+ private long rampUpTime = 1 * 60 * 1000; // 1 min default test ramp up
time
+ private long rampDownTime = 1 * 60 * 1000; // 1 min default test ramp down
time
+ private long sampleIndex = 0;
+
+ private AtomicBoolean start = new AtomicBoolean(false);
+ private AtomicBoolean stop = new AtomicBoolean(false);
+
+ private List perfClients = new ArrayList();
+ private AtomicInteger unstartedClients = new AtomicInteger(0);
+
+ public void registerClient(PerfMeasurable client) {
+ client.setPerfEventListener(this);
+ perfClients.add(client);
+ unstartedClients.incrementAndGet();
+ }
+
+ public void registerClient(PerfMeasurable[] clients) {
+ for (int i=0; i<clients.length; i++) {
+ registerClient(clients[i]);
+ }
+ }
+
+ public void startSampler() {
+ Thread t = new Thread(this);
+ t.setName("Performance Sampler");
+ t.start();
+ }
+
+ public long getDuration() {
+ return duration;
+ }
+
+ public void setDuration(long duration) {
+ this.duration = duration;
+ }
+
+ public long getInterval() {
+ return interval;
+ }
+
+ public void setInterval(long interval) {
+ this.interval = interval;
+ }
+
+ public long getRampUpTime() {
+ return rampUpTime;
+ }
+
+ public void setRampUpTime(long rampUpTime) {
+ this.rampUpTime = rampUpTime;
+ }
+
+ public long getRampDownTime() {
+ return rampDownTime;
+ }
+
+ public void setRampDownTime(long rampDownTime) {
+ this.rampDownTime = rampDownTime;
+ }
+
+ public void onConfigStart(PerfMeasurable client) {
+ }
+
+ public void onConfigEnd(PerfMeasurable client) {
+ }
+
+ public void onPublishStart(PerfMeasurable client) {
+ }
+
+ public void onPublishEnd(PerfMeasurable client) {
+ }
+
+ public void onConsumeStart(PerfMeasurable client) {
+ }
+
+ public void onConsumeEnd(PerfMeasurable client) {
+ }
+
+ public void onJMSException(PerfMeasurable client, JMSException e) {
+ }
+
+ public void onException(PerfMeasurable client, Exception e) {
+ stop.set(true);
+ }
+
+ public void run() {
+ // Compute for the actual duration window of the sampler
+ long endTime = System.currentTimeMillis() + duration - rampDownTime;
+ try {
+ Thread.sleep(rampUpTime);
+
+ // Let's reset the throughput first and start getting the samples
+ for (Iterator i=perfClients.iterator(); i.hasNext();) {
+ PerfMeasurable client = (PerfMeasurable)i.next();
+ client.reset();
+ }
+
+ while (System.currentTimeMillis() < endTime && !stop.get()) {
+ Thread.sleep(interval);
+ sampleClients();
+ sampleIndex++;
+ }
+ } catch (InterruptedException e) {
+ }
+ }
+
+ public void sampleClients() {
+ for (Iterator i=perfClients.iterator(); i.hasNext();) {
+ PerfMeasurable client = (PerfMeasurable)i.next();
+ System.out.println("<sample index=" + sampleIndex + " name=" +
client.getClientName() +
+ " throughput=" + client.getThroughput() + "/>");
+ client.reset();
+ }
+ }
+}
Added:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerformanceSampler.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerformanceSampler.java?rev=411084&view=auto
==============================================================================
(empty)
