Блог

Я использую RSocket.Net для сетевого клиента для сервера RSocket с загрузкой Java Spring. Сервер отправляет клиенту сообщения с цитатами. Пример кода работает до 3-го сообщения с кавычками, которое усекается.

В RSocketProtocol.Handler.cs

     static public async Task Handler(IRSocketProtocol sink, PipeReader pipereader, CancellationToken cancellation)
    {
        Logs.Enter();

        //The original implementation was a state-machine parser with resumability. It doesn't seem like the other implementations follow this pattern and the .NET folks are still figuring this out too - see the internal JSON parser discussion for how they're handling state machine persistence across async boundaries when servicing a Pipeline. So, this version of the handler only processes complete messages at some cost to memory buffer scalability.
        //Note that this means that the Pipeline must be configured to have enough buffering for a complete message before source-quenching. This also means that the downstream consumers don't really have to support resumption, so the interface no longer has the partial buffer methods in it.
        while (!cancellation.IsCancellationRequested)
        {
            var read = await pipereader.ReadAsync(cancellation);
            var buffer = read.Buffer;
 

1-е сообщение выглядит следующим образом с размером буфера 942

Следующее сообщение аналогично. Тогда 3-е сообщение имеет либо слишком большой размер 5657 !!?

Или он слишком мал при 165

Это вызывает ошибку в MessageFramePeek методе

 static public (int Length, bool IsEndOfMessage) MessageFramePeek(ReadOnlySequence<byte> sequence) { var reader = new SequenceReader<byte>(sequence); return reader.TryRead(out byte b1) amp;amp; reader.TryRead(out byte b2) amp;amp; reader.TryRead(out byte b3) ? ((b1 << 8 * 2) | (b2 << 8 * 1) | (b3 << 8 * 0), true) : (0, false); }
 

ОБНОВЛЕНИЕ Я проверил, что тип кодировки — JSON на сервере и клиенте, чтобы строки не смешивались с объектами на проводе. Все та же проблема.

ОБНОВЛЕНИЕ Та же проблема возникает, если RSocket.Ядро построено на net-standard или net-framework.