import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
@Override
public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
    MethodInterceptResult result) throws Throwable {
    HttpRequest request = (HttpRequest)objInst;
    ContextCarrier contextCarrier = new ContextCarrier();
    AbstractSpan span = ContextManager.createExitSpan(request.getURI().getPath(), contextCarrier, request.getHost() + ":" + request.getPort());
    span.setComponent(ComponentsDefine.JETTY_CLIENT);

    Tags.HTTP.METHOD.set(span, getHttpMethod(request));
    Tags.URL.set(span, request.getURI().toString());
    SpanLayer.asHttp(span);

    CarrierItem next = contextCarrier.items();
    HttpFields field = request.getHeaders();
    while (next.hasNext()) {
        next = next.next();
        field.add(next.getHeadKey(), next.getHeadValue());
    }
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
/**
 * Constructor.
 * 
 * @param helper
 *        The parent HTTP client helper.
 * @param method
 *        The method name.
 * @param requestUri
 *        The request URI.
 * @throws IOException
 *         In case of an I/O error
 */
public JettyClientCall( JettyHttpClientHelper helper, final String method, final String requestUri ) throws IOException
{
	super( helper, method, requestUri );
	clientHelper = helper;

	if( requestUri.startsWith( "http:" ) || requestUri.startsWith( "https:" ) )
	{
		httpRequest = (HttpRequest) helper.getHttpClient().newRequest( requestUri );
		httpRequest.method( method );

		setConfidential( httpRequest.getURI().getScheme().equalsIgnoreCase( Protocol.HTTPS.getSchemeName() ) );
	}
	else
	{
		throw new IllegalArgumentException( "Only HTTP or HTTPS resource URIs are allowed here" );
	}
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
@Override
protected HttpRequest newHttpRequest(HttpConversation conversation, URI uri) {
    final HttpRequest req = super.newHttpRequest(conversation, uri);
    final InstrumentedListener listener = new InstrumentedListener(metricRegistry, nameStrategy);
    req.listener(listener);
    req.onResponseBegin((response) -> listener.onResponseBegin());
    req.onResponseSuccess((result) -> listener.onResponseComplete(null, result));
    req.onResponseFailure((x, exn) -> listener.onResponseComplete(exn, x));
    return req;
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
public String getHttpMethod(HttpRequest request) {
    String method = request.getMethod();

    if (method == null || method.length() == 0) {
        method = "GET";
    }

    return method;
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
public String getHttpMethod(HttpRequest request) {
    HttpMethod httpMethod = HttpMethod.GET;

    /**
     * The method is null if the client using GET method.
     *
     * @see org.eclipse.jetty.client.HttpRequest#GET(String uri)
     * @see org.eclipse.jetty.client.HttpRequest( org.eclipse.jetty.client.HttpClient client, long conversation, java.net.URI uri)
     */
    if (request.getMethod() != null) {
        httpMethod = request.getMethod();
    }

    return httpMethod.name();
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
/**
 * <p>
 * ライブラリのバグを修正します<br>
 * URLにマルチバイト文字が含まれている場合にURLが正しく組み立てられないバグを修正します
 * </p>
 */
private static void fixQueryString(Request proxyRequest, String queryString) {
    if (!StringUtils.isEmpty(queryString)) {
        if (proxyRequest instanceof HttpRequest) {
            try {
                QUERY_FIELD.set(proxyRequest, queryString);
            } catch (IllegalArgumentException | IllegalAccessException e) {
                throw new RuntimeException(e);
            }
        }
    }
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
@Override
public HttpRequest newHttpRequest(HttpConversation conversation, URI uri) {
    final SalesforceHttpRequest request = new SalesforceHttpRequest(this, conversation, uri);
    request.timeout(timeout, TimeUnit.MILLISECONDS);
    return request;
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
@Override
public Request copyRequest(HttpRequest oldRequest, URI newURI) {
    return super.copyRequest(oldRequest, newURI);
}
 

import org.eclipse.jetty.client.HttpRequest; //导入依赖的package包/类
/**
 * Returns the HTTP request.
 * 
 * @return The HTTP request.
 */
public HttpRequest getHttpRequest()
{
	return httpRequest;
}