CoreWCF集成RabbitMQ报错：契约需双向绑定，如何修改契约？

问题描述 #

按照CoreWCF RabbitMQ支持的相关文档操作时，遇到以下异常：

System.InvalidOperationException
HResult=0x80131509
Message=Contract requires TwoWay (either request-reply or duplex), but Binding 'RabbitMqBinding' doesn't support it or isn't configured properly to support it.
Source=System.ServiceModel.Primitives
StackTrace:
at System.ServiceModel.Channels.ServiceChannelFactory.BuildChannelFactory(ServiceEndpoint serviceEndpoint, Boolean useActiveAutoClose)
at System.ServiceModel.ChannelFactory.OnOpening()
at System.ServiceModel.Channels.CommunicationObject.<System-ServiceModel-IAsyncCommunicationObject-OpenAsync>d__88.MoveNext()
at System.ServiceModel.Channels.CommunicationObject.<OpenAsyncInternal>d__87.MoveNext()
at System.ServiceModel.ChannelFactory.EnsureOpened()
at System.ServiceModel.ChannelFactory`1.CreateChannel(EndpointAddress address, Uri via)

创建服务使用的命令：

dotnet new --install CoreWCF.Templates 
dotnet new corewcf --name MyService

原契约代码：

[ServiceContract]
public interface IService
{
    [OperationContract]
    string GetData(int value);

    [OperationContract]
    CompositeType GetDataUsingDataContract(CompositeType composite);
}

[DataContract]
public class CompositeType
{
    bool boolValue = true;
    string stringValue = "Hello ";

    [DataMember]
    public bool BoolValue
    {
        get { return boolValue; }
        set { boolValue = value; }
    }

    [DataMember]
    public string StringValue
    {
        get { return stringValue; }
        set { stringValue = value; }
    }
}

创建Channel的代码：

public static TContract CreateChannelOnRabbitMq<TContract>()
{
    var endpointAddress = new System.ServiceModel.EndpointAddress(Uri);
    var rabbitMqBinding = new CoreWCF.ServiceModel.Channels.RabbitMqBinding
    {
        SslOption = new SslOption
        {
            ServerName = Uri.Host,
            Enabled = true
        },
    };
    var factory = new ChannelFactory<TContract>(rabbitMqBinding, endpointAddress);
    
    factory.Credentials.UserName.UserName = Credentials.UserName;
    factory.Credentials.UserName.Password = Credentials.Password;

    var channel = factory.CreateChannel();
    
    (channel as System.ServiceModel.Channels.IChannel)?.Open();

    return channel;
}

尝试将契约改为无返回值方法后仍抛出异常，询问如何修改契约以支持RabbitMQ Bindings。

解决方案 #

方案1：使用单向消息契约（推荐，符合RabbitMQ默认模式） #

RabbitMqBinding默认仅支持单向消息传递，WCF中即使是void返回值的操作，默认OperationContract仍为双向（TwoWay）模式，因此必须显式标记为单向：

修改契约代码，为每个操作添加IsOneWay = true，并将有返回值的方法改为void（单向操作不支持返回值）：

[ServiceContract]
public interface IService
{
    [OperationContract(IsOneWay = true)]
    void SendData(int value); // 修改方法名更符合单向语义，同时设置IsOneWay=true

    [OperationContract(IsOneWay = true)]
    void SendCompositeData(CompositeType composite); // 同样设置IsOneWay=true，返回值改为void
}

[DataContract]
public class CompositeType
{
    bool boolValue = true;
    string stringValue = "Hello ";

    [DataMember]
    public bool BoolValue
    {
        get { return boolValue; }
        set { boolValue = value; }
    }

    [DataMember]
    public string StringValue
    {
        get { return stringValue; }
        set { stringValue = value; }
    }
}

方案2：启用请求-响应模式（如需双向通信） #

如果需要保留请求-响应的双向交互，需在RabbitMqBinding中显式启用请求回复模式，并确保服务端和客户端配置一致：

1. 客户端绑定配置：

public static TContract CreateChannelOnRabbitMq<TContract>()
{
    var endpointAddress = new System.ServiceModel.EndpointAddress(Uri);
    var rabbitMqBinding = new CoreWCF.ServiceModel.Channels.RabbitMqBinding
    {
        SslOption = new SslOption
        {
            ServerName = Uri.Host,
            Enabled = true
        },
        RequestReply = true, // 启用请求回复模式
        ReplyQueueName = "MyService_ReplyQueue" // 指定回复队列名称，需确保队列存在或自动创建
    };
    var factory = new ChannelFactory<TContract>(rabbitMqBinding, endpointAddress);
    
    factory.Credentials.UserName.UserName = Credentials.UserName;
    factory.Credentials.UserName.Password = Credentials.Password;

    var channel = factory.CreateChannel();
    
    (channel as System.ServiceModel.Channels.IChannel)?.Open();

    return channel;
}

2. 服务端绑定配置：
   确保服务端的RabbitMqBinding同样启用RequestReply = true，并配置对应的回复队列，同时保持契约的双向操作（保留返回值）。

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