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 承载。
- IIS WCF 主机应用程序的 web.config
- via NServiceBus.Config.IConfigurationSource
- 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 哪些类是命令和事件通过约定而不是实现标记接口,你仍然需要在应用程序/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"