使用 netMsmqBinding 读取消息的 WCF Msmq 问题

Question

我有一个使用 netMsmqBinding 的 WCF 服务，我用它来将 Msmq 消息添加到队列中。消息添加得很好，我可以通过计算机管理控制台在队列中看到它们。

我有另一个 WCF 服务正在尝试从队列中检索消息，这就是我遇到问题的地方。每当将消息添加到队列中时（该位工作正常），我的服务中的方法就会被调用，但 Msmq 消息似乎全部为空值。

我不确定如何从 Msmq 获取消息？这是我的服务详细信息...任何帮助表示赞赏..

[ServiceContract]
[ServiceKnownType(typeof(Msmq<string>))]
public interface IMessageListener
{
   [OperationContract(IsOneWay = true, Action = "*")]
    void ListenForMessage(Msmq<string> msg);
}

public class MessageListener : IMessageListener
{
    [OperationBehavior(TransactionScopeRequired = false, TransactionAutoComplete = true)]
    public void ListenForMessage(MsmqMessage<string> msg)
    {
         //this gets called and seems to remove the message from the queue, but message attributes are all null
    }
}

Answer 1

我认为您还没有完全“理解”WCF over MSMQ 的想法。

当将 WCF 与 netMsmqBinding 结合使用时，整个想法是您不需要需要处理 MSMQ 的详细信息 - 让 WCF 运行时处理它！

所以基本上，您的方法应该与任何 WCF 服务一样：

• 定义您的服务契约及其方法（操作契约）
• 将您的数据结构定义为 [DataContract] 并在您的服务方法中使用这些结构
• 来实现服务

因此，您的服务应该类似于：

[DataContract]
public class Customer
{
   [DataMember]
   public int ID { get; set; }

   [DataMember]
   public string Name { get; set; }

   ...
}

[ServiceContract]
public interface ICustomerService
{
    [OperationContract(IsOneWay=true)]
    void SaveCustomer(Customer myCustomer)

    [OperationContract(IsOneWay=true)]
    void CreateCustomer(int ID, string name);
}

您应该有一个数据合同来描述您的数据 - 只是您的数据，这里不需要 MSMQ 详细信息！然后您应该有一组处理 Customer 对象的服务方法 - 您可以将其放入队列中进行存储、创建一个新的等。

然后您将实现客户端和服务器端对于此服务协定，WCF 运行时将处理 MSMQ 传输的所有细节，将有效负载（Customer 对象）放入 MSMQ 消息中，然后再次将其取出，等等...真的不必处理这个问题。