mirror of
https://github.com/open62541/open62541.git
synced 2026-10-17 04:42:09 +08:00
Julius Pfrommer
100 lines
3.9 KiB
C
100 lines
3.9 KiB
C
/* This work is licensed under a Creative Commons CCZero 1.0 Universal License.
|
|
* See http://creativecommons.org/publicdomain/zero/1.0/ for more information. */
|
|
|
|
#include <open62541/client.h>
|
|
#include <open62541/client_config_default.h>
|
|
#include <open62541/client_highlevel.h>
|
|
#include <open62541/client_subscriptions.h>
|
|
#include <open62541/plugin/log_stdout.h>
|
|
#include <open62541/server.h>
|
|
#include <open62541/server_config_default.h>
|
|
#include <open62541/util.h>
|
|
|
|
#include <stdio.h>
|
|
|
|
static void
|
|
handler_events(UA_Client *client, UA_UInt32 subId, void *subContext,
|
|
UA_UInt32 monId, void *monContext,
|
|
const UA_KeyValueMap eventFields) {
|
|
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_APPLICATION, "Notification");
|
|
|
|
for(size_t i = 0; i < eventFields.mapSize; ++i) {
|
|
UA_String out = UA_STRING_NULL;
|
|
UA_print(&eventFields.map[i].value, &UA_TYPES[UA_TYPES_VARIANT], &out);
|
|
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_APPLICATION,
|
|
"%S: '%S", eventFields.map[i].key.name, out);
|
|
UA_String_clear(&out);
|
|
}
|
|
}
|
|
|
|
int main(int argc, char *argv[]) {
|
|
if(argc < 2) {
|
|
printf("Usage: tutorial_client_events <opc.tcp://server-url>\n");
|
|
return 0;
|
|
}
|
|
|
|
UA_Client *client = UA_Client_new();
|
|
UA_ClientConfig_setDefault(UA_Client_getConfig(client));
|
|
|
|
/* opc.tcp://uademo.prosysopc.com:53530/OPCUA/SimulationServer */
|
|
/* opc.tcp://opcua.demo-this.com:51210/UA/SampleServer */
|
|
UA_StatusCode retval = UA_Client_connect(client, argv[1]);
|
|
if(retval != UA_STATUSCODE_GOOD) {
|
|
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_APPLICATION, "Could not connect");
|
|
UA_Client_delete(client);
|
|
return 0;
|
|
}
|
|
|
|
/* Create a subscription */
|
|
UA_CreateSubscriptionRequest request = UA_CreateSubscriptionRequest_default();
|
|
UA_CreateSubscriptionResponse response =
|
|
UA_Client_Subscriptions_create(client, request, NULL, NULL, NULL);
|
|
if(response.responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
|
|
UA_Client_disconnect(client);
|
|
UA_Client_delete(client);
|
|
return 0;
|
|
}
|
|
UA_UInt32 subId = response.subscriptionId;
|
|
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_APPLICATION,
|
|
"Create subscription succeeded, id %u", subId);
|
|
|
|
/* Add a MonitoredItem */
|
|
UA_MonitoredItemCreateRequest item;
|
|
UA_MonitoredItemCreateRequest_init(&item);
|
|
item.itemToMonitor.nodeId = UA_NS0ID(SERVER);
|
|
item.itemToMonitor.attributeId = UA_ATTRIBUTEID_EVENTNOTIFIER;
|
|
item.monitoringMode = UA_MONITORINGMODE_REPORTING;
|
|
|
|
/* Set the EventFilter. See the documentation for the human-readable
|
|
* EventFilter expression developed for open62541. */
|
|
char *eventFilter = "SELECT /Message, /Severity WHERE /Severity >= 100";
|
|
UA_EventFilter filter;
|
|
retval = UA_EventFilter_parse(&filter, UA_STRING(eventFilter), NULL);
|
|
UA_assert(retval == UA_STATUSCODE_GOOD);
|
|
UA_ExtensionObject_setValue(&item.requestedParameters.filter,
|
|
&filter, &UA_TYPES[UA_TYPES_EVENTFILTER]);
|
|
|
|
UA_MonitoredItemCreateResult result =
|
|
UA_Client_MonitoredItems_createEvent(client, subId,
|
|
UA_TIMESTAMPSTORETURN_BOTH, item,
|
|
NULL, handler_events, NULL);
|
|
|
|
if(result.statusCode == UA_STATUSCODE_GOOD) {
|
|
/* Run the client until ctrl-c */
|
|
UA_Client_runUntilInterrupt(client);
|
|
} else {
|
|
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_APPLICATION,
|
|
"Could not add the MonitoredItem with %s",
|
|
UA_StatusCode_name(result.statusCode));
|
|
}
|
|
|
|
/* Disconnect and clean up */
|
|
UA_Client_Subscriptions_deleteSingle(client, response.subscriptionId);
|
|
UA_Client_disconnect(client);
|
|
UA_Client_delete(client);
|
|
UA_MonitoredItemCreateResult_clear(&result);
|
|
UA_EventFilter_clear(&filter);
|
|
|
|
return 0;
|
|
}
|