linux 无法在open62541中向订阅者发送已发布的消息

pftdvrlh  于 2023-03-22  发布在  Linux
关注(0)|答案(1)|浏览(268)

我试图构建学习open 62541,我使用的示例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, 0, 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
    * informations for the creation of a new PublishedDataSet */
    UA_PublishedDataSetConfig publishedDataSetConfig;
    memset(&publishedDataSetConfig, 0, 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, UA_LOGCATEGORY_SERVER,
                                          "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, 0, 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, publishedDataSetIdent,
                              &dataSetFieldConfig, &dataSetFieldIdent);
    if (result.result == UA_STATUSCODE_GOOD)
    {
        UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_SERVER,
                                       "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, 0, 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, UA_LOGCATEGORY_SERVER,
                                               "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, UA_LOGCATEGORY_SERVER,
                                                   "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, 0, sizeof(UA_DataSetWriterConfig));
    dataSetWriterConfig.name = UA_STRING("Demo DataSetWriter");
    dataSetWriterConfig.dataSetWriterId = 62541;
    dataSetWriterConfig.keyFrameCount = 10;
    UA_StatusCode retval =  UA_Server_addDataSetWriter(server, writerGroupIdent, publishedDataSetIdent,
                               &dataSetWriterConfig, &dataSetWriterIdent);
    if (retval == UA_STATUSCODE_GOOD)
    {
        UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_SERVER,
                      "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, 0, 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, 0, 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);

}
bgtovc5b

bgtovc5b1#

这可能是防火墙问题?您是否在公司工作?请尝试将其关闭。如果这不能解决问题,请尝试将广播地址从www.example.com更改为224.0.0.22239.255.0.1我在TCL遇到了这个问题,不知何故更改广播地址有所帮助。即使如此,也不应该有关系。也许有人对此有解释。

相关问题