import org.eclipse.jetty.http2.frames.DataFrame; //导入依赖的package包/类
private synchronized void sendMutExc(String method, HeadersFrame headersFrame, FuturePromise<Stream> streamPromise,
		HTTP2StreamHandler http2StreamHandler, DataPostContent dataPostContent, HTTP2SampleResult sampleResult)
		throws Exception {
	session.newStream(headersFrame, streamPromise, http2StreamHandler);
	if (method.equals("POST")) {
		Stream actualStream = streamPromise.get();
		int streamID = actualStream.getId();
		DataCallBack dataCallback = new DataCallBack();
		DataFrame data = new DataFrame(streamID,
				ByteBuffer.wrap(dataPostContent.getPayload(), 0, dataPostContent.getPayload().length), true);
		actualStream.data(data, dataCallback);
		this.addDataCallbackHandler(dataCallback);
		sampleResult.setQueryString(data.toString());// TODO revisar si es este metodo
		// add byte size of the queryString
		sampleResult.setBytes(sampleResult.getBytesAsLong() + (long) sampleResult.getQueryString().length()); 
	}

}
 

import org.eclipse.jetty.http2.frames.DataFrame; //导入依赖的package包/类
@Before
public void setup() throws MalformedURLException {
	TestJMeterUtils.createJmeterEnv();
	JMeterUtils.setProperty("HTTPResponse.parsers", "htmlParser");
	JMeterUtils.setProperty("htmlParser.className","org.apache.jmeter.protocol.http.parser.LagartoBasedHtmlParser");
	JMeterUtils.setProperty("htmlParser.types","text/html application/xhtml+xml application/xml text/xml");
	url = new URL("http://www.tenfieldigital.com.uy");
	http2Connection = Mockito.mock(HTTP2Connection.class);
	stream = Mockito.mock(Stream.class);
	pushPromisFrame = Mockito.mock(PushPromiseFrame.class);
	headersFrame = Mockito.mock(HeadersFrame.class);
	responseMetadata = Mockito.mock(MetaData.Response.class);
	callback = Mockito.mock(Callback.class);
	dataFrame = Mockito.mock(DataFrame.class);
	
}
 

import org.eclipse.jetty.http2.frames.DataFrame; //导入依赖的package包/类
@Override
public void onData(Stream stream, DataFrame frame, Callback callback) {
  LOG.info(frame);
  callback.succeeded();
  if (frame.isEndStream()) {
    phaser.arrive();
  }
}
 

import org.eclipse.jetty.http2.frames.DataFrame; //导入依赖的package包/类
@Before
public void setUp() {
  phaser = mock(Phaser.class);
  headersFrame = mock(HeadersFrame.class);
  dataFrame = mock(DataFrame.class);
  stream = mock(Stream.class);
  pushPromiseFrame = mock(PushPromiseFrame.class);
  callback = mock(Callback.class);
  sut = new StreamListener(phaser);

  when(headersFrame.isEndStream()).thenReturn(Boolean.TRUE);
  when(dataFrame.isEndStream()).thenReturn(Boolean.TRUE);
}
 

import org.eclipse.jetty.http2.frames.DataFrame; //导入依赖的package包/类
@Override
public void onData(Stream stream, DataFrame frame, Callback callback) {
    byte[] bytes = new byte[frame.getData().remaining()];
    frame.getData().get(bytes);
    System.out.println("[" + frame.getStreamId() + "] DATA " + new String(bytes));
    callback.succeeded();
    
    if (frame.isEndStream()) {
        completedFuture.complete(null);
    }
}
 

import org.eclipse.jetty.http2.frames.DataFrame; //导入依赖的package包/类
public static void main(String[] args) throws Exception {
    long startTime = System.nanoTime();

    // Create and start HTTP2Client.
    HTTP2Client client = new HTTP2Client();
    SslContextFactory sslContextFactory = new SslContextFactory(true);
    client.addBean(sslContextFactory);
    client.start();

    // Connect to host.
    String host = "localhost";
    int port = 8443;

    FuturePromise<Session> sessionPromise = new FuturePromise<>();
    client.connect(sslContextFactory, new InetSocketAddress(host, port), new ServerSessionListener.Adapter(), sessionPromise);

    // Obtain the client Session object.
    Session session = sessionPromise.get(5, TimeUnit.SECONDS);

    // Prepare the HTTP request headers.
    HttpFields requestFields = new HttpFields();
    requestFields.put("User-Agent", client.getClass().getName() + "/" + Jetty.VERSION);
    // Prepare the HTTP request object.
    MetaData.Request request = new MetaData.Request("GET", new HttpURI("https://" + host + ":" + port + "/"), HttpVersion.HTTP_2, requestFields);
    // Create the HTTP/2 HEADERS frame representing the HTTP request.
    HeadersFrame headersFrame = new HeadersFrame(request, null, true);

    // Prepare the listener to receive the HTTP response frames.
    Stream.Listener responseListener = new Stream.Listener.Adapter()
    {
        @Override
        public void onData(Stream stream, DataFrame frame, Callback callback)
        {
            byte[] bytes = new byte[frame.getData().remaining()];
            frame.getData().get(bytes);
            int duration = (int) TimeUnit.NANOSECONDS.toSeconds(System.nanoTime() - startTime);
            System.out.println("After " + duration + " seconds: " + new String(bytes));
            callback.succeeded();
        }
    };

    session.newStream(headersFrame, new FuturePromise<>(), responseListener);
    session.newStream(headersFrame, new FuturePromise<>(), responseListener);
    session.newStream(headersFrame, new FuturePromise<>(), responseListener);

    Thread.sleep(TimeUnit.SECONDS.toMillis(20));

    client.stop();
}