diff --git a/.gitignore b/.gitignore index 32858aa..a30c280 100644 --- a/.gitignore +++ b/.gitignore @@ -10,3 +10,7 @@ # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml hs_err_pid* + +.settings/ +bin/ +target/ \ No newline at end of file diff --git a/OPC_Client_Jeasyopc/.classpath b/OPC_Client_Jeasyopc/.classpath new file mode 100644 index 0000000..f7805d0 --- /dev/null +++ b/OPC_Client_Jeasyopc/.classpath @@ -0,0 +1,24 @@ + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/OPC_Client_Jeasyopc/.project b/OPC_Client_Jeasyopc/.project new file mode 100644 index 0000000..7ab1190 --- /dev/null +++ b/OPC_Client_Jeasyopc/.project @@ -0,0 +1,23 @@ + + + OPC_Client_Jeasyopc + + + + + + org.eclipse.jdt.core.javabuilder + + + + + org.eclipse.m2e.core.maven2Builder + + + + + + org.eclipse.m2e.core.maven2Nature + org.eclipse.jdt.core.javanature + + diff --git a/OPC_Client_Jeasyopc/pom.xml b/OPC_Client_Jeasyopc/pom.xml new file mode 100644 index 0000000..858ae4a --- /dev/null +++ b/OPC_Client_Jeasyopc/pom.xml @@ -0,0 +1,19 @@ + + 4.0.0 + com.freud.opc + OPC_Client_Jeasyopc + 0.0.1-SNAPSHOT + + src + + + maven-compiler-plugin + 3.0 + + 1.6 + 1.6 + + + + + \ No newline at end of file diff --git a/OPC_Client_Utgard/.classpath b/OPC_Client_Utgard/.classpath new file mode 100644 index 0000000..1573d71 --- /dev/null +++ b/OPC_Client_Utgard/.classpath @@ -0,0 +1,13 @@ + + + + + + + + + + + + + diff --git a/OPC_Client_Utgard/.project b/OPC_Client_Utgard/.project new file mode 100644 index 0000000..1d40304 --- /dev/null +++ b/OPC_Client_Utgard/.project @@ -0,0 +1,17 @@ + + + OPC_Client_Utgard + + + + + + org.eclipse.jdt.core.javabuilder + + + + + + org.eclipse.jdt.core.javanature + + diff --git a/OPC_Client_Utgard/output.log b/OPC_Client_Utgard/output.log new file mode 100644 index 0000000..3df2b04 --- /dev/null +++ b/OPC_Client_Utgard/output.log @@ -0,0 +1 @@ +2014-12-03 16:22:54,739 INFO com.freud.dcom.utgard.cases.DCOMTest5.main:67 - test diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest1.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest1.java new file mode 100644 index 0000000..f41de08 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest1.java @@ -0,0 +1,67 @@ +package com.freud.dcom.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_CLSID; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.common.JISystem; +import org.jinterop.dcom.core.IJIComObject; +import org.jinterop.dcom.core.JIClsid; +import org.jinterop.dcom.core.JIComServer; +import org.jinterop.dcom.core.JISession; +import org.openscada.opc.dcom.da.OPCSERVERSTATUS; +import org.openscada.opc.dcom.da.impl.OPCServer; + +/** + * 获取Server的Status信息 + * + * @author Freud + * + */ +public class DCOMTest1 { + + public static void main(String[] args) throws Exception { + + JISystem.setAutoRegisteration(true); + + JISession _session = JISession.createSession( + getEntryValue(CONFIG_DOMAIN), getEntryValue(CONFIG_USERNAME), + getEntryValue(CONFIG_PASSWORD)); + + final JIComServer comServer = new JIComServer( + JIClsid.valueOf(getEntryValue(CONFIG_CLSID)), + getEntryValue(CONFIG_HOST), _session); + + final IJIComObject serverObject = comServer.createInstance(); + + OPCServer server = new OPCServer(serverObject); + dumpServerStatus(server); + + } + + public static void dumpServerStatus(final OPCServer server) + throws JIException { + + final OPCSERVERSTATUS status = server.getStatus(); + + System.out.println("===== SERVER STATUS ======"); + System.out.println("State: " + status.getServerState().toString()); + System.out.println("Vendor: " + status.getVendorInfo()); + System.out.println(String.format("Version: %d.%d.%d", + status.getMajorVersion(), status.getMinorVersion(), + status.getBuildNumber())); + System.out.println("Groups: " + status.getGroupCount()); + System.out.println("Bandwidth: " + status.getBandWidth()); + System.out.println(String.format("Start Time: %tc", status + .getStartTime().asCalendar())); + System.out.println(String.format("Current Time: %tc", status + .getCurrentTime().asCalendar())); + System.out.println(String.format("Last Update Time: %tc", status + .getLastUpdateTime().asCalendar())); + System.out.println("===== SERVER STATUS ======"); + } +} diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest2.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest2.java new file mode 100644 index 0000000..df79c54 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest2.java @@ -0,0 +1,128 @@ +package com.freud.dcom.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_CLSID; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import java.net.UnknownHostException; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.common.JISystem; +import org.jinterop.dcom.core.IJIComObject; +import org.jinterop.dcom.core.JIClsid; +import org.jinterop.dcom.core.JIComServer; +import org.jinterop.dcom.core.JISession; +import org.jinterop.dcom.core.JIVariant; +import org.openscada.opc.dcom.da.OPCBROWSEDIRECTION; +import org.openscada.opc.dcom.da.OPCBROWSETYPE; +import org.openscada.opc.dcom.da.OPCNAMESPACETYPE; +import org.openscada.opc.dcom.da.impl.OPCBrowseServerAddressSpace; +import org.openscada.opc.dcom.da.impl.OPCServer; + +/** + * 遍历OPC连接下的所有Group和Item + * + * @author Freud + * + */ +public class DCOMTest2 { + + public static void main(String[] args) throws Exception { + JISystem.setAutoRegisteration(true); + + /** + * Session获取 + */ + JISession _session = JISession.createSession( + getEntryValue(CONFIG_DOMAIN), getEntryValue(CONFIG_USERNAME), + getEntryValue(CONFIG_PASSWORD)); + + final JIComServer comServer = new JIComServer( + JIClsid.valueOf(getEntryValue(CONFIG_CLSID)), + getEntryValue(CONFIG_HOST), _session); + + final IJIComObject serverObject = comServer.createInstance(); + + OPCServer server = new OPCServer(serverObject); + final OPCBrowseServerAddressSpace serverBrowser = server.getBrowser(); + + /** + * Flat形式获取所有Item信息 + */ + browseFlat(serverBrowser); + + /** + * 获取所有的Group和Item信息 + */ + browseTree(serverBrowser); + + } + + /** + * Tree形式获取所有Group和Item的信息 + */ + private static void browseTree(final OPCBrowseServerAddressSpace browser) + throws IllegalArgumentException, UnknownHostException, JIException { + System.out.println("Showing hierarchial address space"); + System.out.println(String.format("Organization: %s", + browser.queryOrganization())); + + if (!browser.queryOrganization().equals( + OPCNAMESPACETYPE.OPC_NS_HIERARCHIAL)) { + return; + } + + browser.changePosition(null, OPCBROWSEDIRECTION.OPC_BROWSE_TO); + browseTree(browser, 0); + } + + private static String printTab(int level) { + StringBuilder sb = new StringBuilder(); + for (int i = 0; i < level; i++) { + sb.append("\t"); + } + return sb.toString(); + } + + private static void browseTree(final OPCBrowseServerAddressSpace browser, + final int level) throws JIException, IllegalArgumentException, + UnknownHostException { + + for (final String item : browser.browse(OPCBROWSETYPE.OPC_LEAF, "", 0, + JIVariant.VT_EMPTY).asCollection()) { + + System.out.println(printTab(level) + "Leaf: " + item + "\tName: " + + browser.getItemID(item)); + } + + for (final String item : browser.browse(OPCBROWSETYPE.OPC_BRANCH, "", + 0, JIVariant.VT_EMPTY).asCollection()) { + System.out.println(printTab(level) + "Branch: " + item); + browser.changePosition(item, OPCBROWSEDIRECTION.OPC_BROWSE_DOWN); + browseTree(browser, level + 1); + browser.changePosition(null, OPCBROWSEDIRECTION.OPC_BROWSE_UP); + } + } + + /** + * Flat形式获取Item的信息 + */ + private static void browseFlat(final OPCBrowseServerAddressSpace browser) + throws JIException, IllegalArgumentException, UnknownHostException { + + System.out.println(String.format("Organization: %s", + browser.queryOrganization())); + + browser.changePosition(null, OPCBROWSEDIRECTION.OPC_BROWSE_TO); + + System.out.println("Showing flat address space"); + for (final String id : browser.browse(OPCBROWSETYPE.OPC_FLAT, "", 0, + JIVariant.VT_EMPTY).asCollection()) { + System.out.println("Item: " + id); + } + } + +} diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest3.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest3.java new file mode 100644 index 0000000..05b1f21 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest3.java @@ -0,0 +1,81 @@ +package com.freud.dcom.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_CLSID; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import java.net.UnknownHostException; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.common.JISystem; +import org.jinterop.dcom.core.IJIComObject; +import org.jinterop.dcom.core.JIClsid; +import org.jinterop.dcom.core.JIComServer; +import org.jinterop.dcom.core.JISession; +import org.openscada.opc.dcom.da.OPCENUMSCOPE; +import org.openscada.opc.dcom.da.impl.OPCGroupStateMgt; +import org.openscada.opc.dcom.da.impl.OPCServer; + +/** + * 通过Scope遍历OPC连接下的所有Group信息 + * + * @author Freud + * + */ +public class DCOMTest3 { + + public static void main(String[] args) throws Exception { + JISystem.setAutoRegisteration(true); + + /** + * Session获取 + */ + JISession _session = JISession.createSession( + getEntryValue(CONFIG_DOMAIN), getEntryValue(CONFIG_USERNAME), + getEntryValue(CONFIG_PASSWORD)); + + final JIComServer comServer = new JIComServer( + JIClsid.valueOf(getEntryValue(CONFIG_CLSID)), + getEntryValue(CONFIG_HOST), _session); + + final IJIComObject serverObject = comServer.createInstance(); + + OPCServer server = new OPCServer(serverObject); + + /** + * 添加一个Group的信息 + */ + OPCGroupStateMgt group = server.addGroup("test", true, 100, 1234, 60, + 0.0f, 1033); + + enumerateGroups(server, OPCENUMSCOPE.OPC_ENUM_PUBLIC); + enumerateGroups(server, OPCENUMSCOPE.OPC_ENUM_PRIVATE); + enumerateGroups(server, OPCENUMSCOPE.OPC_ENUM_ALL); + + // clean up + server.removeGroup(group, true); + } + + /** + * 通过Scope查找并遍历Groups的信息 + * + * @param server + * @param scope + * @throws IllegalArgumentException + * @throws UnknownHostException + * @throws JIException + */ + public static void enumerateGroups(final OPCServer server, + final OPCENUMSCOPE scope) throws IllegalArgumentException, + UnknownHostException, JIException { + System.out.println("Enum Groups: " + scope.toString()); + + for (final String group : server.getGroups(scope).asCollection()) { + System.out.println("Group: " + group); + } + } + +} diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest4.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest4.java new file mode 100644 index 0000000..08fb7f6 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest4.java @@ -0,0 +1,221 @@ +package com.freud.dcom.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_CLSID; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import java.net.UnknownHostException; +import java.util.ArrayList; +import java.util.List; +import java.util.Random; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.common.JISystem; +import org.jinterop.dcom.core.IJIComObject; +import org.jinterop.dcom.core.JIClsid; +import org.jinterop.dcom.core.JIComServer; +import org.jinterop.dcom.core.JISession; +import org.openscada.opc.dcom.common.EventHandler; +import org.openscada.opc.dcom.common.KeyedResult; +import org.openscada.opc.dcom.common.KeyedResultSet; +import org.openscada.opc.dcom.common.Result; +import org.openscada.opc.dcom.common.ResultSet; +import org.openscada.opc.dcom.common.impl.OPCCommon; +import org.openscada.opc.dcom.da.OPCDATASOURCE; +import org.openscada.opc.dcom.da.OPCITEMDEF; +import org.openscada.opc.dcom.da.OPCITEMRESULT; +import org.openscada.opc.dcom.da.OPCITEMSTATE; +import org.openscada.opc.dcom.da.impl.OPCGroupStateMgt; +import org.openscada.opc.dcom.da.impl.OPCItemMgt; +import org.openscada.opc.dcom.da.impl.OPCServer; +import org.openscada.opc.dcom.da.impl.OPCSyncIO; + +/** + * 通过Scope遍历OPC连接下的所有Group信息 + * + * @author Freud + * + */ +public class DCOMTest4 { + + public static void main(String[] args) throws Exception { + JISystem.setAutoRegisteration(true); + + /** + * Session获取 + */ + JISession _session = JISession.createSession( + getEntryValue(CONFIG_DOMAIN), getEntryValue(CONFIG_USERNAME), + getEntryValue(CONFIG_PASSWORD)); + + final JIComServer comServer = new JIComServer( + JIClsid.valueOf(getEntryValue(CONFIG_CLSID)), + getEntryValue(CONFIG_HOST), _session); + + final IJIComObject serverObject = comServer.createInstance(); + + OPCServer server = new OPCServer(serverObject); + + /** + * 添加一个Group的信息 + */ + OPCGroupStateMgt group = server.addGroup("test", true, 100, 1234, 60, + 0.0f, 1033); + + testItems(server, group, new String[] { "Saw-toothed Waves.Int2", + "Saw-toothed Waves.test2" }); + + // clean up + server.removeGroup(group, true); + } + + private static void showError(final OPCCommon common, final int errorCode) + throws JIException { + System.out.println(String.format("Error (%X): '%s'", errorCode, + common.getErrorString(errorCode, 1033))); + } + + private static void showError(final OPCServer server, final int errorCode) + throws JIException { + showError(server.getCommon(), errorCode); + } + + private static boolean dumpOPCITEMRESULT( + final KeyedResultSet result) { + int failed = 0; + for (final KeyedResult resultEntry : result) { + System.out.println("=================================="); + System.out.println(String.format("Item: '%s' ", resultEntry + .getKey().getItemID())); + + System.out.println(String.format("Error Code: %08x", + resultEntry.getErrorCode())); + if (!resultEntry.isFailed()) { + System.out.println(String.format("Server Handle: %08X", + resultEntry.getValue().getServerHandle())); + System.out.println(String.format("Data Type: %d", resultEntry + .getValue().getCanonicalDataType())); + System.out.println(String.format("Access Rights: %d", + resultEntry.getValue().getAccessRights())); + System.out.println(String.format("Reserved: %d", resultEntry + .getValue().getReserved())); + } else { + failed++; + } + } + return failed == 0; + } + + private static void testItems(final OPCServer server, + final OPCGroupStateMgt group, final String... itemIDs) + throws IllegalArgumentException, UnknownHostException, JIException { + + final OPCItemMgt itemManagement = group.getItemManagement(); + final List items = new ArrayList(itemIDs.length); + for (final String id : itemIDs) { + final OPCITEMDEF item = new OPCITEMDEF(); + item.setItemID(id); + item.setClientHandle(new Random().nextInt()); + items.add(item); + } + + final OPCITEMDEF[] itemArray = items.toArray(new OPCITEMDEF[0]); + + System.out.println("Validate"); + KeyedResultSet result = itemManagement + .validate(itemArray); + if (!dumpOPCITEMRESULT(result)) { + return; + } + + // now add them to the group + System.out.println("Add"); + result = itemManagement.add(itemArray); + if (!dumpOPCITEMRESULT(result)) { + return; + } + + // get the server handle array + final Integer[] serverHandles = new Integer[itemArray.length]; + for (int i = 0; i < itemArray.length; i++) { + serverHandles[i] = new Integer(result.get(i).getValue() + .getServerHandle()); + } + + // set them active + System.out.println("Activate"); + final ResultSet resultSet = itemManagement.setActiveState( + true, serverHandles); + for (final Result resultEntry : resultSet) { + System.out.println(String.format("Item: %08X, Error: %08X", + resultEntry.getValue(), resultEntry.getErrorCode())); + } + + // set client handles + System.out.println("Set client handles"); + final Integer[] clientHandles = new Integer[serverHandles.length]; + for (int i = 0; i < serverHandles.length; i++) { + clientHandles[i] = i; + } + itemManagement.setClientHandles(serverHandles, clientHandles); + + System.out.println("Create async IO 2.0 object"); + // OPCAsyncIO2 asyncIO2 = group.getAsyncIO2 (); + // connect handler + + System.out.println("attach"); + final EventHandler eventHandler = group.attach(new DumpDataCallback()); + + // sleep + try { + System.out.println("Waiting..."); + Thread.sleep(10 * 1000); + } catch (final InterruptedException e) { + e.printStackTrace(); + } + + eventHandler.detach(); + + // sync IO - read + final OPCSyncIO syncIO = group.getSyncIO(); + // OPCAsyncIO2 asyncIO2 = group.getAsyncIO2 (); + /* + * System.out.println ( "attach..enable" ); asyncIO2.setEnable ( true ); + * System.out.println ( "attach..refresh" ); asyncIO2.refresh ( + * (short)1, 1 ); + */ + + final KeyedResultSet itemState = syncIO.read( + OPCDATASOURCE.OPC_DS_DEVICE, serverHandles); + for (final KeyedResult itemStateEntry : itemState) { + final int errorCode = itemStateEntry.getErrorCode(); + System.out + .println(String + .format("Server ID: %08X, Value: %s, Timestamp: %d/%d (%Tc), Quality: %d, Error: %08X", + itemStateEntry.getKey(), itemStateEntry + .getValue().getValue(), + itemStateEntry.getValue().getTimestamp() + .getHigh(), + itemStateEntry.getValue().getTimestamp() + .getLow(), itemStateEntry + .getValue().getTimestamp() + .asCalendar(), itemStateEntry + .getValue().getQuality(), errorCode)); + if (errorCode != 0) { + showError(server, errorCode); + } + } + + // set them inactive + System.out.println("In-Active"); + itemManagement.setActiveState(false, serverHandles); + + // finally remove them again + System.out.println("Remove"); + itemManagement.remove(serverHandles); + } + +} diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest5.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest5.java new file mode 100644 index 0000000..f1c24b2 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest5.java @@ -0,0 +1,119 @@ +package com.freud.dcom.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_CLSID; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import java.util.Collection; + +import org.apache.log4j.Logger; +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.common.JISystem; +import org.jinterop.dcom.core.IJIComObject; +import org.jinterop.dcom.core.JIClsid; +import org.jinterop.dcom.core.JIComServer; +import org.jinterop.dcom.core.JISession; +import org.jinterop.dcom.core.JIVariant; +import org.openscada.opc.dcom.common.KeyedResult; +import org.openscada.opc.dcom.common.KeyedResultSet; +import org.openscada.opc.dcom.da.PropertyDescription; +import org.openscada.opc.dcom.da.impl.OPCGroupStateMgt; +import org.openscada.opc.dcom.da.impl.OPCItemProperties; +import org.openscada.opc.dcom.da.impl.OPCServer; + +/** + * 获取指定Item的Properties + * + * @author Freud + * + */ +public class DCOMTest5 { + + private static Logger LOGGER = Logger.getLogger(DCOMTest5.class); + + public static void main(String[] args) throws Exception { + JISystem.setAutoRegisteration(true); + + /** + * Session获取 + */ + JISession _session = JISession.createSession( + getEntryValue(CONFIG_DOMAIN), getEntryValue(CONFIG_USERNAME), + getEntryValue(CONFIG_PASSWORD)); + + final JIComServer comServer = new JIComServer( + JIClsid.valueOf(getEntryValue(CONFIG_CLSID)), + getEntryValue(CONFIG_HOST), _session); + + final IJIComObject serverObject = comServer.createInstance(); + + OPCServer server = new OPCServer(serverObject); + + /** + * 添加一个Group的信息 + */ + OPCGroupStateMgt group = server.addGroup("test", true, 100, 1234, 60, + 0.0f, 1033); + + final OPCItemProperties itemProperties = server + .getItemPropertiesService(); + dumpItemProperties(itemProperties, "Saw-toothed Waves.Int"); + + // clean up + server.removeGroup(group, true); + LOGGER.info("test"); + } + + public static void dumpItemProperties( + final OPCItemProperties itemProperties, final String itemID) + throws JIException { + final Collection properties = itemProperties + .queryAvailableProperties(itemID); + final int[] ids = new int[properties.size()]; + + System.out.println(String.format("Item Properties for '%s' (count:%d)", + itemID, properties.size())); + + int i = 0; + for (final PropertyDescription pd : properties) { + ids[i] = pd.getId(); + System.out.println("ID: " + pd.getId()); + System.out.println("Description: " + pd.getDescription()); + System.out.println("Variable Type: " + pd.getVarType()); + i++; + } + + System.out.println("Lookup"); + dumpItemPropertiesLookup(itemProperties, itemID, ids); + + System.out.println("Query"); + dumpItemProperties2(itemProperties, itemID, ids); + } + + public static void dumpItemProperties2( + final OPCItemProperties itemProperties, final String itemID, + final int... ids) throws JIException { + final KeyedResultSet values = itemProperties + .getItemProperties(itemID, ids); + for (final KeyedResult entry : values) { + System.out.println(String.format( + "ID: %d, Value: %s, Error Code: %08x", entry.getKey(), + entry.getValue().toString(), entry.getErrorCode())); + } + } + + public static void dumpItemPropertiesLookup( + final OPCItemProperties itemProperties, final String itemID, + final int... ids) throws JIException { + final KeyedResultSet values = itemProperties + .lookupItemIDs(itemID, ids); + for (final KeyedResult entry : values) { + System.out.println(String.format( + "ID: %d, Item ID: %s, Error Code: %08x", entry.getKey(), + entry.getValue(), entry.getErrorCode())); + } + } +} diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest6.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest6.java new file mode 100644 index 0000000..c2c554a --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest6.java @@ -0,0 +1,71 @@ +package com.freud.dcom.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_CLSID; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import java.util.LinkedList; +import java.util.List; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.common.JISystem; +import org.jinterop.dcom.core.IJIComObject; +import org.jinterop.dcom.core.JIClsid; +import org.jinterop.dcom.core.JIComServer; +import org.jinterop.dcom.core.JISession; +import org.openscada.opc.dcom.da.IORequest; +import org.openscada.opc.dcom.da.impl.OPCGroupStateMgt; +import org.openscada.opc.dcom.da.impl.OPCItemIO; +import org.openscada.opc.dcom.da.impl.OPCServer; + +/** + * Query指定的Item + * + * @author Freud + * + */ +public class DCOMTest6 { + + public static void main(String[] args) throws Exception { + JISystem.setAutoRegisteration(true); + + /** + * Session获取 + */ + JISession _session = JISession.createSession( + getEntryValue(CONFIG_DOMAIN), getEntryValue(CONFIG_USERNAME), + getEntryValue(CONFIG_PASSWORD)); + + final JIComServer comServer = new JIComServer( + JIClsid.valueOf(getEntryValue(CONFIG_CLSID)), + getEntryValue(CONFIG_HOST), _session); + + final IJIComObject serverObject = comServer.createInstance(); + + OPCServer server = new OPCServer(serverObject); + + /** + * 添加一个Group的信息 + */ + OPCGroupStateMgt group = server.addGroup("test", true, 100, 1234, 60, + 0.0f, 1033); + + final OPCItemIO itemIO = server.getItemIOService(); + queryItems(itemIO, "Saw-toothed Waves.Int"); + + // clean up + server.removeGroup(group, true); + } + + public static void queryItems(final OPCItemIO itemIO, final String... items) + throws JIException { + final List requests = new LinkedList(); + for (final String item : items) { + requests.add(new IORequest(item, 0)); + } + itemIO.read(requests.toArray(new IORequest[0])); + } +} diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest7.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest7.java new file mode 100644 index 0000000..edca637 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DCOMTest7.java @@ -0,0 +1,201 @@ +package com.freud.dcom.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_CLSID; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import java.net.UnknownHostException; +import java.util.ArrayList; +import java.util.List; +import java.util.Random; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.common.JISystem; +import org.jinterop.dcom.core.IJIComObject; +import org.jinterop.dcom.core.JIClsid; +import org.jinterop.dcom.core.JIComServer; +import org.jinterop.dcom.core.JISession; +import org.openscada.opc.dcom.common.EventHandler; +import org.openscada.opc.dcom.common.KeyedResult; +import org.openscada.opc.dcom.common.KeyedResultSet; +import org.openscada.opc.dcom.common.Result; +import org.openscada.opc.dcom.common.ResultSet; +import org.openscada.opc.dcom.common.impl.OPCCommon; +import org.openscada.opc.dcom.da.OPCDATASOURCE; +import org.openscada.opc.dcom.da.OPCITEMDEF; +import org.openscada.opc.dcom.da.OPCITEMRESULT; +import org.openscada.opc.dcom.da.impl.OPCAsyncIO2; +import org.openscada.opc.dcom.da.impl.OPCAsyncIO2.AsyncResult; +import org.openscada.opc.dcom.da.impl.OPCGroupStateMgt; +import org.openscada.opc.dcom.da.impl.OPCItemMgt; +import org.openscada.opc.dcom.da.impl.OPCServer; + +/** + * 通过Scope遍历OPC连接下的所有Group信息 + * + * @author Freud + * + */ +public class DCOMTest7 { + + public static void main(String[] args) throws Exception { + JISystem.setAutoRegisteration(true); + + /** + * Session获取 + */ + JISession _session = JISession.createSession( + getEntryValue(CONFIG_DOMAIN), getEntryValue(CONFIG_USERNAME), + getEntryValue(CONFIG_PASSWORD)); + + final JIComServer comServer = new JIComServer( + JIClsid.valueOf(getEntryValue(CONFIG_CLSID)), + getEntryValue(CONFIG_HOST), _session); + + final IJIComObject serverObject = comServer.createInstance(); + + OPCServer server = new OPCServer(serverObject); + + /** + * 添加一个Group的信息 + */ + OPCGroupStateMgt group = server.addGroup("test", true, 100, 1234, 60, + 0.0f, 1033); + + testItems(server, group, new String[] { "Saw-toothed Waves.Int2" }); + + // clean up + server.removeGroup(group, true); + } + + public static void testItems(final OPCServer server, + final OPCGroupStateMgt group, final String... itemIDs) + throws IllegalArgumentException, UnknownHostException, JIException { + final OPCItemMgt itemManagement = group.getItemManagement(); + final List items = new ArrayList(itemIDs.length); + for (final String id : itemIDs) { + final OPCITEMDEF item = new OPCITEMDEF(); + item.setItemID(id); + item.setClientHandle(new Random().nextInt()); + items.add(item); + } + + final OPCITEMDEF[] itemArray = items.toArray(new OPCITEMDEF[0]); + + System.out.println("Validate"); + KeyedResultSet result = itemManagement + .validate(itemArray); + if (!dumpOPCITEMRESULT(result)) { + return; + } + + // now add them to the group + System.out.println("Add"); + result = itemManagement.add(itemArray); + if (!dumpOPCITEMRESULT(result)) { + return; + } + + // get the server handle array + final Integer[] serverHandles = new Integer[itemArray.length]; + for (int i = 0; i < itemArray.length; i++) { + serverHandles[i] = new Integer(result.get(i).getValue() + .getServerHandle()); + } + + // set them active + System.out.println("Activate"); + final ResultSet resultSet = itemManagement.setActiveState( + true, serverHandles); + for (final Result resultEntry : resultSet) { + System.out.println(String.format("Item: %08X, Error: %08X", + resultEntry.getValue(), resultEntry.getErrorCode())); + } + + // set client handles + System.out.println("Set client handles"); + final Integer[] clientHandles = new Integer[serverHandles.length]; + for (int i = 0; i < serverHandles.length; i++) { + clientHandles[i] = i; + } + itemManagement.setClientHandles(serverHandles, clientHandles); + + System.out.println("Create async IO 2.0 object"); + final OPCAsyncIO2 asyncIO2 = group.getAsyncIO2(); + + // connect handler + System.out.println("attach"); + final EventHandler eventHandler = group.attach(new DumpDataCallback()); + + System.out.println("attach..enable"); + asyncIO2.setEnable(true); + + System.out.println("attach..refresh"); + final int cancelId = asyncIO2.refresh(OPCDATASOURCE.OPC_DS_DEVICE, 1); + System.out.println("Cancel ID: " + cancelId); + + System.out.println("attach..read"); + final AsyncResult asyncResult = asyncIO2.read(2, serverHandles); + System.out.println(String.format("attach..read..cancelId: %08X", + asyncResult.getCancelId())); + + // sleep + try { + System.out.println("Waiting..."); + Thread.sleep(10 * 1000); + } catch (final InterruptedException e) { + e.printStackTrace(); + } + + System.out.println("Detaching"); + eventHandler.detach(); + + // set them inactive + System.out.println("In-Active"); + itemManagement.setActiveState(false, serverHandles); + + // finally remove them again + System.out.println("Remove"); + itemManagement.remove(serverHandles); + } + + public static void showError(final OPCCommon common, final int errorCode) + throws JIException { + System.out.println(String.format("Error (%X): '%s'", errorCode, + common.getErrorString(errorCode, 1033))); + } + + public static void showError(final OPCServer server, final int errorCode) + throws JIException { + showError(server.getCommon(), errorCode); + } + + public static boolean dumpOPCITEMRESULT( + final KeyedResultSet result) { + int failed = 0; + for (final KeyedResult resultEntry : result) { + System.out.println("=================================="); + System.out.println(String.format("Item: '%s' ", resultEntry + .getKey().getItemID())); + + System.out.println(String.format("Error Code: %08x", + resultEntry.getErrorCode())); + if (!resultEntry.isFailed()) { + System.out.println(String.format("Server Handle: %08X", + resultEntry.getValue().getServerHandle())); + System.out.println(String.format("Data Type: %d", resultEntry + .getValue().getCanonicalDataType())); + System.out.println(String.format("Access Rights: %d", + resultEntry.getValue().getAccessRights())); + System.out.println(String.format("Reserved: %d", resultEntry + .getValue().getReserved())); + } else { + failed++; + } + } + return failed == 0; + } +} diff --git a/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DumpDataCallback.java b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DumpDataCallback.java new file mode 100644 index 0000000..bc1a978 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/dcom/utgard/cases/DumpDataCallback.java @@ -0,0 +1,60 @@ +package com.freud.dcom.utgard.cases; + +import org.openscada.opc.dcom.common.KeyedResult; +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; + +public class DumpDataCallback implements IOPCDataCallback { + + public void cancelComplete(final int transactionId, + final int serverGroupHandle) { + System.out.println(String.format("cancelComplete: %08X, Group: %08X", + transactionId, serverGroupHandle)); + } + + public void dataChange(final int transactionId, + final int serverGroupHandle, final int masterQuality, + final int masterErrorCode, + final KeyedResultSet result) { + + System.out.println(String.format( + "dataChange: %d, Group: %08X, MasterQ: %d, Error: %d", + transactionId, serverGroupHandle, masterQuality, + masterErrorCode)); + + for (final KeyedResult entry : result) { + System.out.println(String.format( + "%08X - Error: %08X, Quality: %d, %Tc - %s", + entry.getKey(), entry.getErrorCode(), entry.getValue() + .getQuality(), entry.getValue().getTimestamp(), + entry.getValue().getValue().toString())); + } + + } + + public void readComplete(final int transactionId, + final int serverGroupHandle, final int masterQuality, + final int masterErrorCode, + final KeyedResultSet result) { + System.out.println(String.format( + "readComplete: %d, Group: %08X, MasterQ: %d, Error: %d", + transactionId, serverGroupHandle, masterQuality, + masterErrorCode)); + + for (final KeyedResult entry : result) { + System.out.println(String.format( + "%08X - Error: %08X, Quality: %d, %Tc - %s", + entry.getKey(), entry.getErrorCode(), entry.getValue() + .getQuality(), entry.getValue().getTimestamp(), + entry.getValue().getValue().toString())); + } + } + + public void writeComplete(final int transactionId, + final int serverGroupHandle, final int masterErrorCode, + final ResultSet result) { + // TODO Auto-generated method stub + } +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/BaseConfiguration.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/BaseConfiguration.java new file mode 100644 index 0000000..2bb090e --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/BaseConfiguration.java @@ -0,0 +1,85 @@ +package com.freud.opc.utgard; + +import java.io.IOException; +import java.util.Properties; + +import org.openscada.opc.lib.common.ConnectionInformation; + +/** + * 配置文件工具类 + * + * @author Freud + * + */ +public final class BaseConfiguration { + + private final static ConnectionInformation ci; + private final static Properties prop; + + public final static String CONFIG_USERNAME = "username"; + public final static String CONFIG_PASSWORD = "password"; + public final static String CONFIG_HOST = "host"; + public final static String CONFIG_DOMAIN = "domain"; + public final static String CONFIG_CLSID = "clsid"; + public final static String CONFIG_PROGID = "progid"; + + private final static String CONFIG_FILE_NAME = "config.properties"; + + /** + * 加载配置文件 + */ + static { + ci = new ConnectionInformation(); + prop = new Properties(); + try { + prop.load(BaseConfiguration.class.getClassLoader() + .getResourceAsStream(CONFIG_FILE_NAME)); + } catch (IOException e) { + e.printStackTrace(); + } + } + + /** + * 通过名字获得配置的值 + * + * @param name + * @return + */ + public static String getEntryValue(String name) { + return prop.getProperty(name); + } + + /** + * 获得包含ClsId的连接信息 + * + * @return + */ + public static ConnectionInformation getCLSIDConnectionInfomation() { + ci.setProgId(null); + getConnectionInfomation(); + ci.setClsid(prop.getProperty(CONFIG_CLSID)); + return ci; + } + + /** + * 获得包含ProgId的连接信息 + * + * @return + */ + public static ConnectionInformation getPROGIDConnectionInfomation() { + ci.setClsid(null); + getConnectionInfomation(); + ci.setProgId(prop.getProperty(CONFIG_PROGID)); + return ci; + } + + /** + * 获得基础的连接信息 + */ + private static void getConnectionInfomation() { + ci.setHost(prop.getProperty(CONFIG_HOST)); + ci.setDomain(prop.getProperty(CONFIG_DOMAIN)); + ci.setUser(prop.getProperty(CONFIG_USERNAME)); + ci.setPassword(prop.getProperty(CONFIG_PASSWORD)); + } +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest1.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest1.java new file mode 100644 index 0000000..8d21dfe --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest1.java @@ -0,0 +1,50 @@ +package com.freud.opc.utgard.cases; + +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_DOMAIN; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_HOST; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_PASSWORD; +import static com.freud.opc.utgard.BaseConfiguration.CONFIG_USERNAME; +import static com.freud.opc.utgard.BaseConfiguration.getEntryValue; + +import java.util.Collection; + +import org.openscada.opc.dcom.list.ClassDetails; +import org.openscada.opc.lib.list.Categories; +import org.openscada.opc.lib.list.Category; +import org.openscada.opc.lib.list.ServerList; + +/** + * 获得Server上所有的OPC连接信息 + * + * @author Freud + * + */ +public class OPCTest1 { + + public static void main(String[] args) throws Exception { + + ServerList serverList = new ServerList(getEntryValue(CONFIG_HOST), + getEntryValue(CONFIG_USERNAME), getEntryValue(CONFIG_PASSWORD), + getEntryValue(CONFIG_DOMAIN)); + + /** 通过ProgId获得ClsId，然后获得ClassDetai */ + // final String cls = serverList + // .getClsIdFromProgId("Matrikon.OPC.Simulation.1"); + // + // ClassDetails cd = serverList.getDetails(cls); + // + // if (cd != null) { + // System.out.println(cd.getProgId() + "=" + cd.getDescription()); + // } + + Collection classDetails = serverList + .listServersWithDetails(new Category[] { + Categories.OPCDAServer10, Categories.OPCDAServer20, + Categories.OPCDAServer30 }, new Category[] {}); + + for (ClassDetails cds : classDetails) { + System.out.println(cds.getProgId() + "=" + cds.getDescription()); + } + + } +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest2.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest2.java new file mode 100644 index 0000000..38d069c --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest2.java @@ -0,0 +1,96 @@ +package com.freud.opc.utgard.cases; + +import java.net.UnknownHostException; +import java.util.concurrent.Executors; + +import org.jinterop.dcom.common.JIException; +import org.openscada.opc.lib.da.Server; +import org.openscada.opc.lib.da.browser.Branch; +import org.openscada.opc.lib.da.browser.FlatBrowser; +import org.openscada.opc.lib.da.browser.Leaf; + +import com.freud.opc.utgard.BaseConfiguration; + +/** + * 通过ClsId定位到连接，并将连接下的所有Group和Item打印 + * + * @author Freud + * + */ +public class OPCTest2 { + + public static void main(String[] args) throws Exception { + + Server server = new Server( + BaseConfiguration.getCLSIDConnectionInfomation(), + Executors.newSingleThreadScheduledExecutor()); + + server.connect(); + + /** 获得OPC连接下所有的Group和Item */ + dumpTree(server.getTreeBrowser().browse(), 0); + /** 获得OPC下所有的Item */ + dumpFlat(server.getFlatBrowser()); + + server.disconnect(); + } + + /** + * 遍历Flat结构的所有Item值 + * + * @param browser + * @throws IllegalArgumentException + * @throws UnknownHostException + * @throws JIException + */ + private static void dumpFlat(final FlatBrowser browser) + throws IllegalArgumentException, UnknownHostException, JIException { + for (String name : browser.browse()) { + System.out.println(name); + } + } + + /** + * 遍历Tree结构 + * + * @param branch + * @param level + */ + private static void dumpTree(final Branch branch, final int level) { + + for (final Leaf leaf : branch.getLeaves()) { + dumpLeaf(leaf, level); + } + for (final Branch subBranch : branch.getBranches()) { + dumpBranch(subBranch, level); + dumpTree(subBranch, level + 1); + } + } + + private static String printTab(int level) { + StringBuilder sb = new StringBuilder(); + for (int i = 0; i < level; i++) { + sb.append("\t"); + } + return sb.toString(); + } + + /** + * 打印Item + * + * @param leaf + */ + private static void dumpLeaf(final Leaf leaf, final int level) { + System.out.println(printTab(level) + "Leaf: " + leaf.getName() + ":" + + leaf.getItemId()); + } + + /** + * 打印Group + * + * @param branch + */ + private static void dumpBranch(final Branch branch, final int level) { + System.out.println(printTab(level) + "Branch: " + branch.getName()); + } +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest3.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest3.java new file mode 100644 index 0000000..0b8a5a7 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest3.java @@ -0,0 +1,51 @@ +package com.freud.opc.utgard.cases; + +import java.util.Map; +import java.util.Map.Entry; +import java.util.concurrent.Executors; + +import org.jinterop.dcom.common.JIException; +import org.openscada.opc.lib.da.Group; +import org.openscada.opc.lib.da.Item; +import org.openscada.opc.lib.da.Server; + +import com.freud.opc.utgard.BaseConfiguration; + +/** + * 同步读取某个点位的值 + * + * @author Freud + * + */ +public class OPCTest3 { + + public static void main(String[] args) throws Exception { + + Server server = new Server( + BaseConfiguration.getCLSIDConnectionInfomation(), + Executors.newSingleThreadScheduledExecutor()); + + server.connect(); + + Group group = server.addGroup(); + Item item = group.addItem("Random.Real5"); + + Map items = group.addItems("Random.Real1", + "Random.Real2", "Random.Real3", "Random.Real4"); + + dumpItem(item); + + for (Entry temp : items.entrySet()) { + dumpItem(temp.getValue()); + } + + server.dispose(); + } + + private static void dumpItem(Item item) throws JIException { + System.out.println("[" + (++count) + "],ItemName:[" + item.getId() + + "],value:" + item.read(false).getValue()); + } + + private static int count; +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest4.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest4.java new file mode 100644 index 0000000..390f9be --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest4.java @@ -0,0 +1,64 @@ +package com.freud.opc.utgard.cases; + +import java.util.concurrent.Executors; + +import org.openscada.opc.lib.da.AccessBase; +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; +import org.openscada.opc.lib.da.SyncAccess; + +import com.freud.opc.utgard.BaseConfiguration; + +/** + * 同步Access，读取某个点的变化值 + * + * @author Freud + * + */ +public class OPCTest4 { + + /** 间隔时间 */ + private static final int PERIOD = 100; + + /** 休眠时间 */ + private static final int SLEEP = 2000; + + public static void main(String[] args) throws Exception { + + Server server = new Server( + BaseConfiguration.getCLSIDConnectionInfomation(), + Executors.newSingleThreadScheduledExecutor()); + + server.connect(); + + /** + * 其中100单位为毫秒，为每次从OPC获取刷新的间隔时间 + */ + AccessBase access = new SyncAccess(server, PERIOD); + + /** + * 定时每隔间隔时间获取一次值 + */ + access.addItem("Random.Real5", new DataCallback() { + private int i; + + @Override + public void changed(Item item, ItemState itemstate) { + System.out.println("[" + (++i) + "],ItemName:[" + item.getId() + + "],value:" + itemstate.getValue()); + } + }); + + /** 开始监听 */ + access.bind(); + + /** 当前线程休眠时间单位：毫秒 */ + Thread.sleep(SLEEP); + /** 监听 结束 */ + access.unbind(); + + server.dispose(); + } +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest5.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest5.java new file mode 100644 index 0000000..d37edba --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest5.java @@ -0,0 +1,65 @@ +package com.freud.opc.utgard.cases; + +import java.util.concurrent.Executors; + +import org.openscada.opc.lib.da.AccessBase; +import org.openscada.opc.lib.da.Async20Access; +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; + +import com.freud.opc.utgard.BaseConfiguration; + +/** + * 异步Access，订阅读取点位的值,并且只有值有变化的时候才会触发CallBack函数 + * + * @author Freud + * + */ +public class OPCTest5 { + + /** 间隔时间 */ + private static final int PERIOD = 100; + + /** 休眠时间 */ + private static final int SLEEP = 2000; + + public static void main(String[] args) throws Exception { + + Server server = new Server( + BaseConfiguration.getCLSIDConnectionInfomation(), + Executors.newSingleThreadScheduledExecutor()); + + server.connect(); + + /** + * 其中100单位为毫秒，为每次从OPC获取刷新的间隔时间 + */ + AccessBase access = new Async20Access(server, PERIOD, false); + + /** + * 只有Item的值有变化的时候才会触发CallBack函数 + */ + access.addItem("Random.Real5", new DataCallback() { + + private int count; + + @Override + public void changed(Item item, ItemState itemstate) { + System.out.println("[" + (++count) + "],ItemName:[" + + item.getId() + "],value:" + itemstate.getValue()); + } + }); + + /** 开始监听 */ + access.bind(); + + /** 当前线程休眠时间单位：毫秒 */ + Thread.sleep(SLEEP); + /** 监听 结束 */ + access.unbind(); + + server.dispose(); + } +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest6.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest6.java new file mode 100644 index 0000000..3685d6b --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest6.java @@ -0,0 +1,68 @@ +package com.freud.opc.utgard.cases; + +import java.util.concurrent.Executors; + +import org.openscada.opc.lib.da.AccessBase; +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; +import org.openscada.opc.lib.da.SyncAccess; + +import com.freud.opc.utgard.BaseConfiguration; + +/** + * 如果Connection Break掉了，会自动重新连接 + * + * @author Freud + * + */ +public class OPCTest6 { + + /** 间隔时间 */ + private static final int PERIOD = 100; + + /** 休眠时间 */ + private static final int SLEEP = 2000; + + public static void main(String[] args) throws Exception { + + Server server = new Server( + BaseConfiguration.getCLSIDConnectionInfomation(), + Executors.newSingleThreadScheduledExecutor()); + + AutoReconnectController controller = new AutoReconnectController(server); + + controller.connect(); + + /** + * 其中100单位为毫秒，为每次从OPC获取刷新的间隔时间 + */ + AccessBase access = new SyncAccess(server, PERIOD); + + /** + * 定时每隔间隔时间获取一次值 + */ + access.addItem("Random.Real5", new DataCallback() { + private int i; + + @Override + public void changed(Item item, ItemState itemstate) { + System.out.println("[" + (++i) + "],ItemName:[" + item.getId() + + "],value:" + itemstate.getValue()); + } + }); + + /** 开始监听 */ + access.bind(); + + /** 当前线程休眠时间单位：毫秒 */ + Thread.sleep(SLEEP); + /** 监听结束 */ + access.unbind(); + + controller.disconnect(); + + } +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest7.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest7.java new file mode 100644 index 0000000..aa0b243 --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest7.java @@ -0,0 +1,55 @@ +package com.freud.opc.utgard.cases; + +import java.util.concurrent.Executors; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.core.JIArray; +import org.jinterop.dcom.core.JIVariant; +import org.openscada.opc.lib.da.Group; +import org.openscada.opc.lib.da.Item; +import org.openscada.opc.lib.da.Server; + +import com.freud.opc.utgard.BaseConfiguration; + +/** + * 同步写入某个点位的值 + * + * @author Freud + * + */ +public class OPCTest7 { + + public static void main(String[] args) throws Exception { + + Server server = new Server( + BaseConfiguration.getCLSIDConnectionInfomation(), + Executors.newSingleThreadScheduledExecutor()); + + server.connect(); + + Group group = server.addGroup(); + Item item = group.addItem("Square Waves.Real4"); + + /** 构造写入数据 */ + final Float[] integerData = new Float[] { 1202f, 1203f, 1204f }; + final JIArray array = new JIArray(integerData, false); + final JIVariant value = new JIVariant(array); + + /** 同步写入 */ + item.write(value); + Thread.sleep(1000); + + /** Dump出item的值 */ + dumpItem(item); + + server.dispose(); + + } + + private static void dumpItem(Item item) throws JIException { + System.out.println("[" + (++count) + "],ItemName:[" + item.getId() + + "],value:" + item.read(true).getValue()); + } + + private static int count; +} diff --git a/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest8.java b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest8.java new file mode 100644 index 0000000..315ff2b --- /dev/null +++ b/OPC_Client_Utgard/src/com/freud/opc/utgard/cases/OPCTest8.java @@ -0,0 +1,54 @@ +package com.freud.opc.utgard.cases; + +import java.util.concurrent.Executors; + +import org.jinterop.dcom.common.JIException; +import org.jinterop.dcom.core.JIArray; +import org.jinterop.dcom.core.JIVariant; +import org.openscada.opc.lib.da.Group; +import org.openscada.opc.lib.da.Item; +import org.openscada.opc.lib.da.Server; + +import com.freud.opc.utgard.BaseConfiguration; + +/** + * 异步写入 + * + * @author Freud + * + */ +public class OPCTest8 { + + public static void main(String[] args) throws Exception { + + Server server = new Server( + BaseConfiguration.getCLSIDConnectionInfomation(), + Executors.newSingleThreadScheduledExecutor()); + + server.connect(); + + Group group = server.addGroup(); + Item item = group.addItem("Square Waves.Real4"); + + /** 构造写入数据 */ + final Float[] integerData = new Float[] { 1202f, 1203f, 1204f }; + final JIArray array = new JIArray(integerData, false); + final JIVariant value = new JIVariant(array); + + /** 同步写入 */ + item.write(value); + Thread.sleep(1000); + + /** Dump出item的值 */ + dumpItem(item); + + server.dispose(); + } + + private static void dumpItem(Item item) throws JIException { + System.out.println("[" + (++count) + "],ItemName:[" + item.getId() + + "],value:" + item.read(true).getValue()); + } + + private static int count; +} diff --git a/OPC_Client_Utgard/src/config.properties b/OPC_Client_Utgard/src/config.properties new file mode 100644 index 0000000..f9dc925 --- /dev/null +++ b/OPC_Client_Utgard/src/config.properties @@ -0,0 +1,6 @@ +host=10.1.5.123 +domain= +username=neusoft +password=`1nktd84jx +clsid=F8582CF2-88FB-11D0-B850-00C0F0104305 +progid= diff --git a/OPC_Client_Utgard/src/log4j.out.xml b/OPC_Client_Utgard/src/log4j.out.xml new file mode 100644 index 0000000..e69de29 diff --git a/OPC_Client_Utgard/src/log4j.xml b/OPC_Client_Utgard/src/log4j.xml new file mode 100644 index 0000000..57e3c02 --- /dev/null +++ b/OPC_Client_Utgard/src/log4j.xml @@ -0,0 +1,32 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file