У меня есть служба, которая отвечает на сообщения в MSMQ, используя WCF. Когда сообщение хорошо отформатировано, оно работает как обычно, и мы счастливы. Когда сообщение предназначено для другой службы, а действие отличается, сообщение остается в очереди, мы получаем записи в журнале, исправляем, и мы счастливы.
Но когда сообщение имеет правильное действие, но содержит элементы XML, которые не могут быть десериализованы сервером, сообщение исчезает из очереди, мы не получаем записей журнала и почти не знаем, что произошло. мы не счастливы.
Я пытался добавить IErrorHandler. Я попытался добавить обработчик событий Faults. Единственное, что я могу сделать, - это использовать диагностические журналы, встроенные в WCF. Можно ли как-то ответить на такую ошибку в коде с помощью моего собственного регистратора или обработчика ошибок?
Мои очереди оказываются транзакционными, но это, похоже, не имеет никакого значения для этой проблемы. Это происходит в MSMQ версии 3.0, в Windows Server 2003.
В этом исходном коде обнаружена проблема:
class Program : IErrorHandler {
private static Uri QueueUri = new Uri("net.msmq://localhost/private/server_queue");
static void Main(string[] args) {
Program program = new Program();
if (args.Length > 0) {
if (args[0] == "server") {
program.Server();
} else if (args[0] == "bad") {
program.BadClient();
}
} else {
program.Client();
}
}
public void BadClient() {
using (var client = new BadServiceClient(QueueUri)) {
client.Do(new [] {new BadStuff { BadMessage = "hi" }});
}
}
public void Client() {
using (var client = new ServiceClient(QueueUri)) {
client.Do(new [] {new Stuff {Message = "hi"}});
}
}
public void Server() {
var serviceHost = new ServiceHost(typeof(Service));
serviceHost.AddServiceEndpoint(typeof (IService), new NetMsmqBinding(), QueueUri);
serviceHost.Open();
serviceHost.Faulted += serviceHost_Faulted;
serviceHost.UnknownMessageReceived += new EventHandler<UnknownMessageReceivedEventArgs>(serviceHost_UnknownMessageReceived);
foreach (ChannelDispatcher dispatcher in serviceHost.ChannelDispatchers) {
dispatcher.ErrorHandlers.Add(this);
}
Console.WriteLine("press the any key");
Console.ReadKey(true);
}
void serviceHost_UnknownMessageReceived(object sender, UnknownMessageReceivedEventArgs e) {
Console.WriteLine("unknown message: {0}", e);
}
private static void serviceHost_Faulted(object sender, EventArgs e) {
Console.WriteLine("fault: {0}", e);
}
public void ProvideFault(Exception error, MessageVersion version, ref Message fault) {
Console.WriteLine("handling error: {0}", error);
}
public bool HandleError(Exception error) {
Console.WriteLine("handling error: {0}", error);
return true;
}
}
[ServiceContract]
public interface IService {
[OperationContract(IsOneWay = true, Action = "do")]
void Do(IEnumerable<Stuff> stuffs);
}
[ServiceContract]
public interface IBadService {
[OperationContract(IsOneWay = true, Action = "do")]
void Do(IEnumerable<BadStuff> stuffs);
}
class ServiceClient : ClientBase<IService>, IService {
public ServiceClient(Uri uri) : base(new NetMsmqBinding(), new EndpointAddress(uri)) {}
public void Do(IEnumerable<Stuff> stuffs) {
Channel.Do(stuffs);
}
}
class BadServiceClient : ClientBase<IBadService>, IBadService {
public BadServiceClient(Uri uri) : base(new NetMsmqBinding(), new EndpointAddress(uri)) {}
public void Do(IEnumerable<BadStuff> stuffs) {
Channel.Do(stuffs);
}
}
[ServiceBehavior(TransactionTimeout = "00:5:00", InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Single)]
class Service : IService {
[OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
public void Do(IEnumerable<Stuff> stuffs) {
foreach (var stuff in stuffs) {
Console.WriteLine("service doing stuff, message: " + stuff.Message);
}
}
}
[DataContract]
public class Stuff {
[DataMember]
public string Message;
}
[DataContract]
public class BadStuff : Stuff {
[DataMember]
public string BadMessage;
}