Windows服务启动后仅能读取首条MSMQ消息的故障解决求助

问题分析 #

从你描述的情况和给出的代码片段来看，核心问题很明确：你只在服务启动的OnStart方法里执行了一次消息读取操作。读完第一条消息后，这段代码就执行完毕了，没有任何逻辑去持续监听队列里的新消息——所以后续进来的消息自然没人处理，而重启服务后OnStart会重新执行，又能读到当时队列的第一条消息。

解决方案 #

要让服务持续监听并处理MSMQ消息，你需要改用MSMQ的异步事件监听机制，而不是单次读取。下面是完整的修正思路和代码示例：

1. 调整代码结构，用异步事件实现持续监听

// 把MessageQueue声明为服务类的成员变量，避免被GC回收
private MessageQueue _msMq;

protected override void OnStart(string[] args)
{
    // 初始化你的MSMQ队列（替换成实际的队列路径）
    _msMq = new MessageQueue(@".\Private$\YourQueueName");
    
    // 关键：设置消息格式化器，要和你发送JobModel时的格式匹配
    _msMq.Formatter = new XmlMessageFormatter(new Type[] { typeof(JobModel) });
    
    // 注册消息接收完成的事件
    _msMq.ReceiveCompleted += Msmq_MessageReceived;
    
    // 启动异步监听
    _msMq.BeginReceive();
}

// 消息处理的核心方法
private void Msmq_MessageReceived(object sender, ReceiveCompletedEventArgs e)
{
    try
    {
        // 结束异步接收，获取消息
        var message = _msMq.EndReceive(e.AsyncResult);
        var job = (JobModel)message.Body;
        
        // 这里写你处理JobModel的业务逻辑
        // 比如：ProcessJob(job);
        
        // 处理完当前消息后，一定要再次启动监听，否则后续消息不会被处理
        _msMq.BeginReceive();
    }
    catch (Exception ex)
    {
        // 务必捕获异常，避免单个消息处理失败导致整个监听终止
        // 这里可以添加日志记录，比如：LogError("处理MSMQ消息失败", ex);
        
        // 即使出错，也要重新启动监听
        _msMq.BeginReceive();
    }
}

protected override void OnStop()
{
    // 服务停止时，清理资源
    if (_msMq != null)
    {
        // 取消事件注册
        _msMq.ReceiveCompleted -= Msmq_MessageReceived;
        // 关闭并释放队列
        _msMq.Close();
        _msMq.Dispose();
    }
}

2. 几个必须注意的细节

• 成员变量声明：绝对不能把MessageQueue放在OnStart里当局部变量，否则方法执行完后会被垃圾回收，后续的事件触发会失效。
• 消息格式匹配：如果发送消息时用的是其他格式化器（比如BinaryMessageFormatter），一定要对应调整，不然会解析失败抛出异常。
• 异常处理：如果不捕获异常，一旦某条消息处理出错，整个监听流程就会中断，服务虽然运行但再也不会处理新消息。
• 权限检查：确保Windows服务的运行账号拥有MSMQ队列的读取权限，虽然你能读第一条，但权限不足可能导致后续读取静默失败（这个可以排查下）。

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