使用Apache.NMS在WinForms中调用CreateSession无响应问题求助

问题描述 #

我用Apache.NMS.ActiveMQ和Apache.NMS.AMQP在C#控制台应用中能正常连接ActiveMQ Artemis队列生产消息，但移植到C# Windows Forms应用后，调用CreateSession方法一直无响应。代理采用SSL加密，控制台中用ssl://mybroker:443（ActiveMQ客户端）和amqps://mybroker:443（AMQP客户端）都正常，WinForms中异常。

代码示例：

IConnectionFactory factory = new ConnectionFactory(brokerUri);
using (IConnection connection = factory.CreateConnection(username, password))
{
    using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
    {
        IDestination destination = session.GetQueue(queueName);
        IMessageProducer producer = session.CreateProducer(destination);
        IMessage textMessage = session.CreateTextMessage(text);
        producer.Send(textMessage);
    }
}

可能的原因及解决方法 #

• UI线程阻塞导致无响应
  WinForms采用单线程UI模型，同步执行网络操作（比如CreateSession）会直接阻塞UI线程，看起来就像程序卡住了，而控制台没有这个限制所以能正常运行。
  解决：把消息生产逻辑放到异步方法里，用async/await调用，避免阻塞UI线程。修改后的代码参考：

  private async Task SendMessageAsync(string brokerUri, string username, string password, string queueName, string text)
  {
      IConnectionFactory factory = new ConnectionFactory(brokerUri);
      using (IConnection connection = factory.CreateConnection(username, password))
      {
          await Task.Run(() =>
          {
              connection.Start(); // WinForms中需显式启动连接，控制台可能隐式处理
              using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
              {
                  IDestination destination = session.GetQueue(queueName);
                  IMessageProducer producer = session.CreateProducer(destination);
                  IMessage textMessage = session.CreateTextMessage(text);
                  producer.Send(textMessage);
              }
          });
      }
  }
  
  // 在按钮点击等UI事件中调用
  private async void btnSend_Click(object sender, EventArgs e)
  {
      await SendMessageAsync("ssl://mybroker:443", "你的用户名", "你的密码", "目标队列名", "测试消息");
      MessageBox.Show("消息发送完成");
  }
  

• SSL证书验证差异
  WinForms应用的证书信任策略和控制台可能不同，导致SSL握手过程卡住。可以临时禁用证书验证（仅测试环境使用，生产环境必须配置合法证书）：
  对于Apache.NMS.ActiveMQ客户端：

  ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(brokerUri);
  factory.SslProtocol = System.Security.Authentication.SslProtocols.Tls12;
  factory.ServerCertificateValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
  

  对于Apache.NMS.AMQP客户端：

  AmqpConnectionFactory factory = new AmqpConnectionFactory(new Uri(brokerUri));
  factory.SslOptions.RemoteCertificateValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
  

• 连接未显式启动
  控制台中CreateConnection后可能自动启动连接，但WinForms环境下需要显式调用connection.Start()，否则创建会话时会一直等待连接启动，导致无响应。记得在调用CreateSession前执行connection.Start()。

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