UDP Socket连接器超时排查：Node.js正常MuleSoft超时

问题背景 #

尝试通过UDP Socket向本地SQL Server Browser服务（端口1434）发送数据报，Node.js客户端可正常获取响应，但MuleSoft应用使用Socket连接器时始终超时，提示“UDP connection timed out”。已添加Socket扩展的调试日志，但未获取到有效排查信息。

正常运行的Node.js代码 #

const dgram = require('node:dgram');
const process = require('node:process');
const buffer = require('node:buffer');
 
var soc = dgram.createSocket('udp4');
 
soc.on('error', (err) => {
    console.error(`socket error:\n${err.stack}`);
});
 
soc.on('message', (msg) => {
    console.log(`message received: ${msg}`);
});
 
soc.connect(1434, () => {
    console.log(`socket connected`);
    const queryInstanceCode = 3;
    const buff = buffer.Buffer.alloc(1);
    buff[0] = queryInstanceCode;
    soc.send(buff);
});

Mule应用Socket连接器配置 #

<?xml version="1.0" encoding="UTF-8"?>
 
<mule xmlns:scripting="http://www.mulesoft.org/schema/mule/scripting" xmlns:sockets="http://www.mulesoft.org/schema/mule/sockets"
    xmlns:http="http://www.mulesoft.org/schema/mule/http"
    xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/sockets http://www.mulesoft.org/schema/mule/sockets/current/mule-sockets.xsd
http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/current/mule-scripting.xsd">
    <http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="aaeb8ad9-c25d-4076-90b4-5fbf0584fefa" >
        <http:listener-connection host="0.0.0.0" port="8081" />
    </http:listener-config>
    <sockets:request-config name="SQLServiceBrowserSocket" doc:name="Sockets Request config" doc:id="ccebf069-3ea5-403b-8f38-14a1b181c93f" >
        <sockets:udp-requester-connection host="127.0.0.1" port="1434" clientTimeout="5000"/>
    </sockets:request-config>
    <flow name="named.instance.finderFlow" doc:id="f0259fdc-c7ce-43ba-a124-07df0bee9ec4" >
        <http:listener doc:name="Listener" doc:id="3ece9740-15b6-4681-b5e3-20ff66fa46c7" config-ref="HTTP_Listener_config" path="/mssqlhost/{host}/instance/{instance}/port" allowedMethods="GET" responseStreamingMode="NEVER">
        </http:listener>
        <logger level="INFO" doc:name="Log Request" doc:id="3bd2076d-23f6-4388-a3d8-0da2816d00dc" message="#attributes"/>
        <sockets:send-and-receive doc:name="Query SQL Server Browser" doc:id="14f15af2-ee9a-41f9-9890-a021fd066d35" config-ref="SQLServiceBrowserSocket" target="instancePort" outputMimeType="application/octet-stream" outputEncoding="US-ASCII">
            <non-repeatable-stream />
            <sockets:content><![CDATA[3]]></sockets:content>
        </sockets:send-and-receive>
        <logger level="INFO" doc:name="Logger" doc:id="6ca780c0-21c7-409c-9c64-17cb0a0fc543" message="#payload"/>
    </flow>
</mule>

排查步骤与解决方案 #

1. 修正发送的字节内容（核心问题） #

Node.js发送的是单个字节值为0x03的Buffer，但Mule配置中sockets:content里的字符串"3"会被编码为ASCII字节0x33（字符'3'的ASCII码），与服务期望的字节不匹配。

• 修正方法：使用Groovy脚本生成正确的字节数组，替换原sockets:content内容：

  <sockets:content>#[groovy: return [3] as byte[]]</sockets:content>
  

2. 增强日志输出 #

在log4j2.xml中添加以下日志配置，捕获更底层的网络交互细节：

<AsyncLogger name="org.mule.extension.socket" level="DEBUG"/>
<AsyncLogger name="org.mule.transport.socket" level="DEBUG"/>
<AsyncLogger name="java.net" level="DEBUG"/>
<AsyncLogger name="sun.net" level="DEBUG"/>

这些日志会输出UDP数据包的发送、接收状态，以及字节内容、端口绑定信息。

3. 抓包验证网络流量 #

使用Wireshark或tcpdump抓取本地UDP端口1434的流量：

• 确认Mule是否发送了UDP数据包
• 检查发送的字节是否为0x03，而非0x33
• 验证服务是否返回响应，以及Mule是否接收到响应包

4. 匹配UDP连接模式 #

Node.js使用connect()建立了关联UDP（Connected UDP），而Mule默认可能使用无关联UDP。尝试在UDP连接配置中显式开启关联：

<sockets:udp-requester-connection host="127.0.0.1" port="1434" clientTimeout="5000" connected="true"/>

5. 调整超时时间 #

临时将clientTimeout调整为10000（10秒），排除因响应延迟导致的超时：

<sockets:udp-requester-connection host="127.0.0.1" port="1434" clientTimeout="10000"/>

内容的提问来源于stack exchange，提问作者Guillaume Cretot-Richert