Node-OPCUA-建置心得(ES6)

import opcua, { StatusCodes } from "node-opcua"

// Server初始化設定
const server = new opcua.OPCUAServer({
    port: 48040, // 端口
    resourcePath: "/UA/MyLittleServer", // opc ua url, etc. opc.tcp://DESKTOP-XXXXX:48040/UA/MyLittleServer
     buildInfo : {
        productName: "MySampleServer1",
        buildNumber: "7658",
        buildDate: new Date(2014,5,2)
    }
});

function post_initialize() {
    // initialized
    function construct_my_address_space(server) {
    
        // namespace引用
        const addressSpace = server.engine.addressSpace;
        const namespace = addressSpace.getOwnNamespace();
    
        // 1. declare a new object 建立一個塞Tag的群組
        const device = namespace.addObject({
            organizedBy: addressSpace.rootFolder.objects,
            browseName: "MyDevice"
        });

        let variable1 = 1;
        
        // 2. emulate variable1 changing every 500 ms 弄一個計時器，每秒更新variable1
        setInterval(function(){  variable1+=1; }, 1000);
        
        // 3. 新增node Tags(node節點)的定義
        namespace.addVariable({
            componentOf: device,        // 選擇Tags的Group
            browseName: "MyVariable1",  // Tags的名稱
            dataType: "Double",         // Tags的資料型態(Tags Types)
            value: {                    // 塞數值
                get: function () {      // 可讀(Let Node Can Read)
                    return new opcua.Variant({dataType: opcua.DataType.Double, value: variable1 });
                },
                set: (variant) => {     // 可寫(Let Node Can Write)
                    variable1 = variant.value
                    return StatusCodes.Good
                }
            
            }
        });
        
    }
    // 生成Tages定義
    construct_my_address_space(server);

    // Server Start
    server.start(function() {
        console.log("Server is now listening ... ( press CTRL+C to stop)");
        console.log("port ", server.endpoints[0].port);
        const endpointUrl = server.endpoints[0].endpointDescriptions()[0].endpointUrl;
        console.log(" the primary server endpoint url is ", endpointUrl );
    });
}
server.initialize(post_initialize);

// namespace的定義
namespace.addVariable({
            componentOf: device,        // 選擇Tags的Group
            browseName: "MyVariable1",  // Tags的名稱
            dataType: "Double",         // Tags的資料型態(Tags Types)
            value: {                    // 塞數值
                get: function () {      // 可讀(Let Node Can Read)
                    return new opcua.Variant({dataType: opcua.DataType.Double, value: variable1 });
                },
                set: (variant) => {     // 可寫(Let Node Can Write)
                    variable1 = variant.value
                    return StatusCodes.Good
                }
            
            }
        });

import opcua from "node-opcua"

// OPC UA Client定義 Connection URL
const connectionStrategy = {
    initialDelay: 1000,
    maxRetry: 1 // 若設為0-> 初始Client啟動時，Server未啟動，則會斷線(程式報錯) | 非0則等待，直到Server On
    /*
        maxRetry: number
        initialDelay: number
        maxDelay: number
        randomisationFactor: number

        maxRetry: the number of retries before the reconnection process will give up and return a connection error:
        initialDelay: the delay in miliseconds before the first reconnexion occur. This delay will increase linearly if reconnexion is still failing ( until it reaches maxDelay)
        maxDelay: the maximum delay between two attempts to reconnect
   */
}
const options = {
        applicationName: 'GateWay',
        connectionStrategy,
        securityMode: opcua.MessageSecurityMode.None,   // 有簽證，要改Sign(2)/SignAndEncrypt(3)
        securityPolicy: opcua.SecurityPolicy.None,      // 密碼的Type, etc. Basic256Sha256、Basic128Rsa15
        endpointMustExist: false
}
const endpointUrl = 'opc.tcp://192.168.1.50:48040'      // OPC UA Server IP and port
const opcclient = opcua.OPCUAClient.create(options)
await opcclient.connect(endpointUrl)                    // Client連線
const session = await opcclient.createSession()         // 創建Client Session

// 引用Session, 創建Pub/Sub訂閱
const subscription = opcua.ClientSubscription.create(session, {
    requestedPublishingInterval: 500, // 每秒讀一次
    requestedLifetimeCount: 100,
    requestedMaxKeepAliveCount: 10,
    maxNotificationsPerPublish: 9000,
    publishingEnabled: true,
    priority: 10
})

// Subscription監控的node參數
const parameters = {
    samplingInterval: 500, // 取樣間隔, 若為500ms, 有N次變化，則取最後一次變化，要注意!
    discardOldest: true,
    queueSize: 10
}

//------------------------------------Sub by Group----------------------------
// 定義欲讀取的Node Tage(Node節點)
// 主要用於一次性監控N的節點，避免程式過程與重複宣告
const MyVariable1_Gruop = [
    {
        attributeId: opcua.AttributeIds.Value,
        nodeId: 'ns=1;i=1001'
    },
    {
        attributeId: opcua.AttributeIds.Value,
        nodeId: 'ns=1;i=1001'
    }
]
const Gruop_Abbr = opcua.ClientMonitoredItemGroup.create(subscription, MyVariable1_Gruop, parameters, opcua.TimestampsToReturn.Both)
Gruop_Abbr.on('changed', function (monitoredItem, dataValue, index) { // 節點定義, 節點變數, Group內的第幾個節點變化
    console.log(dataValue.value.value,index)
})

//------------------------------------Sub by Item----------------------------
const MyVariable1_Item = {
    attributeId: opcua.AttributeIds.Value,
    nodeId: 'ns=1;i=1001'
}
const Item_Abbr = opcua.ClientMonitoredItem.create(subscription, MyVariable1_Item, parameters, opcua.TimestampsToReturn.Both)
Item_Abbr.on('changed', function (dataValue) { // 節點變數
    console.log(dataValue.value.value)
})

//------------------------------------Node Read----------------------------
const readValue = await session.read({ nodeId: 'ns=1;i=1001', attributeId: opcua.AttributeIds.Value })
const readValue1 = await session.read({ nodeId: 'ns=1;i=1001'})
console.log(readValue.value.value, readValue1.value.value)

//------------------------------------Node Write----------------------------
const nodeToWrite = {
    nodeId: 'ns=1;i=1001',
    attributeId: opcua.AttributeIds.Value,
    value: /* DataValue */{
        value: /* Variant */{
            dataType: opcua.DataType.Double,
            value: 1098
        }
    },
}
const writeValue = await session.write(nodeToWrite)
console.log(writeValue)
const writeAnser = await session.read({ nodeId: 'ns=1;i=1001'})
console.log(writeAnser.value.value)