MsmqIntegrationBinding是否支持多个服务操作

Question

我正在学习MsmqIntegrationBinding。到目前为止，我看到的所有示例和指南都涵盖了这样的场景，即只有一个操作和一个数据契约。我尝试添加另一个约定，但服务成功启动。然而，我不知道如何到达第二个操作。使用这个绑定，这样的事情是可能的吗？

[ServiceContract]
[ServiceKnownType(typeof(Data1))]
[ServiceKnownType(typeof(Data2))]
public interface ISampleService
{
    [OperationContract(IsOneWay = true, Action = "*")]
    void Operation1(MsmqMessage<Data1> msg);

    [OperationContract(IsOneWay = true)]
    void Operation2(MsmqMessage<Data2> msg);
}

public class SampleService : ISampleService
{
    [OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
    public void Operation1(MsmqMessage<Data1> msg)
    {
        var data = msg.Body;
    }

    [OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
    public void Operation2(MsmqMessage<Data2> msg)
    {
        var data = msg.Body;
    }
}

调用代码

var queue = new MessageQueue(@".\private$\samplequeue");
var body = new Data1() { Data = "some data" };
var message = new Message(body);
message.Label = "some label";
queue.Send(body, MessageQueueTransactionType.Single);

这将触发操作设置为"*“的Operation1。

Answer 1

这是一个非常有趣的问题。

操作OperationContractAttribute通常由WCF堆栈用来填充WS-Addressing soap标头。它的使用显然被队列绑定以某种方式覆盖了。

WCF可能有一个未记录的特性，它允许msmq消息报头到基于Action属性的操作的一些映射，但如果有，我不知道它会采用什么形式。

我认为最简单的解释是:不，这是不可能的，原因是msmqIntegrationBinding完全是它在tin上所说的:它是关于互操作而不是功能。

因为您被迫使用MsmqMessage包装器调用操作，所以它在某种程度上使这种绑定在语义上是一维的，这与我的理论相一致，即它旨在包装单个端点操作，以支持与旧式COM和ActiveX客户端的互操作。

无论如何，没有法律规定绑定必须支持多个操作，就像某些绑定不支持回调，而某些绑定只支持单向操作一样。

感谢这并没有直接回答你的问题。

Answer 2

我不确定这是不是一个答案，我也没有必要的50个声誉来评论。

从这个答案中获得灵感：https://stackoverflow.com/a/33154517/1095296我们正在做以下事情。

[ServiceContract]
public interface IMSMQueueHandler
{
    [OperationContract(IsOneWay = true, Action = "*")]
    void Handle(MsmqMessage<object> message);
}

然后，我们在包装服务主机的类上有一个构造函数

    public MSMQueueServiceHost(IMSMQConfig msmqConfig, IMSMQueueHandler handler)
    {
        _hostService = new ServiceHost(handler);

        AddHostServiceEndPoint(msmqConfig);

        _hostService.Open();
    }

    private void AddHostServiceEndPoint(IMSMQConfig msmqConfig)
    {
        ServiceMetadataBehavior smb = new ServiceMetadataBehavior { HttpGetEnabled = false };
        _hostService.Description.Behaviors.Add(smb);

        MsmqIntegrationBinding binding = new MsmqIntegrationBinding(MsmqIntegrationSecurityMode.None);
        binding.SerializationFormat = MsmqMessageSerializationFormat.Stream;
        binding.ReceiveErrorHandling = ReceiveErrorHandling.Move;

        ServiceEndpoint endpoint = _hostService.AddServiceEndpoint(
            typeof(IMSMQueueHandler),
            binding, 
            string.Format("msmq.formatname:DIRECT=OS:{0}", msmqConfig.MsmqPath));

        // enforce ServiceBehaviours and OperationBehaviours so we dont have to decorate all the handlers
        _hostService.Description.Behaviors.Find<ServiceBehaviorAttribute>().InstanceContextMode = InstanceContextMode.Single;
        _hostService.Description.Behaviors.Find<ServiceBehaviorAttribute>().ConcurrencyMode = ConcurrencyMode.Single;

        AddKnownTypes(endpoint);
    }

    private static void AddKnownTypes(ServiceEndpoint endpoint)
    {
        foreach(OperationDescription operation in endpoint.Contract.Operations)
        {
            operation.KnownTypes.Add(typeof(XElement));
            operation.Behaviors.Find<OperationBehaviorAttribute>().TransactionScopeRequired = true;
            operation.Behaviors.Find<OperationBehaviorAttribute>().TransactionAutoComplete = true;
        }
    }

这里让它工作的关键代码行是：

[OperationContract(IsOneWay = true, Action = "*")]
void Handle(MsmqMessage<object> message);

binding.SerializationFormat = MsmqMessageSerializationFormat.Stream;

operation.KnownTypes.Add(typeof(XElement));

使用Stream格式的原因是我们在消息体中看到了用大括号封装的XML (闻起来像JSON，但我们看不到原因)。

最后，也是我不确定这是答案的原因，因为它没有使用WCF DataContract和内置的WCF序列化，我们将一个包含以下方法的处理程序传递给构造函数：

    public void Handle(MsmqMessage<object> message)
    {
        object msmqType = Serializer.Deserialize(message.Body);

        _bus.Publish(msmqType);
    }

如果不是很明显，我们对消息使用XML序列化。