Почему MSMQ не отправляет пробел? - PullRequest
Новая
       23

Почему MSMQ не отправляет пробел?

1 голос
/ 24 мая 2010

Я изучаю службы MSMQ и написал простое консольное клиент-серверное приложение, которое отправляет каждое нажатие клавиши на сервер.Каждый раз, когда вы нажимаете контрольный символ (DEL, ESC, INS и т. Д.), Сервер по понятным причинам выдает ошибку.Однако всякий раз, когда я набираю пробел, сервер получает пакет, но не выдает ошибку и не отображает пробел.

Сервер: 

namespace QIM
{
    class Program
    {
        const string QUEUE = @".\Private$\qim";
        static MessageQueue _mq;
        static readonly object _mqLock = new object();
        static XmlSerializer xs;

        static void Main(string[] args)
        {
            lock (_mqLock)
            {
                if (!MessageQueue.Exists(QUEUE))
                    _mq = MessageQueue.Create(QUEUE);
                else
                    _mq = new MessageQueue(QUEUE);
            }
            xs = new XmlSerializer(typeof(string));
            _mq.BeginReceive(new TimeSpan(0, 1, 0), new object(), OnReceive);
            while (Console.ReadKey().Key != ConsoleKey.Escape) { }
        }

        static void OnReceive(IAsyncResult result)
        {
            Message msg;
            lock (_mqLock)
            {
                try
                {
                    msg = _mq.EndReceive(result);
                    Console.Write(".");
                    Console.Write(xs.Deserialize(msg.BodyStream));
                }
                catch (Exception ex)
                {
                    Console.Write(ex);
                }
            }
            _mq.BeginReceive(new TimeSpan(0, 1, 0), new object(), OnReceive);
        }
    }
}

Клиент: 

namespace QIM_Client
{
    class Program
    {
        const string QUEUE = @".\Private$\qim";
        static MessageQueue _mq;

        static void Main(string[] args)
        {
            if (!MessageQueue.Exists(QUEUE))
                _mq = MessageQueue.Create(QUEUE);
            else
                _mq = new MessageQueue(QUEUE);
            ConsoleKeyInfo key = new ConsoleKeyInfo();
            while (key.Key != ConsoleKey.Escape)
            {
                key = Console.ReadKey();
                _mq.Send(key.KeyChar.ToString());
            }
        }
    }
}

Клиентский ввод:

Тестирование, тестирование ...

Вывод на сервер:

.Testing, .. Тестирование .....

Вы заметите, что символ пробела отправляетсообщение, но символ не отображается.

Ответы [ 2 ]

5 голосов
/ 24 мая 2010

Ваша проблема не в MSMQ, а в классе XmlSerializer.См .: 

var key = Console.ReadKey();

XmlSerializer s = new XmlSerializer(typeof(string));

using (System.IO.MemoryStream ms = new System.IO.MemoryStream())
{
    s.Serialize(ms, key.KeyChar.ToString());

    ms.Position = 0;

    var foo = (string)s.Deserialize(ms);
}

Если вы введете пробел в консоли, вы увидите, что key.KeyChar.ToString() дает " ", но foo равно "".Из-за реализации по умолчанию XmlReader класс XmlSerializer считает строку только пустого пространства пустой;если строка содержит какие-либо другие символы, как начальные, так и конечные пробелы сохраняются.Пробел делает сериализованным, но десериализация превращает его в пустую строку.

Вместо этого используйте: 

Console.Write(
    s.Deserialize(System.Xml.XmlReader.Create(msg.BodyStream, 
                                          new System.Xml.XmlReaderSettings() 
                                          { 
                                              IgnoreWhitespace = false 
                                          })));
3 голосов
/ 24 мая 2010

Ответ от @Adam правильный. Самое простое решение - использовать BinaryMessageFormatter (в любом случае это приведет к небольшим сообщениям).

После инициализации объектов очереди сообщений как на клиенте, так и на сервере, установите форматер явно: 

_mq.Formatter = new BinaryMessageFormatter();

Тогда на сервере не пытайтесь связываться с BodyStream напрямую. Вместо этого просто используйте Body (который уже был десериализован форматером): 

Console.Write(".");
Console.Write(msg.Body);
...