如何获取Promise返回值并提取最低优先级MX记录用于网络请求

看起来你卡在了异步结果处理和连接参数传递这两个点上，咱们一步步拆解解决：

1. 核心问题分析 #

你的代码有两个关键问题：

• Promise异步处理不当：getMxRecords返回的是Promise对象，直接赋值let a = getMxRecords(res)拿到的只是Promise实例，不是最终的MX记录值
• SMTP连接参数错误：你调用net.createConnection时传了request(email)（这个逻辑显然不对），导致连接到了本地127.0.0.1，触发了ECONNREFUSED错误

2. 修正后的完整代码 #

先给你能直接用的版本，后面再解释细节：

const dns = require('dns');
const net = require('net');

// 提取邮箱域名
const email = '...@gmail.com';
const domain = email.split('@').pop();

/**
 * 获取优先级最低（数值最大）的MX服务器域名
 * @param {string} domain - 邮箱域名
 * @returns {Promise<string|null>} MX服务器域名，失败则返回null
 */
function getLowestPriorityMx(domain) {
  return new Promise((resolve, reject) => {
    dns.resolveMx(domain, (err, addresses) => {
      if (err) {
        console.error('获取MX记录失败:', err);
        reject(err); // 用reject传递错误，方便上层捕获
        return;
      }
      if (!addresses || addresses.length === 0) {
        resolve(null);
        return;
      }
      // 找到优先级数值最大的记录（即最低优先级）
      const lowestPriorityRecord = addresses.reduce((prev, curr) => {
        return curr.priority > prev.priority ? curr : prev;
      });
      // 返回MX服务器的域名（exchange字段是我们需要的连接地址）
      resolve(lowestPriorityRecord.exchange);
    });
  });
}

// 异步初始化SMTP连接（推荐用async/await，代码更清晰）
async function initSmtpConnection() {
  try {
    const mxServer = await getLowestPriorityMx(domain);
    if (!mxServer) {
      console.error('未找到有效的MX记录');
      return;
    }
    // 用正确的MX服务器域名连接25端口
    const socket = net.createConnection(25, mxServer, () => {
      console.log('成功连接到SMTP服务器');
      // 这里可以开始发送SMTP命令，比如 EHLO your-domain.com
    });

    // 监听连接错误
    socket.on('error', (err) => {
      console.error('SMTP连接失败:', err);
    });
  } catch (err) {
    console.error('初始化流程出错:', err);
  }
}

// 启动流程
initSmtpConnection();

// 模块导出，供外部调用
module.exports = getLowestPriorityMx;

3. 关键细节解释 #

异步结果处理 #

• 因为dns.resolveMx是异步操作，所以我们用Promise封装，外部必须通过await或者.then()来获取结果，不能直接赋值使用
• 示例中用了async/await语法，比.then()链式调用更易读

MX记录字段说明 #

dns.resolveMx返回的数组中，每个元素是包含两个字段的对象：

• priority：优先级数值（越小越优先，你要的是数值最大的，也就是最低优先级）
• exchange：MX服务器的域名（这才是我们需要用来连接SMTP的地址）

连接错误修复 #

你之前的net.createConnection(25, request(email), ...)是错误的，现在替换成mxServer（从MX记录里拿到的真实服务器域名），就不会再连接本地127.0.0.1了。

另外注意：很多公共邮箱（比如Gmail）的MX服务器会拒绝普通IP的连接，或者要求使用加密端口（465/587），如果25端口连接失败，可以尝试切换端口。

4. 外部调用示例（导出模块后） #

如果其他文件要使用这个函数，可以这样写：

const getLowestPriorityMx = require('./your-module-path');
const net = require('net');

async function sendEmailRequest(targetEmail) {
  const domain = targetEmail.split('@').pop();
  try {
    const mxServer = await getLowestPriorityMx(domain);
    if (!mxServer) throw new Error('无可用MX记录');
    
    const socket = net.createConnection(25, mxServer, () => {
      // 连接成功后的逻辑，比如发送SMTP命令
      socket.write(`EHLO example.com\r\n`);
    });

    socket.on('data', (data) => {
      console.log('SMTP响应:', data.toString());
    });
  } catch (err) {
    console.error('邮件请求失败:', err);
  }
}

sendEmailRequest('test@gmail.com');

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