import org.eclipse.jetty.io.AbstractBuffer; //导入依赖的package包/类
public static InvokeResult postData(String url, String params) {
    if (StringUtils.isBlank(url) || StringUtils.isBlank(params)) {
        return InvokeResult.errorResult;
    }
    ContentExchange contentExchange = new ContentExchange();
    contentExchange.setMethod(HttpMethod.POST.getValue());
    contentExchange.setURL(url);
    try {
        AbstractBuffer content = new ByteArrayBuffer(params.getBytes(InvokerMsg.CHARSET_UTF8));
        contentExchange.setRequestContent(content);
        return invoke(contentExchange);
    } catch (UnsupportedEncodingException e) {
        logger.error(e.getMessage(), e);
    }
    return InvokeResult.errorResult;
}
 

import org.eclipse.jetty.io.AbstractBuffer; //导入依赖的package包/类
public static InvokeResult putData(String url, String params) {
    if (StringUtils.isBlank(url) || StringUtils.isBlank(params)) {
        return InvokeResult.errorResult;
    }
    ContentExchange contentExchange = new ContentExchange();
    contentExchange.setMethod(HttpMethod.PUT.getValue());
    contentExchange.setURL(url);
    try {
        AbstractBuffer content = new ByteArrayBuffer(params.getBytes(InvokerMsg.CHARSET_UTF8));
        contentExchange.setRequestContent(content);
        return invoke(contentExchange);
    } catch (UnsupportedEncodingException e) {
        logger.error(e.getMessage(), e);
    }
    return InvokeResult.errorResult;
}
 

import org.eclipse.jetty.io.AbstractBuffer; //导入依赖的package包/类
public GenericContentExchange streamingHandshake(String instance, String sessionId) throws IOException {
    GenericContentExchange exchange = new GenericContentExchange();
    //ContentExchange exchange = new ContentExchange();
    exchange.setMethod("POST");
    exchange.setURL(instance + SfdcConstants.DEFAULT_PUSH_ENDPOINT + SfdcConstants.HANDSHAKE);
    exchange.setRequestHeader("Authorization", "Bearer " + sessionId);
    exchange.setRequestHeader("Content-Type", "application/json");
    AbstractBuffer buffer = new ByteArrayBuffer(SfdcConstants.HANDSHAKE_MESSAGE.getBytes());
    exchange.setRequestContent(buffer);
    send(exchange);
    return exchange;
}