| Re: [jetty-users] Continuation Frame |
Hi,
I send it in this way, but it cannot guarantee the continuation frame is sent in the specific stream and session or using the http2 protocol. Am I right?
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("127.0.0.1", 443));
for (ByteBuffer buffer : buffers)
{
socketChannel.write(buffer);
Thread.sleep(1000);
}
And Also java will raise the exception
java.io.IOException: Broken pipe
at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)
at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
at sun.nio.ch.IOUtil.write(IOUtil.java:65)
at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471)
Thank you very much.
Best Regards
Muhui Jiang
Hi,
On Tue, Oct 13, 2015 at 9:39 AM, Muhui Jiang <jiangmuhui@xxxxxxxxx> wrote:
> Hi,
>
> Simone, Thanks for your detailed suggestions.
> So in your code, you mean
>
> List<ByteBuffer> buffers = lease.getByteBuffers();
>
> the list is the whole Continuation frames?
No.
It contains a list of buffers to write.
The buffers are typically 2 per frame: 1 buffer containing the header
bytes, 1 buffer containing the body bytes.
> But how can I write the continuation frame to the server periodically. I
> tried to use
>
> session.newStream(headers,
>
> new Promise.Adapter<>(), new Stream.Listener.Adapter() {}
>
> this way to send the headers but the result is that I can get the whole
> headersframe immediately.
Sure that will send a whole HEADERS frame.
You need to generate the buffers with the Generator and then write the
buffers one at a time.
> My question is how to write the buffer(Continuation frame) into the server
> periodically then the server can not get my whole headers frame in a short
> time. Many thanks.
List<ByteBuffer> buffers = lease.getByteBuffers();
for (ByteBuffer buffer : buffers)
{
socketChannel.write(buffer);
Thread.sleep(1000);
}
Alternatively, you can just generate the buffers and then continuously
send the same couple of buffers over and over.
buffers[0] = HEADERS header bytes
buffers[1] = HEADERS body bytes
buffers[2] = CONTINUATION #1 headers bytes
buffers[3] = CONTINUATION #1 body bytes
buffers[4] = CONTINUATION #2 headers bytes
buffers[5] = CONTINUATION #2 body bytes
etc.
--
Simone Bordet
----
http://cometd.org
http://webtide.com
Developer advice, training, services and support
from the Jetty & CometD experts.
_______________________________________________
jetty-users mailing list
jetty-users@xxxxxxxxxxx
To change your delivery options, retrieve your password, or unsubscribe from this list, visit
https://dev.eclipse.org/mailman/listinfo/jetty-users