在Ubuntu多IP环境下，Node-RED发送UDP数据包如何指定源IP？

问题根源 #

默认的Node-RED UDP Out节点不支持指定发送数据包的源IP地址，需要通过自定义函数调用Node.js原生的dgram模块实现绑定特定源IP的UDP发送。你遇到的TypeError: Cannot read properties of undefined (reading 'createSocket')错误，本质是函数节点中没有正确引入dgram模块导致的。

具体实现步骤 #

1. 正确引入dgram模块 #

Node-RED的函数节点可直接调用Node.js核心模块，在函数开头添加以下代码即可引入：

const dgram = require('dgram');

2. 绑定指定源IP的UDP发送代码 #

以下是完整的函数节点代码示例，以从192.168.25.43发送UDP数据包为例：

const dgram = require('dgram');
const socket = dgram.createSocket('udp4');

// 根据实际需求修改参数
const sourceIp = '192.168.25.43'; // 必须是enp0s8网卡已配置的静态IP
const sourcePort = 12345; // 自定义未被占用的源端口
const targetIp = 'xxx.xxx.xxx.xxx'; // 接收方IP地址
const targetPort = 54321; // 接收方端口号

// 绑定源IP与端口
socket.bind(sourcePort, sourceIp, () => {
    // 将消息转为UDP要求的Buffer格式
    const message = Buffer.from(msg.payload);
    // 发送数据包
    socket.send(message, 0, message.length, targetPort, targetIp, (err) => {
        if (err) {
            node.error('UDP发送失败: ' + err.message);
        } else {
            node.log(`从${sourceIp}:${sourcePort}发送数据到${targetIp}:${targetPort}`);
        }
        // 发送完成后关闭socket，避免资源占用
        socket.close();
    });
});

// 处理socket异常
socket.on('error', (err) => {
    node.error('Socket异常: ' + err.message);
    socket.close();
});

3. 关键注意事项 #

• 必须确保sourceIp是enp0s8网卡上已配置的静态IP，否则绑定会失败。
• 若需持续发送心跳包，建议将socket实例存入Node-RED上下文复用，避免频繁创建销毁socket。
• 源端口需选择未被占用的端口，可通过netstat -tulpn命令查看端口占用情况。

4. 心跳响应的扩展实现 #

若需要监听UDP心跳并从指定源IP回复，可使用以下代码（复用socket实例避免重复创建）：

const dgram = require('dgram');
// 从上下文获取已创建的socket，无则新建
let serverSocket = context.get('heartbeatSocket');
if (!serverSocket) {
    serverSocket = dgram.createSocket('udp4');
    const listenIp = '192.168.25.43';
    const listenPort = 12345;

    serverSocket.bind(listenPort, listenIp, () => {
        node.log(`在${listenIp}:${listenPort}监听UDP心跳`);
    });

    serverSocket.on('message', (msg, rinfo) => {
        node.log(`收到来自${rinfo.address}:${rinfo.port}的心跳: ${msg.toString()}`);
        // 构造回复消息
        const replyMsg = Buffer.from('心跳已收到');
        // 从绑定的源IP回复
        serverSocket.send(replyMsg, 0, replyMsg.length, rinfo.port, rinfo.address, (err) => {
            if (err) node.error('心跳回复失败: ' + err.message);
        });
    });

    // 将socket存入上下文复用
    context.set('heartbeatSocket', serverSocket);
}

错误排查 #

你遇到的Cannot read properties of undefined (reading 'createSocket')错误，只需检查函数开头的const dgram = require('dgram');语句是否拼写正确，且后续代码未覆盖dgram变量即可解决。

内容的提问来源于stack exchange，提问作者petterssonm