используя HttpClient, как я могу сохранить XDocument непосредственно в поток запросов? - PullRequest
Новая
       46

используя HttpClient, как я могу сохранить XDocument непосредственно в поток запросов?

3 голосов
/ 11 февраля 2012

Используя HttpWebRequest, я могу вызвать XDocument.Save () для записи напрямую в поток запроса: 

XDocument doc = ...;
var request = (HttpWebRequest)WebCreate.Create(uri);
request.method = "POST";
Stream requestStream = request.GetRequestStream();
doc.Save(requestStream);

Можно ли сделать то же самое с HttpClient? Прямой путь - 

XDocument doc = ...;
Stream stream = new MemoryStream();
doc.Save(stream);
var content = new System.Net.Http.StreamContent(stream);
var client = new HttpClient();
client.Post(uri, content);

Но это создает другую копию XDocument в MemoryStream.

1 Ответ

1 голос
/ 11 февраля 2012

XDocument.Save() ожидает Stream, в который можно записать.StreamContent ожидает поток, который можно прочитать.Таким образом, вы можете использовать два Stream с, где один выступает в качестве пересылки для другого.Я не думаю, что такой тип существует во фреймворке, но вы можете написать его самостоятельно: 

class ForwardingStream
{
    private readonly ReaderStream m_reader;
    private readonly WriterStream m_writer;

    public ForwardingStream()
    {
        // bounded, so that writing too much data blocks
        var buffers = new BlockingCollection<byte[]>(10);
        m_reader = new ReaderStream(buffers);
        m_writer = new WriterStream(buffers);
    }

    private class ReaderStream : Stream
    {
        private readonly BlockingCollection<byte[]> m_buffers;
        private byte[] m_currentBuffer;
        private int m_readFromCurrent;

        public ReaderStream(BlockingCollection<byte[]> buffers)
        {
            m_buffers = buffers;
        }

        public override void Flush()
        {}

        public override long Seek(long offset, SeekOrigin origin)
        {
            throw new NotSupportedException();
        }

        public override void SetLength(long value)
        {
            throw new NotSupportedException();
        }

        public override int Read(byte[] buffer, int offset, int count)
        {
            if (m_currentBuffer == null)
            {
                if (!m_buffers.TryTake(out m_currentBuffer, -1))
                {
                    return 0;
                }
                m_readFromCurrent = 0;
            }

            int toRead = Math.Min(count, m_currentBuffer.Length - m_readFromCurrent);

            Array.Copy(m_currentBuffer, m_readFromCurrent, buffer, offset, toRead);

            m_readFromCurrent += toRead;

            if (m_readFromCurrent == m_currentBuffer.Length)
                m_currentBuffer = null;

            return toRead;
        }

        public override void Write(byte[] buffer, int offset, int count)
        {
            throw new NotSupportedException();
        }

        public override bool CanRead
        {
            get { return true; }
        }

        public override bool CanSeek
        {
            get { return false; }
        }

        public override bool CanWrite
        {
            get { return false; }
        }

        public override long Length
        {
            get { throw new NotSupportedException(); }
        }

        public override long Position
        {
            get { throw new NotSupportedException(); }
            set { throw new NotSupportedException(); }
        }
    }

    private class WriterStream : Stream
    {
        private readonly BlockingCollection<byte[]> m_buffers;

        public WriterStream(BlockingCollection<byte[]> buffers)
        {
            m_buffers = buffers;
        }

        public override void Flush()
        {}

        public override long Seek(long offset, SeekOrigin origin)
        {
            throw new NotSupportedException();
        }

        public override void SetLength(long value)
        {
            throw new NotSupportedException();
        }

        public override int Read(byte[] buffer, int offset, int count)
        {
            throw new NotSupportedException();
        }

        public override void Write(byte[] buffer, int offset, int count)
        {
            if (count == 0)
                return;

            var copied = new byte[count];
            Array.Copy(buffer, offset, copied, 0, count);

            m_buffers.Add(copied);
        }

        public override bool CanRead
        {
            get { return false; }
        }

        public override bool CanSeek
        {
            get { return false; }
        }

        public override bool CanWrite
        {
            get { return true; }
        }

        public override long Length
        {
            get { throw new NotSupportedException(); }
        }

        public override long Position
        {
            get { throw new NotSupportedException(); }
            set { throw new NotSupportedException(); }
        }

        protected override void Dispose(bool disposing)
        {
            m_buffers.CompleteAdding();

            base.Dispose(disposing);
        }
    }

    public Stream Reader
    {
        get { return m_reader; }
    }

    public Stream Writer
    {
        get { return m_writer; }
    }
}

К сожалению, вы не можете одновременно читать и записывать эти потоки из одного потока.Но вы можете использовать Task для записи из другого потока: 

XDocument doc = …;

var forwardingStream = new ForwardingStream();

var client = new HttpClient();
var content = new StreamContent(forwardingStream.Reader);

Task.Run(() => doc.Save(forwardingStream.Writer));

var response = client.Post(url, content);
...