github/OPC_Client
4
0
Fork 1
mirror of https://github.com/luoyan35714/OPC_Client.git synced 2026-04-18 00:01:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

update async test and publish/scribe test

Browse Source
This commit is contained in:
luoyan35714
2014-12-11 10:04:35 +08:00
parent 6d72a9b91e
commit 32938d33c0
5 changed files with 183 additions and 140 deletions
Download Patch File Download Diff File Expand all files Collapse all files
OPC_Client_Utgard_Performance/src/main/java/com/freud/opc/utgard/perf/AsyncMultiThreadTest.java
+2 -3
View File
@@ -5,7 +5,6 @@ import static com.freud.opc.utgard.perf.config.ConfigReader.config;
import java.util.Date;
import java.util.concurrent.Executors;
import org.apache.commons.logging.Log;
import org.apache.log4j.Logger;
import org.openscada.opc.dcom.common.KeyedResult;
import org.openscada.opc.dcom.common.KeyedResultSet;
@@ -21,7 +20,7 @@ import org.openscada.opc.lib.da.Server;
public class AsyncMultiThreadTest {
private static final int count = 50;
private static final int count = 1;
public static void main(String[] args) throws Exception {
for (int i = 1; i <= count; i++) {
@@ -34,7 +33,7 @@ class AsyncMulti implements Runnable {
private static Logger LOGGER = Logger.getLogger(AsyncMulti.class);
private static final int NUMBER = 4000;
private static final int NUMBER = 10000;
private int count_number;
private static long start;
OPC_Client_Utgard_Performance/src/main/java/com/freud/opc/utgard/perf/PublishMultiTreadTest.java
+67
View File
@@ -0,0 +1,67 @@
package com.freud.opc.utgard.perf;
import static com.freud.opc.utgard.perf.config.ConfigReader.config;
import java.util.Date;
import java.util.concurrent.Executors;
import org.apache.log4j.Logger;
import org.openscada.opc.lib.da.AccessBase;
import org.openscada.opc.lib.da.Async20Access;
import org.openscada.opc.lib.da.AutoReconnectController;
import org.openscada.opc.lib.da.DataCallback;
import org.openscada.opc.lib.da.Item;
import org.openscada.opc.lib.da.ItemState;
import org.openscada.opc.lib.da.Server;
public class PublishMultiTreadTest {
public static void main(String[] args) throws Exception {
for (int i = 1; i <= 10; i++) {
new Thread(new PublishMultiThread(i)).start();
}
}
}
class PublishMultiThread implements Runnable {
private static Logger LOGGER = Logger.getLogger(PublishMultiThread.class);
private static final int NUMBER = 4000;
private int countNumber;
public PublishMultiThread(int countNumber) {
this.countNumber = countNumber;
}
public void run() {
try {
long start = System.currentTimeMillis();
LOGGER.info("Step-" + countNumber * NUMBER + " site:");
LOGGER.info("StartDate[" + new Date() + "],CurrentMillis:" + start);
Server server = new Server(config(),
Executors.newSingleThreadScheduledExecutor());
AutoReconnectController controller = new AutoReconnectController(
server);
controller.connect();
AccessBase access = new Async20Access(server, 0, true);
for (int i = (countNumber - 1) * NUMBER; i < countNumber * NUMBER; i++) {
access.addItem("Random.Real" + i, new DataCallback() {
public void changed(Item item, ItemState is) {
}
});
}
access.bind();
Thread.sleep(12 * 60 * 60 * 1000);
access.unbind();
long end = System.currentTimeMillis();
LOGGER.info("EndDate[" + new Date() + "],CurrentMillis:" + end);
LOGGER.info("Total Spend:[" + (end - start) + "]");
server.dispose();
} catch (Exception e) {
e.printStackTrace();
}
}
}
OPC_Client_Utgard_Performance/src/main/java/com/freud/opc/utgard/perf/PublishOPCPerfTest.java
+21 -36
View File
@@ -6,19 +6,19 @@ import java.util.Date;
import java.util.concurrent.Executors;
import org.apache.log4j.Logger;
import org.openscada.opc.dcom.common.KeyedResultSet;
import org.openscada.opc.dcom.common.ResultSet;
import org.openscada.opc.dcom.da.IOPCDataCallback;
import org.openscada.opc.dcom.da.ValueData;
import org.openscada.opc.lib.da.Group;
import org.openscada.opc.lib.da.AccessBase;
import org.openscada.opc.lib.da.Async20Access;
import org.openscada.opc.lib.da.AutoReconnectController;
import org.openscada.opc.lib.da.DataCallback;
import org.openscada.opc.lib.da.Item;
import org.openscada.opc.lib.da.ItemState;
import org.openscada.opc.lib.da.Server;
public class PublishOPCPerfTest {
private static Logger LOGGER = Logger.getLogger(PublishOPCPerfTest.class);
//private static final int NUMBER = 10000;
private static final int WAN_NUMBER = 1;
private static final int NUMBER = 4000;
private static final int WAN_NUMBER = 10;
public static void main(String[] args) throws Exception {
for (int i = 1; i <= WAN_NUMBER; i++) {
@@ -28,38 +28,23 @@ public class PublishOPCPerfTest {
private static void testSteps(int count) throws Exception {
long start = System.currentTimeMillis();
LOGGER.info("Step-" + count + "W:");
LOGGER.info("StartDate[" + new Date() + "],CurrentMillis:" + start);
Server server = new Server(config(),
Executors.newSingleThreadScheduledExecutor());
server.connect();
Group group = server.addGroup("Group");
//Map<String, Item> map = group.addItems("Random.int" + 1);
group.attach(new IOPCDataCallback() {
public void writeComplete(int i, int j, int k,
ResultSet<Integer> resultset) {
}
public void readComplete(int i, int j, int k, int l,
KeyedResultSet<Integer, ValueData> keyedresultset) {
}
public void dataChange(int i, int j, int k, int l,
KeyedResultSet<Integer, ValueData> keyedresultset) {
System.out.println("DataChanged");
}
public void cancelComplete(int i, int j) {
}
});
AutoReconnectController controller = new AutoReconnectController(server);
controller.connect();
AccessBase access = new Async20Access(server, 0, true);
int limit = count * NUMBER;
for (int i = 0; i < limit; i++) {
access.addItem("Random.Real" + i, new DataCallback() {
public void changed(Item item, ItemState is) {
}
});
}
access.bind();
Thread.sleep(10 * 1000);
access.unbind();
long end = System.currentTimeMillis();
LOGGER.info("EndDate[" + new Date() + "],CurrentMillis:" + end);
LOGGER.info("Total Spend:[" + (end - start) + "]");