mirror of
https://github.com/open62541/open62541.git
synced 2026-10-19 14:22:58 +08:00
Julius Pfrommer
65 lines
2.9 KiB
C
65 lines
2.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/plugin/log_stdout.h>
|
|
#include <open62541/server.h>
|
|
#include <open62541/server_pubsub.h>
|
|
|
|
#include <stdlib.h>
|
|
|
|
/**
|
|
* The PubSub connection example demonstrate the PubSub TransportLayer configuration and
|
|
* the dynamic creation of PubSub Connections on runtime.
|
|
*/
|
|
int main(void) {
|
|
UA_Server *server = UA_Server_new();
|
|
|
|
/* Create a new ConnectionConfig. The addPubSubConnection function takes the
|
|
* config and create a new connection. The Connection identifier is
|
|
* copied to the NodeId parameter.*/
|
|
UA_PubSubConnectionConfig connectionConfig;
|
|
memset(&connectionConfig, 0, sizeof(connectionConfig));
|
|
connectionConfig.name = UA_STRING("UDP-UADP Connection 1");
|
|
connectionConfig.transportProfileUri =
|
|
UA_STRING("http://opcfoundation.org/UA-Profile/Transport/pubsub-udp-uadp");
|
|
/* The address and interface is part of the standard
|
|
* defined UA_NetworkAddressUrlDataType. */
|
|
UA_NetworkAddressUrlDataType networkAddressUrl =
|
|
{UA_STRING_NULL , UA_STRING("opc.udp://224.0.0.22:4840/")};
|
|
UA_Variant_setScalar(&connectionConfig.address, &networkAddressUrl,
|
|
&UA_TYPES[UA_TYPES_NETWORKADDRESSURLDATATYPE]);
|
|
connectionConfig.publisherId.idType = UA_PUBLISHERIDTYPE_UINT32;
|
|
connectionConfig.publisherId.id.uint32 = UA_UInt32_random();
|
|
/* Connection options are given as Key/Value Pairs. The available options are
|
|
* maybe standard or vendor defined. */
|
|
UA_KeyValuePair connectionOptions[3];
|
|
connectionOptions[0].key = UA_QUALIFIEDNAME(0, "ttl");
|
|
UA_UInt32 ttl = 10;
|
|
UA_Variant_setScalar(&connectionOptions[0].value, &ttl, &UA_TYPES[UA_TYPES_UINT32]);
|
|
connectionOptions[1].key = UA_QUALIFIEDNAME(0, "loopback");
|
|
UA_Boolean loopback = false;
|
|
UA_Variant_setScalar(&connectionOptions[1].value, &loopback, &UA_TYPES[UA_TYPES_BOOLEAN]);
|
|
connectionOptions[2].key = UA_QUALIFIEDNAME(0, "reuse");
|
|
UA_Boolean reuse = true;
|
|
UA_Variant_setScalar(&connectionOptions[2].value, &reuse, &UA_TYPES[UA_TYPES_BOOLEAN]);
|
|
connectionConfig.connectionProperties.map = connectionOptions;
|
|
connectionConfig.connectionProperties.mapSize = 3;
|
|
/* Create a new concrete connection and add the connection
|
|
* to the current PubSub configuration. */
|
|
UA_NodeId connectionIdentifier;
|
|
UA_StatusCode retval =
|
|
UA_Server_addPubSubConnection(server, &connectionConfig, &connectionIdentifier);
|
|
if(retval == UA_STATUSCODE_GOOD){
|
|
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_SERVER,
|
|
"The PubSub Connection was created successfully!");
|
|
}
|
|
|
|
/* Enable the PubSubComponents */
|
|
UA_Server_enableAllPubSubComponents(server);
|
|
retval = UA_Server_runUntilInterrupt(server);
|
|
|
|
UA_Server_delete(server);
|
|
return retval == UA_STATUSCODE_GOOD ? EXIT_SUCCESS : EXIT_FAILURE;
|
|
}
|