问题描述
我正在尝试构建学习 open62541，我正在使用示例示例 Here。
我将示例保存为 publish.c 并使用 cmake 选项编译， cmake -DUA_ENABLE_SUBSCRIPTIONS=ON -DUA_ARCHITECTURE=freertosLWIP -DUA_ENABLE_AMALGAMATION=ON -DUA_ENABLE_PUBSUB=ON -DUA_ENABLE_PUBSUB_ETH_UADP=ON ../ 编译示例后 我收到以下错误：
[2021-02-10 21:15:41.328 (UTC+0100)] warn/server AccessControl: Unconfigured AccessControl. Users have all permissions.
[2021-02-10 21:15:41.328 (UTC+0100)] info/server AccessControl: Anonymous login is enabled
[2021-02-10 21:15:41.328 (UTC+0100)] warn/server Username/Password configured,but no encrypting SecurityPolicy. This can leak credentials on the network.
[2021-02-10 21:15:41.328 (UTC+0100)] warn/userland AcceptAll Certificate Verification. Any remote certificate will be accepted.
[2021-02-10 21:15:41.328 (UTC+0100)] info/userland PubSub channel requested
[2021-02-10 21:15:41.328 (UTC+0100)] info/network TCP network layer listening on opc.tcp://gaurav-VirtualBox:4840
[2021-02-10 21:15:41.431 (UTC+0100)] warn/server PubSub Connection sending Failed.
[2021-02-10 21:15:41.431 (UTC+0100)] error/server PubSub Publish: Could not send a NetworkMessage
[2021-02-10 21:15:41.528 (UTC+0100)] warn/server PubSub Connection sending Failed.
[2021-02-10 21:15:41.528 (UTC+0100)] error/server PubSub Publish: Could not send a NetworkMessage
[2021-02-10 21:15:41.631 (UTC+0100)] warn/server PubSub Connection sending Failed.
[2021-02-10 21:15:41.631 (UTC+0100)] error/server PubSub Publish: Could not send a NetworkMessage
**[2021-02-10 21:15:41.729 (UTC+0100)] warn/server PubSub Connection sending Failed.
[2021-02-10 21:15:41.729 (UTC+0100)] error/server PubSub Publish: Could not send a NetworkMessage**
我将发布间隔更改为 1 秒。 因此，每 1 秒后，已发布的消息就会发出消息，但不知何故我收到此错误：
**PubSub Connection sending Failed. & error/server PubSub Publish: Could not send a NetworkMessage**
连续直到按下 ctrl-c。
谁能帮我在我的电脑上实现这个功能
代码如下
#include "OPcua/open62541.h"
#include "OPcua/opcua.h"
UA_NodeId connectionIdent,publishedDataSetIdent,writerGroupIdent,dataSetWriterIdent;
UA_NodeId connectionIdentifier;
UA_PublishedDataSetConfig publishedDataSetConfig;
UA_DataSetWriterConfig dataSetWriterConfig;
UA_Boolean running = true;
static void
addPubSubConnection(UA_Server *server,UA_String *transportProfile,UA_NetworkAddressUrlDataType *networkAddressUrl){
/* Details about the connection configuration and handling are located
* in the pubsub connection tutorial */
UA_PubSubConnectionConfig connectionConfig;
memset(&connectionConfig,sizeof(connectionConfig));
connectionConfig.name = UA_STRING("UADP Connection 1");
connectionConfig.transportProfileUri = *transportProfile;
connectionConfig.enabled = UA_TRUE;
UA_Variant_setScalar(&connectionConfig.address,networkAddressUrl,&UA_TYPES[UA_TYPES_NETWORKADDRESSURLDATATYPE]);
/* Changed to static publisherId from random generation to identify
* the publisher on Subscriber side */
connectionConfig.publisherId.numeric = UA_UInt32_random();
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 = UA_FALSE;
UA_Variant_setScalar(&connectionoptions[1].value,&loopback,&UA_TYPES[UA_TYPES_BOOLEAN]);
connectionoptions[2].key = UA_QUALIFIednAME(0,"reuse");
UA_Boolean reuse = UA_TRUE;
UA_Variant_setScalar(&connectionoptions[2].value,&reuse,&UA_TYPES[UA_TYPES_BOOLEAN]);
connectionConfig.connectionProperties = connectionoptions;
connectionConfig.connectionPropertiesSize = 3;
UA_StatusCode retval = UA_Server_addPubSubConnection(server,&connectionConfig,&connectionIdent);
if (retval == UA_STATUSCODE_GOOD) {
UA_LOG_INFO(UA_Log_Stdout,UA_LOGCATEGORY_SERVER,"1 --> The PubSub Connection was added successfully!");
}
printf("networkAddressUrl.url : %s \n",networkAddressUrl->url.data);
printf ("Done addPubSubConnection here...\r\n");
}
static void
addPublishedDataSet(UA_Server *server) {
/* The PublishedDataSetConfig contains all necessary public
* @R_718_4045@ions for the creation of a new PublishedDataSet */
UA_PublishedDataSetConfig publishedDataSetConfig;
memset(&publishedDataSetConfig,sizeof(UA_PublishedDataSetConfig));
publishedDataSetConfig.publishedDataSetType = UA_PUBSUB_DATASET_PUBLISHEDITEMS;
publishedDataSetConfig.name = UA_STRING("Demo PDS");
/* Create new PublishedDataSet based on the PublishedDataSetConfig. */
UA_AddPublishedDataSetResult result = UA_Server_addPublishedDataSet(server,&publishedDataSetConfig,&publishedDataSetIdent);
if (result.addResult == UA_STATUSCODE_GOOD){
UA_LOG_INFO(UA_Log_Stdout,"2 -->The addPublishedDataSet was created successfully!");
}
printf ("Done addPublishedDataSet here...\r\n");
}
static void
addDataSetField(UA_Server *server) {
/* Add a field to the prevIoUs created PublishedDataSet */
UA_NodeId dataSetFieldIdent;
UA_DataSetFieldConfig dataSetFieldConfig;
memset(&dataSetFieldConfig,sizeof(UA_DataSetFieldConfig));
dataSetFieldConfig.dataSetFieldType = UA_PUBSUB_DATASETFIELD_VARIABLE;
dataSetFieldConfig.field.variable.fieldNameAlias = UA_STRING("Server localtime");
dataSetFieldConfig.field.variable.promotedField = UA_FALSE;
dataSetFieldConfig.field.variable.publishParameters.publishedVariable =
UA_NODEID_NUMERIC(0,UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME);
dataSetFieldConfig.field.variable.publishParameters.attributeId = UA_ATTRIBUTEID_VALUE;
UA_DataSetFieldResult result = UA_Server_addDataSetField(server,&dataSetFieldConfig,&dataSetFieldIdent);
if (result.result == UA_STATUSCODE_GOOD)
{
UA_LOG_INFO(UA_Log_Stdout,"3--> The PubSub UA_Server_addDataSetField successfully!");
}
printf ("Done addDataSetField here...\r\n");
}
static void
addWriterGroup(UA_Server *server) {
/* Now we create a new WriterGroupConfig and add the group to the existing
* PubSubConnection. */
UA_WriterGroupConfig writerGroupConfig;
memset(&writerGroupConfig,sizeof(UA_WriterGroupConfig));
writerGroupConfig.name = UA_STRING("Demo WriterGroup");
writerGroupConfig.publishingInterval = 1000;
writerGroupConfig.enabled = UA_FALSE;
writerGroupConfig.writerGroupId = 2234;
writerGroupConfig.encodingMimeType = UA_PUBSUB_ENCODING_UADP;
writerGroupConfig.messageSettings.encoding = UA_EXTENSIONOBJECT_DECODED;
writerGroupConfig.messageSettings.content.decoded.type = &UA_TYPES[UA_TYPES_UADPWRITERGROUPMESSAGEDATATYPE];
/* The configuration flags for the messages are encapsulated inside the
* message- and transport settings extension objects. These extension
* objects are defined by the standard. e.g.
* UadpWriterGroupMessageDataType */
UA_UadpWriterGroupMessageDataType *writerGroupMessage = UA_UadpWriterGroupMessageDataType_new();
/* Change message settings of writerGroup to send PublisherId,* WriterGroupId in GroupHeader and DataSetWriterId in PayloadHeader
* of NetworkMessage */
writerGroupMessage->networkMessageContentMask = (UA_UadpnetworkMessageContentMask)(UA_UAdpnETWORKMESSAGECONTENTMASK_PUBLISHERID |
(UA_UadpnetworkMessageContentMask)UA_UAdpnETWORKMESSAGECONTENTMASK_GROUPHEADER |
(UA_UadpnetworkMessageContentMask)UA_UAdpnETWORKMESSAGECONTENTMASK_WRITERGROUPID |
(UA_UadpnetworkMessageContentMask)UA_UAdpnETWORKMESSAGECONTENTMASK_PAYLOADHEADER);
writerGroupConfig.messageSettings.content.decoded.data = writerGroupMessage;
UA_StatusCode retval1 = UA_Server_addWriterGroup(server,connectionIdent,&writerGroupConfig,&writerGroupIdent);
if (retval1 == UA_STATUSCODE_GOOD )
{
UA_LOG_INFO(UA_Log_Stdout,"4-->The PubSub Connection UA_Server_addWriterGroup successfully!");
}
UA_StatusCode retval2 = UA_Server_setWriterGroupOperational(server,writerGroupIdent);
if (retval2 == UA_STATUSCODE_GOOD )
{
UA_LOG_INFO(UA_Log_Stdout,"4.1-->The PubSub UA_Server_setWriterGroupOperational executed successfully!");
}
UA_UadpWriterGroupMessageDataType_delete(writerGroupMessage);
printf("Done addWriterGroup here...\r\n");
}
static void
addDataSetWriter(UA_Server *server) {
/* We need Now a DataSetWriter within the WriterGroup. This means we must
* create a new DataSetWriterConfig and add call the addWriterGroup function. */
UA_NodeId dataSetWriterIdent;
UA_DataSetWriterConfig dataSetWriterConfig;
memset(&dataSetWriterConfig,sizeof(UA_DataSetWriterConfig));
dataSetWriterConfig.name = UA_STRING("Demo DataSetWriter");
dataSetWriterConfig.dataSetWriterId = 62541;
dataSetWriterConfig.keyFrameCount = 10;
UA_StatusCode retval = UA_Server_addDataSetWriter(server,&dataSetWriterConfig,&dataSetWriterIdent);
if (retval == UA_STATUSCODE_GOOD)
{
UA_LOG_INFO(UA_Log_Stdout,"5-->The PubSub addDataSetWriter executed successfully!");
}
printf("Done addDataSetWriter here...\r\n");
}
static int opcua_call (UA_String *transportProfile,UA_NetworkAddressUrlDataType *networkAddressUrl)
{
UA_Boolean running = true;
/* Create the Server */
UA_Server *server = UA_Server_new();
if (server != 0)
printf("Server Created Successfully...\r\n");
else
printf("Failed to create Server...\r\n");
UA_ServerConfig *config = UA_Server_getConfig(server);
UA_ServerConfig_setDefault(config);
/* Server is created Now */
/* Add the PubSubTransportLayer implementation to the server config.
* The PubSubTransportLayer is a factory to create new connections
* on runtime. The UA_PubSubTransportLayer is used for all kinds of
* concrete connections e.g. UDP,MQTT,AMQP...
*/
UA_String hostname;
hostname = UA_STRING("opc.udp://224.0.0.21");
UA_ServerConfig_setCustomHostname(UA_Server_getConfig(server),hostname);
wiced_hostname_t whn;
wiced_result_t wres;
memset(&whn,sizeof(whn));
wiced_network_set_hostname("myServer");
wres = wiced_network_get_hostname( &whn );
printf ("wiced_network_get_hostname returned %d\n",wres);
printf ("wiced_network_get_hostname: %s\n",whn.value );
/* Change the host name */
// UA_String hostname;
// UA_String_init(&hostname);
// hostname.length = 8;
// hostname.data = "myServer";// "opc.udp://224.0.0.23:4841/"; //224.0.0.22:4840
// printf ("Hostname is set with %s...\r\n",hostname.data);
// UA_ServerConfig_setCustomHostname(UA_Server_getConfig(server),hostname);
config->pubsubTransportLayers = (UA_PubSubTransportLayer *) UA_calloc(
2,sizeof(UA_PubSubTransportLayer));
config->pubsubTransportLayers[0] = UA_PubSubTransportLayerUDPMP();
config->pubsubTransportLayeRSSize++;
UA_PubSubConnectionConfig connectionConfig;
memset(&connectionConfig,sizeof(connectionConfig));
connectionConfig.name = UA_STRING("UDP-UADP Connection 1");
connectionConfig.transportProfileUri = UA_STRING("http://opcfoundation.org/UA-Profile/Transport/pubsub-udp-uadp");
connectionConfig.enabled = UA_TRUE;
addPubSubConnection(server,transportProfile,networkAddressUrl);
addPublishedDataSet(server);
addDataSetField(server);
addWriterGroup(server);
addDataSetWriter(server);
UA_Server_run_startup(server);
if (!config->pubsubTransportLayers) {
UA_Server_delete(server);
return -1;
printf("Error ! \r\n");
} else
printf("Success Adding the Transport Layer... \r\n");
// UA_StatusCode retval = UA_Server_run(server,&running);
UA_Server_delete(server);
}
int opcua_pub_thread (void *arg)
{
/* Configure the transport profile and Network Address*/
UA_String transportProfile =
UA_STRING("http://opcfoundation.org/UA-Profile/Transport/pubsub-udp-uadp");
UA_NetworkAddressUrlDataType networkAddressUrl =
{UA_STRING_NULL,UA_STRING("opc.udp://224.0.0.22:4840/")};
networkAddressUrl.networkInterface = UA_STRING("udp");
networkAddressUrl.url = UA_STRING("opc.udp://224.0.0.22");
/* Start the pubsub procedure*/
return opcua_call(&transportProfile,&networkAddressUrl);
}
void opcua_pub_init(void)
{
printf("OPcua Thread Created...\r\n");
/* Create the opcua sttarting point thread */
sys_thread_new("OPcua Start",opcua_pub_thread,NULL,20000,WICED_DEFAULT_LIBRARY_PRIORITY);
}
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）