NServiceBus 无法在不显眼的模式下找到端点或消息端点映射

本文关键字:端点 映射 消息 模式 不显眼 NServiceBus | 更新日期: 2023-09-27 18:19:48

我正在尝试将基元TestService终结点连接到基元 WCF 服务,其中 WCF 服务实例使用最新的 NSB 5.2.9/Host6.0 将基元TestCommand发送到TestService终结点:

[ServiceBehavior(
    InstanceContextMode = InstanceContextMode.PerCall,
    ConcurrencyMode = ConcurrencyMode.Single )]
public class MyService : IMyService
{
    private readonly IBus bus;
    public MyService( IBus bus )
    {
        this.bus = bus;
    }
    public void Test( string value )
    {
        bus.Send( new TestCommand( value ) );
    }
}

我无法正确配置此功能。错误信息:

Exception thrown: 'System.InvalidOperationException' in System.ServiceModel.dll
Additional information: No destination could be found for message type Company.App.Commands.TestCommand. Check the <**MessageEndpointMappings**> section of the configuration of this endpoint for an entry either for this specific message type or for its assembly.

我可以在不使用"不显眼的节点"的情况下做到这一点,但不能使用约定。在尝试了所有方法后,我对如何配置它感到非常困惑。WCF 主机是自承载的,而测试终结点由 NServiceBus.Host 承载。

  1. IIS WCF 主机应用程序的 web.config
  2. via NServiceBus.Config.IConfigurationSource
  3. via NServiceBus.Config.IProvideConfiguration

现在我在 web.config 中有这个,它似乎毫无用处且被忽略:

<MessageEndpointMappings>
    <add Assembly="Company.App.Messages" Type="Company.App.Commands.TestCommand" Endpoint="testservice" />
</MessageEndpointMappings>

"不显眼模式":我为约定创建了一个单独的项目,该项目由 WCF 主机终结点和 TestService 终结点引用。

public class MessageConventions : INeedInitialization
{
    public void Customize( BusConfiguration configuration )
    {
        var conventions = configuration.Conventions();
        conventions.DefiningCommandsAs( t => t.Namespace != null && t.Namespace.StartsWith( "Company.App" ) && t.Namespace.EndsWith( "Commands" ) );
        conventions.DefiningEventsAs( t => t.Namespace != null && t.Namespace.StartsWith( "Company.App" ) && t.Namespace.EndsWith( "Events" ) );
        conventions.DefiningMessagesAs( t => t.Namespace != null && t.Namespace.StartsWith( "Company.App" ) );
        //conventions.DefiningTimeToBeReceivedAs( t => GetTimeToBeReceived( t ) )
        //conventions.DefiningDataBusPropertiesAs( pi => IsDataBusProperty( pi ) );
    }
}

这些约定似乎被TestService所接受。

我的理解是,IIS WCF 主机必须在其 web.config 中声明映射,以便 WCF 服务知道将消息发送到何处bus.Send(new TestCommand("test"));但这不起作用。

然后我尝试在两个端点中定义这些映射,但没有运气。

此方法将输出使用上述约定找到的所有消息类型:

public class Startup : IWantToRunWhenBusStartsAndStops
{
public MessageMetadataRegistry Messages { get; set; }
public Conventions Conventions { get; set; }
public void Start()
{
    var getAllMessagesMethod = typeof( MessageMetadataRegistry ).GetMethod( "GetAllMessages",
        BindingFlags.NonPublic | BindingFlags.Instance );
    var allMessages = getAllMessagesMethod.Invoke( Messages, new object[ 0 ] ) as IEnumerable<MessageMetadata>;
    foreach ( var metadata in allMessages )
    {
        Type type = metadata.MessageType;
        string name = type.FullName;
        if ( this.Conventions.IsInSystemConventionList( type ) )
            Console.WriteLine( "System Msg: {0}", name );
        else if ( this.Conventions.IsCommandType( type ) )
            Console.WriteLine( "   Command: {0}", name );
        else if ( this.Conventions.IsEventType( type ) )
            Console.WriteLine( "     Event: {0}", name );
        else if ( this.Conventions.IsMessageType( type ) )
            Console.WriteLine( "   Message: {0}", name );
        if ( metadata.TimeToBeReceived != TimeSpan.MaxValue )
            Console.WriteLine( "            TimeToBeReceived={0}", metadata.TimeToBeReceived );
    }
}
public void Stop()
{
}
}

上面的方法输出消息类型"TestCommand",因此它知道所做的约定。

我已经检查了 1000 倍的错别字、大小写和每一个。我清洁了溶液。我的问题是:为什么 NServiceBus 找不到端点?

请帮忙。

NServiceBus 无法在不显眼的模式下找到端点或消息端点映射

不显眼意味着你告诉 NServiceBus 哪些类是命令和事件通过约定而不是实现标记接口,你仍然需要在应用程序/Web 配置中添加消息映射,以便 NServiceBus 知道将消息发送到哪个队列。

例外情况是表明这是您的问题

Check the <**MessageEndpointMappings**> section of the configuration of this endpoint for an entry either for this specific message type or for its assembly.

确保你的web.config中仍然有这样的东西:

<UnicastBusConfig>
  <MessageEndpointMappings>
    <add Messages="Company.App.Commands.TestCommand, Company.App.Commands" Endpoint="test.server" />
  </MessageEndpointMappings>
</UnicastBusConfig>

编辑

现在您已经发布了 web.config,问题似乎是您在 web.config 中的类型名称错误:

<add Assembly="Company.App.Messages" Type="Company.App.Commands.RunTestCommand"

但你这样做bus.Send(new TestCommand(value));

所以web.config是错误的,它应该是

<add Assembly="Company.App.Messages" Type="Company.App.Commands.TestCommand"