后台工作线程问题

Question

我在我的应用程序中使用后台工作程序

我的代码

 void CreateThreadForEachServer()
 {
    DataAccess oDA = new DataAccess();

    List<Server> allServerData = oDA.GetAllServers();

    foreach (Server serverData in allServerData)
    {
        backgroundWorker = new BackgroundWorker();

        backgroundWorker.DoWork += new DoWorkEventHandler(backgroundWorker_DoWork);

        backgroundWorker.RunWorkerAsync(serverData);

    }
}

void backgroundWorker_DoWork(object sender, DoWorkEventArgs e)
{
    Server server = (Server)e.Argument;
    CreateSnapshotForEachServer(server);
}

void CreateSnapshotForEachServer(Server server)
{
    DataAccess oDA = new DataAccess();
    MsmqMessageFormat message = new MsmqMessageFormat();

    try
    {
        message = new Queue().ReadMessageFromMSMQ(server.ServerName);
    }
    catch
    {
    }
 }

我的问题是当我

 try
 {
     message = new Queue().ReadMessageFromMSMQ(server.ServerName);
 }
 catch
 {
 }

在后台工作程序中调用此方法时我无法调用此方法只是从 MSMQ 读取消息

但是当我无法使用后台工作程序时在像这样的简单线程中调用这个方法

void CreateThreadForEachServer()
{
    DataAccess oDA = new DataAccess();

    List<Server> allServerData = oDA.GetAllServers();

    foreach (Server serverData in allServerData)
    {
        ThreadStart t = delegate { CreateSnapshotForEachServer(serverData); };
        Thread td = new Thread(t);                
        td.Priority = ThreadPriority.Highest;
        td.Start();
    }
}

然后这个方法正确调用

try
{
    message = new Queue().ReadMessageFromMSMQ(server.ServerName);
}
catch
{
}

后台工作者有什么问题我的Queue类是这样的

 class Queue
 {
     public MsmqMessageFormat ReadMessageFromMSMQ(string queueName)
     {
         MessageQueue messageQueue = null;

         messageQueue = new MessageQueue(@".\Private$\" + queueName);

         messageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(MsmqMessageFormat) });

         System.Messaging.Message msg = null;
         System.Messaging.Message[] allMessages = messageQueue.GetAllMessages();

         if (allMessages.Length > 0)
         {
             msg = messageQueue.Receive();

             MsmqMessageFormat readMessage = (MsmqMessageFormat)(msg.Body);

             return readMessage;
         }
         else
         {
             return null;
         }
     }
 }

而MsmqMessageFormat类是这样的

[Serializable]
public class MsmqMessageFormat
{      
    public Zvol Zvol { get; set;}
    public List<PolicyInterval> listPolicyIntervalInfo = new List<PolicyInterval>(); 
}

Answer 1

您能澄清一下您的申请背景吗？

它是 Windows 窗体应用程序吗？控制台应用程序？还是WPF？

它可能与线程的单元状态有关。 BackgroundWorker 使用的线程默认为 MTA（并且您无法覆盖它）。虽然手动创建的线程可以将公寓状态设置为 STA。

Answer 2

我不确定你的方法是否正确。我会一一阅读消息并绑定适当的事件。

从链接：

消息循环

上例中的最后一行
是“queue.BeginReceive()”。这是一个
成功的关键线
微软消息的实现
队列因为它提供了手段
用于连续收听
消息队列。每次有一条消息
收到后，监听过程停止。
这有助于提供线程安全的
环境。然而，这也意味着
开发商有责任
恢复监听队列。

使用 Microsoft 消息队列 MSMQ 和 C#

同样在您的文件中的最后一段代码中问题：

if (allMessages.Length > 0)
        {

            msg = messageQueue.Receive();

            MsmqMessageFormat readMessage = (MsmqMessageFormat)(msg.Body);


            return readMessage;
        }
        else
        {
            return null;
        }

这将获取所有消息并使用它们，但即使队列中有多个消息，也只会返回第一条消息。