WinForms应用集成Azure Service Bus无法接收/展示消息问题

你的代码存在4个致命问题，直接导致消息无法接收、UI无法展示：

• 处理器启动后立刻被销毁：StartProcessingAsync()是启动后台监听的非阻塞方法，调用后会立刻返回，不会阻塞等待消息接收。你在MainAsync里写的finally块会在StartProcessingAsync返回后立刻执行，直接Dispose掉processor和client，监听器刚启动就被释放，根本没有机会接收消息。
• 消息读取时机完全错误：你只在await Program.MainAsync()返回的瞬间读取一次静态List里的数据，后续就算有消息到达，也不会触发UI更新逻辑。
• 跨线程访问风险：ServiceBus的消息处理回调运行在后台线程，直接操作WinForms UI控件会抛出跨线程访问异常，你当前的写法没有做任何线程调度。
• 共享数据非线程安全：用普通List<string>在UI线程和后台处理线程间共享数据，多线程并发读写会出现数据丢失、集合损坏的问题，且你没有实现ErrorHandler，异常会被静默吞没，完全看不到报错。

调整Program.cs逻辑 #

把资源生命周期和窗体绑定，不要在启动处理器后立刻释放资源，增加线程安全处理和消息通知事件：

using Azure.Messaging.ServiceBus;
using System.Collections.Concurrent;
using System.Diagnostics;

namespace App
{
    public class Program
    {
        public static ServiceBusClient client;
        public static ServiceBusProcessor processor;
        // 用线程安全集合存储消息，避免多线程读写冲突
        public static ConcurrentQueue<string> MessageQueue = new ConcurrentQueue<string>();
        // 定义消息到达事件，通知UI更新
        public static event Action<string> MessageReceived;

        [STAThread]
        static void Main()
        {
            ApplicationConfiguration.Initialize();
            Application.Run(new Form1());
        }

        public static async Task InitServiceBus()
        {
            // 替换为你实际的连接串、Topic、订阅名称
            const string _serviceBusConn = "你的ServiceBus连接字符串";
            const string _serviceBustopic = "你的Topic名称";
            const string _ServiceBusSubscription = "你的订阅名称";

            client = new ServiceBusClient(_serviceBusConn);
            processor = client.CreateProcessor(_serviceBustopic, _ServiceBusSubscription, new ServiceBusProcessorOptions
            {
                AutoCompleteMessages = false,
                MaxConcurrentCalls = 1
            });

            // 注册处理委托
            processor.ProcessMessageAsync += MessageHandler;
            processor.ProcessErrorAsync += ErrorHandler;
            
            // 启动监听，不要在此处写释放逻辑
            await processor.StartProcessingAsync();
        }

        static async Task MessageHandler(ProcessMessageEventArgs args)
        {
            try
            {
                string body = args.Message.Body.ToString();
                MessageQueue.Enqueue(body);
                // 触发事件通知UI有新消息
                MessageReceived?.Invoke(body);
                await args.CompleteMessageAsync(args.Message);
            }
            catch (Exception ex)
            {
                await args.AbandonMessageAsync(args.Message);
            }
        }

        static Task ErrorHandler(ProcessErrorEventArgs args)
        {
            Debug.WriteLine($"ServiceBus处理异常: {args.Exception}");
            return Task.CompletedTask;
        }

        // 提供统一释放方法，窗体关闭时调用
        public static async Task DisposeServiceBus()
        {
            if (processor != null)
            {
                await processor.StopProcessingAsync();
                await processor.DisposeAsync();
            }
            if (client != null)
            {
                await client.DisposeAsync();
            }
        }
    }
}

调整Form1.cs逻辑 #

注册消息事件，通过UI线程更新控件，绑定窗体关闭事件释放资源：

namespace App
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
            // 注册消息接收事件
            Program.MessageReceived += Program_MessageReceived;
            this.FormClosing += Form1_FormClosing;
        }

        private async void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            // 窗体关闭时释放ServiceBus资源
            await Program.DisposeServiceBus();
            Program.MessageReceived -= Program_MessageReceived;
        }

        // 新消息到达时，切回UI线程更新列表框
        private void Program_MessageReceived(string msg)
        {
            if (listBox1.InvokeRequired)
            {
                listBox1.Invoke(new Action(() => 
                {
                    listBox1.Items.Add($"item{msg}");
                }));
            }
            else
            {
                listBox1.Items.Add($"item{msg}");
            }
        }

        private async void button1_Click(object sender, EventArgs e)
        {
            button1.Enabled = false;
            try
            {
                await Program.InitServiceBus();
                listBox1.Items.Add("消息监听已启动，等待接收消息...");
            }
            catch (Exception ex)
            {
                MessageBox.Show($"启动监听失败: {ex.Message}");
            }
            finally
            {
                button1.Enabled = true;
            }
        }
    }
}

• ServiceBusProcessor的生命周期应该和应用生命周期一致，不要在启动监听后立刻释放资源
• WinForms控件永远只能在创建它的UI线程访问，后台线程更新UI必须调用Invoke/BeginInvoke调度
• 多线程共享数据场景不要用普通List<T>，必须使用ConcurrentQueue<T>等线程安全集合
• 必须实现ProcessErrorAsync对应的错误处理，否则后台异常会被静默吞没，排查难度极高

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