【发布时间】：2014-05-14 17:14:19
【问题描述】：
我有一个非常简单的设置，其中生产者发布事件并有一个订阅者进行处理。这两个角色都使用存储队列作为传输托管在 Azure 中。这是生产者配置：
public class EndpointConfig : IConfigureThisEndpoint, AsA_Worker, UsingTransport<AzureStorageQueue>, IWantCustomInitialization
{
public void Init()
{
Configure.Transactions.Disable();
Configure.With()
.DefaultBuilder()
.UnicastBus();
}
}
这是订阅者配置：
public class EndpointConfig : IConfigureThisEndpoint, AsA_Worker, UsingTransport<AzureStorageQueue>, IWantCustomInitialization
{
public void Init()
{
Configure.Transactions.Disable();
Configure.With()
.DefaultBuilder()
.UnicastBus()
.LoadMessageHandlers();
}
}
和 app.config：
<connectionStrings>
<add name="NServiceBus/Transport" connectionString="UseDevelopmentStorage=true" />
</connectionStrings>
<AzureProfileConfig Profiles="NServiceBus.Development" />
<AzureSubscriptionStorageConfig ConnectionString="UseDevelopmentStorage=true" />
<AuditConfig QueueName="audit" />
<UnicastBusConfig>
<MessageEndpointMappings>
<add Assembly="Interfaces" Type="Interfaces.SumbitOrder" Endpoint="Producer" />
</MessageEndpointMappings>
</UnicastBusConfig>
事件定义如常：
public class SumbitOrder : IEvent
{
public string Name { get; set; }
}
活动的发布与其他活动一样：
Bus.Publish(Bus.CreateInstance<SumbitOrder>(m => { m.Name = "sample order"; }));
因此浏览 IntelliSense 流，我可以看到以下消息输出到控制台：
控制台：“从发件人 Subscriber1@UseDevelopmentStorage=true 收到 ID 为 0d46873c-102e-4d2a-b2a8-a3290097836a 的消息” 控制台输出“从发件人 Subscriber1@UseDevelopmentStorage=true 收到 ID 为 0d46873c-102e-4d2a-b2a8-a3290097836a 的消息” 时间：12.05.2014 9:11:40 线程：[4892]
控制台：“订阅 Subscriber1@UseDevelopmentStorage=true 到消息类型 Interfaces.SumbitOrder, Interfaces, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null” 控制台输出“订阅 Subscriber1@UseDevelopmentStorage=true 到消息类型 Interfaces.SumbitOrder, Interfaces, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null”。 时间：12.05.2014 9:11:40 线程：[4892]
而且我也可以在生产者输入队列上看到相同的消息：
{
"IdForCorrelation": null,
"Id": "0d46873c-102e-4d2a-b2a8-a3290097836a",
"MessageIntent": 3,
"ReplyToAddress": "Subscriber1@UseDevelopmentStorage=true",
"TimeToBeReceived": "10675199.02:48:05.4775807",
"Headers": {
"NServiceBus.MessageId": "0d46873c-102e-4d2a-b2a8-a3290097836a",
"NServiceBus.CorrelationId": "0d46873c-102e-4d2a-b2a8-a3290097836a",
"NServiceBus.OriginatingEndpoint": "Subscriber1",
"$.diagnostics.originating.hostid": "3814ca7177296375c232c8d0293664dc",
"NServiceBus.MessageIntent": "Subscribe",
"NServiceBus.Version": "4.6.1",
"NServiceBus.TimeSent": "2014-05-12 06:11:38:591761 Z",
"NServiceBus.OriginatingMachine": "VALDIS-MAC",
"NServiceBus.ControlMessage": "True",
"SubscriptionMessageType": "Interfaces.SumbitOrder, Interfaces, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null"
},
"Body": null,
"CorrelationId": "0d46873c-102e-4d2a-b2a8-a3290097836a",
"Recoverable": true
}
订阅者被写入订阅存储表。 然而，事件处理程序永远不会被调用：
namespace Subscriber1
{
public class SubmitOrderHandler : IHandleMessages<SumbitOrder>
{
public void Handle(SumbitOrder message)
{
// logic
}
}
}
但是，普通消息传递正在运行 (Bus.Send) - 因此这 2 个 Azure 角色之间的连接已启动并正在运行。 我不确定问题出在哪里，我不知道这是否与问题有关，但在调试时，我可以在 Bus.Publish 行看到以下异常：
Microsoft.Data.OData.ODataException: Cannot convert a primitive value to the expected type 'Edm.DateTime'. See the inner exception for more details. ---> System.NullReferenceException: Object reference not set to an instance of an object.
at System.Xml.Schema.XsdDateTime.Parser.ParseTime(Int32& start)
at System.Xml.Schema.XsdDateTime.Parser.ParseTimeAndZoneAndWhitespace(Int32 start)
at System.Xml.Schema.XsdDateTime.Parser.Parse(String text, XsdDateTimeFlags kinds)
at System.Xml.Schema.XsdDateTime..ctor(String text, XsdDateTimeFlags kinds)
at System.Xml.XmlConvert.ToDateTime(String s, XmlDateTimeSerializationMode dateTimeOption)
at Microsoft.Data.OData.PlatformHelper.ConvertStringToDateTime(String text)
at Microsoft.Data.OData.JsonLight.ODataJsonLightReaderUtils.ConvertStringValue(String stringValue, Type targetType)
at Microsoft.Data.OData.JsonLight.ODataJsonLightReaderUtils.ConvertValue(Object value, IEdmPrimitiveTypeReference primitiveTypeReference, ODataMessageReaderSettings messageReaderSettings, ODataVersion version, Boolean validateNullValue, String propertyName)
--- End of inner exception stack trace ---
at Microsoft.Data.OData.JsonLight.ODataJsonLightReaderUtils.ConvertValue(Object value, IEdmPrimitiveTypeReference primitiveTypeReference, ODataMessageReaderSettings messageReaderSettings, ODataVersion version, Boolean validateNullValue, String propertyName)
Inner exceptoin:
System.NullReferenceException: Object reference not set to an instance of an object.
at System.Xml.Schema.XsdDateTime.Parser.ParseTime(Int32& start)
at System.Xml.Schema.XsdDateTime.Parser.ParseTimeAndZoneAndWhitespace(Int32 start)
at System.Xml.Schema.XsdDateTime.Parser.Parse(String text, XsdDateTimeFlags kinds)
at System.Xml.Schema.XsdDateTime..ctor(String text, XsdDateTimeFlags kinds)
at System.Xml.XmlConvert.ToDateTime(String s, XmlDateTimeSerializationMode dateTimeOption)
at Microsoft.Data.OData.PlatformHelper.ConvertStringToDateTime(String text)
at Microsoft.Data.OData.JsonLight.ODataJsonLightReaderUtils.ConvertStringValue(String stringValue, Type targetType)
at Microsoft.Data.OData.JsonLight.ODataJsonLightReaderUtils.ConvertValue(Object value, IEdmPrimitiveTypeReference primitiveTypeReference, ODataMessageReaderSettings messageReaderSettings, ODataVersion version, Boolean validateNullValue, String propertyName)
这会导致 NServiceBus.Core 程序集中的InvalidOperationException。
但是手动从堆栈跟踪中调用最终的公共方法是成功的：
XmlConvert.ToDateTime("2014-05-11T20:42:01.15Z", XmlDateTimeSerializationMode.RoundtripKind);
调用堆栈上来自 NServiceBus 的最后一个方法是：NServiceBus.Azure.dll!NServiceBus.Unicast.Subscriptions.AzureSubscriptionStorage.NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions.ISubscriptionStorage.Subscribe(NServiceBus.Address address = {unknown}, System.Collections.Generic.IEnumerable<NServiceBus.Unicast.Subscriptions.MessageType> messageTypes = {unknown})。
我可以验证使用 Azure 存储队列的相同设置与刚刚在本地托管的传输一样效果很好。所以我的猜测应该与角色在模拟器中的托管方式或存储模拟器的工作方式有关。
请帮助诊断此问题，因为当前的 pub/sub 方案失败，这是我们向管理层演示完整样本以进行决策制定过程的关键！
【问题讨论】：
标签： c# azure nservicebus