Отправить двоичное сообщение в MSMQ - PullRequest
Новая
       17

Отправить двоичное сообщение в MSMQ

2 голосов
/ 07 апреля 2011

В службе .NET я хотел бы отправить содержимое потока в сообщении MSMQ.Я получаю объект Stream из WCF (который может быть изображением, файлом .doc или чем-то еще), и я просто хотел бы поместить содержимое в MSMQ.Я попытался установить свойство System.Messaging.Message.BodyStream для объекта потока, но я получаю сообщение об ошибке «Метод не поддерживается» при попытке отправить сообщение.

У кого-нибудь есть пример или учебное пособие о том, какдля этого?

Я ищу что-то вроде этого:

Сообщение контракта: 

    <MessageContract()> _
   Class UploadStreamMessage
        <MessageHeader()> _
        Public guidCaller As Guid
        <MessageBodyMember()> _
        Public data As Stream
    End Class

А затем реализация метода WriteToMSMQ: 

   <OperationBehavior(TransactionScopeRequired:=True, Impersonation:=ImpersonationOption.Required)> _
   Public Sub WriteToMSMQ (ByVal stream As IServiceMSMQ.UploadStreamMessage) Implements IServiceMSMQ.WriteToMSMQ 

Using queue As New MessageQueue(NOM_QUEUE)

    Dim msmqMessage As New Message
    msmqMessage = New System.Messaging.Message()
    msmqMessage.Body = stream.data
    queue.Send(msmqMessage, transaction)
    stream.data.Close()

End Using

Спасибо!

Ответы [ 2 ]

2 голосов
/ 07 апреля 2011

MSMQ не поддерживает потоковую передачу, поскольку она явно основана на сообщениях и слабо связана.Вы должны объявить поле контракта как byte[] и собрать там данные.

2 голосов
/ 07 апреля 2011

Вот пример очереди электронной почты, которую я использую ... Я думаю, вам нужно добавить форматер.

Вот DTO: 

[Serializable]
public class EmailOut
{
  private readonly string _fromEmail;
  private readonly string _toEmail;
  private readonly string _subject;
  private readonly string _body;
  private readonly string _cc;
  private readonly IList<EmailOutAttachment> _emailOutAttachments;


  public EmailOut(string fromEmail, string toEmail, string subject, string body, string cc, IList<EmailOutAttachment> emailOutAttachments)
{
  _fromEmail = fromEmail;
  _cc = cc;
  _emailOutAttachments = emailOutAttachments;
  _toEmail = toEmail;
  _subject = subject;
  _body = body;
}

public string FromEmail
{
  get { return _fromEmail; }
}

public string ToEmail
{
  get { return _toEmail; }
}

public string Subject
{
  get { return _subject; }
}

public string Body
{
  get { return _body; }
}

public string Cc
{
  get { return _cc; }
}

public IList<EmailOutAttachment> EmailOutAttachments
{
  get { return _emailOutAttachments; }
}

public override string ToString()
{
  return string.Format("FromEmail: {0}, ToEmail: {1}, Subject: {2}, Body: {3}, Cc: {4}", _fromEmail, _toEmail, _subject, _body, _cc);
}
}

[Serializable]
public class EmailOutAttachment
{
private readonly string _name;
private readonly byte[] _bytes;
private readonly int _size;
//Null ok for emailer
private readonly string _mimeEncodingType;

/// <summary>
/// Null ok for mime type.
/// </summary>
/// <param name="name"></param>
/// <param name="bytes"></param>
/// <param name="size"></param>
/// <param name="mimeEncodingType">Null ok for mime type.</param>
public EmailOutAttachment( string name, byte[] bytes, int size, string mimeEncodingType)
{
  _bytes = bytes;
  _name = name;
  _size = size;
  _mimeEncodingType = mimeEncodingType;
}

public byte[] Bytes
{
  get { return _bytes; }
}

public int Size
{
  get { return _size; }
}

public string MimeEncodingType
{
  get { return _mimeEncodingType; }
}

public string Name
{
  get { return _name; }
}

}

Вот расширение, которое вам нужно. 

public static Byte[] GetBytes(this Stream input)
{
  if (null == input || 0 == input.Length)
    return new Byte[0];

  byte[] bytes = new byte[input.Length];
  int numBytesToRead = (int)input.Length;
  int numBytesRead = 0;
  while (numBytesToRead > 0)
  {
    // Read may return anything from 0 to numBytesToRead.
    int n = input.Read(bytes, numBytesRead, numBytesToRead);

    // Break when the end of the file is reached.
    if (n == 0)
      break;

    numBytesRead += n;
    numBytesToRead -= n;
  }
  return bytes;
}

Это механизм отправки: 

  using (Message msg = new Message())
  {
    msg.Body = new EmailOut(from, to, title, body, cc, attachments);
    msg.Recoverable = true;
    msg.Formatter = new BinaryMessageFormatter();
    string queuePath = config.MsmqEmailBox;
    //if this queue doesn't exist we will create it
    //if (!MessageQueue.Exists(queuePath))
    //  MessageQueue.Create(queuePath);
    using (MessageQueue messageQueue = new MessageQueue(queuePath))
    {
      messageQueue.Formatter = new BinaryMessageFormatter();
      messageQueue.Send(msg);
    }
  }

Это его принимающий конец ... 

  using (var messageQueue = new MessageQueue(_config.MsmqEmailBox))
    try
    {
      _log.Debug("Retrieving queue");
      messageQueue.Formatter = new BinaryMessageFormatter();
      messageQueue.MessageReadPropertyFilter.SetAll();
      List<Message> allMessages = messageQueue.GetAllMessages().ToList();
      if(0 < allMessages.Count)
        SendEmailNoMsmq.Instance.SendDotNetEmail(_config.DevRecipient,string.Format("Sending queued messages, Count: {0}, Time: {1}",allMessages.Count,DateTime.Now),"MSMQ MAIL SEND", _config, _log);

      foreach (Message message in allMessages)
      {
        EmailOut msg = (EmailOut)message.Body;
        _log.Info(string.Format("Sending email id:{0} to:{1} ", message.Id, msg.ToEmail));
        SendEmailNoMsmq.Instance.SendDotNetEmail(msg, _config, _log);
        messageQueue.ReceiveById(message.Id);
      }
    }
    catch (Exception ex)
    {
      _log.Error("Error ex:" + ex);
      throw;
    }
}
...