本文整理了Java中com.google.appengine.api.urlfetch.HTTPRequest.addHeader()
方法的一些代码示例,展示了HTTPRequest.addHeader()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HTTPRequest.addHeader()
方法的具体详情如下:
包路径:com.google.appengine.api.urlfetch.HTTPRequest
类名称:HTTPRequest
方法名:addHeader
暂无
代码示例来源:origin: stackoverflow.com
URL url = new URL(request);
HTTPRequest req = new HTTPRequest(url, HTTPMethod.GET);
req.addHeader(new HTTPHeader("Authorization", "Bearer " + bearerToken));
HTTPResponse response = URLFetchServiceFactory.getURLFetchService().fetch(req);
System.out.println(new String(response.getContent()));
代码示例来源:origin: com.google.http-client/google-http-client-appengine
@Override
public void addHeader(String name, String value) {
request.addHeader(new HTTPHeader(name, value));
}
代码示例来源:origin: com.google.http-client/google-http-client-extensions
@Override
public void addHeader(String name, String value) {
request.addHeader(new HTTPHeader(name, value));
}
代码示例来源:origin: stackoverflow.com
URL url = new URL(URBAN_AIRSHIP_API_URL);
HTTPRequest req = new HTTPRequest(url, HTTPMethod.POST);
String authString = ApplicationProperties.getUrbanAirshipAppId() + ":" + ApplicationProperties.getUrbanAirshipMasterSecret();
String authStringBase64 = new String(Base64.encodeBase64(authString.getBytes()));
authStringBase64 = authStringBase64.trim();
req.addHeader(new HTTPHeader("Content-Type", "application/json"));
req.addHeader(new HTTPHeader("Authorization", "Basic " + authStringBase64));
ObjectMapper mapper = new ObjectMapper();
ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
mapper.writeValue(byteStream, new PushNotificationObj(userEmail, message));
req.setPayload(byteStream.toByteArray());
代码示例来源:origin: stackoverflow.com
final HTTPRequest updateStatus = new HTTPRequest(new URL("http://api.twitter.com/1/statuses/update.json"), HTTPMethod.POST);
updateStatus.addHeader(new HTTPHeader("Content-Type", "application/x-www-form-urlencoded"));
代码示例来源:origin: stackoverflow.com
String json ="{}";
URL url = new URL("https://android.googleapis.com/gcm/send");
HTTPRequest request = new HTTPRequest(url, HTTPMethod.POST);
request.addHeader(new HTTPHeader("Content-Type","application/json"));
request.addHeader(new HTTPHeader("Authorization", "key=<>"));
request.setPayload(json.getBytes("UTF-8"));
HTTPResponse response = URLFetchServiceFactory.getURLFetchService().fetch(request);
代码示例来源:origin: stackoverflow.com
public static void addMultipartBodyToRequest(MultipartEntity entity, HTTPRequest req) throws IOException{
/*
* turn Entity to byte[] using ByteArrayOutputStream
*/
ByteArrayOutputStream bos = new ByteArrayOutputStream();
entity.writeTo(bos);
byte[] body = bos.toByteArray();
/*
* extract multipart boundary (body starts with --boundary\r\n)
*/
String boundary = new BufferedReader(new StringReader(new String(body))).readLine();
boundary = boundary.substring(2, boundary.length());
/*
* add multipart header and body
*/
req.addHeader(new HTTPHeader("Content-type", "multipart/form-data; boundary=" + boundary));
req.setPayload(body);
}
代码示例来源:origin: stackoverflow.com
URL fetchurl = new URL(url);
String nameAndPassword = credentials.get("name")+":"+credentials.get("password");
String authorizationString = "Basic " + Base64.encode(nameAndPassword.getBytes());
HTTPRequest request = new HTTPRequest(fetchurl);
request.addHeader(new HTTPHeader("Authorization", authorizationString));
HTTPResponse response = URLFetchServiceFactory.getURLFetchService().fetch(request);
System.out.println(new String(response.getContent()));
代码示例来源:origin: com.threewks.thundr/thundr-gae
private void addHeaders(HttpRequestImpl request, HTTPRequest fetchRequest) {
for (Map.Entry<String, String> header : request.getHeaders().entrySet()) {
fetchRequest.addHeader(new HTTPHeader(header.getKey(), StringUtil.toString(header.getValue())));
}
}
代码示例来源:origin: stackoverflow.com
String pivotalUrl = "http://www.pivotaltracker.com/services/v3/projects/"+projectID+"/stories"
String body = "<story><story_type>feature</story_type><name>Story name</name><requested_by>James Kirk</requested_by></story>"
URLFetchService fetchService = URLFetchServiceFactory.getURLFetchService();
HTTPRequest request = new HTTPRequest(pivotalUrl, HTTPMethod.POST, FetchOptions.Builder.withDeadline(30));
request.addHeader(new HTTPHeader("X-TrackerToken","putTokenHere"));
request.addHeader(new HTTPHeader("Content-type","application/xml"));
HTTPResponse response = fetchService.fetch(request);
if (response.getResponseCode() != 200) {
// something went wrong
}
代码示例来源:origin: org.apache.camel/camel-gae
protected void writeRequestHeaders(GHttpEndpoint endpoint, Exchange exchange, HTTPRequest request) {
HeaderFilterStrategy strategy = endpoint.getHeaderFilterStrategy();
for (String headerName : exchange.getIn().getHeaders().keySet()) {
String headerValue = exchange.getIn().getHeader(headerName, String.class);
if (strategy != null && !strategy.applyFilterToCamelHeaders(headerName, headerValue, exchange)) {
request.addHeader(new HTTPHeader(headerName, headerValue));
}
}
}
代码示例来源:origin: com.dropbox.core/dropbox-core-sdk
private HTTPRequest newRequest(String url, HTTPMethod method, Iterable<Header> headers) throws IOException {
HTTPRequest request = new HTTPRequest(new URL(url), method, options);
for (Header header : headers) {
request.addHeader(new HTTPHeader(header.getKey(), header.getValue()));
}
return request;
}
代码示例来源:origin: com.threewks.thundr/thundr-gae
private void addCookies(HttpRequestImpl request, HTTPRequest fetchRequest) {
for (HttpCookie cookie : request.getCookies()) {
fetchRequest.addHeader(new HTTPHeader("Cookie", cookie.toString()));
}
}
代码示例来源:origin: org.codehaus.groovy.modules.http-builder/http-builder
public void sendRequestHeader(HttpRequest request)
throws HttpException, IOException {
try {
HttpHost host = route.getTargetHost();
URI uri = new URI(host.getSchemeName()
+ "://"
+ host.getHostName()
+ ((host.getPort() == -1) ? "" : (":" + host.getPort()))
+ request.getRequestLine().getUri());
this.request = new HTTPRequest(uri.toURL(),
HTTPMethod.valueOf(request.getRequestLine().getMethod()),
FetchOptions.Builder.disallowTruncate().doNotFollowRedirects());
}
catch (URISyntaxException ex) {
throw new IOException("Malformed request URI: " + ex.getMessage(), ex);
}
catch (IllegalArgumentException ex) {
throw new IOException("Unsupported HTTP method: " + ex.getMessage(), ex);
}
// System.err.println("SEND: " + this.request.getMethod() + " " + this.request.getURL());
for (Header h : request.getAllHeaders()) {
// System.err.println("SEND: " + h.getName() + ": " + h.getValue());
this.request.addHeader(new HTTPHeader(h.getName(), h.getValue()));
}
}
代码示例来源:origin: jgritman/httpbuilder
public void sendRequestHeader(HttpRequest request)
throws HttpException, IOException {
try {
HttpHost host = route.getTargetHost();
URI uri = new URI(host.getSchemeName()
+ "://"
+ host.getHostName()
+ ((host.getPort() == -1) ? "" : (":" + host.getPort()))
+ request.getRequestLine().getUri());
this.request = new HTTPRequest(uri.toURL(),
HTTPMethod.valueOf(request.getRequestLine().getMethod()),
FetchOptions.Builder.disallowTruncate().doNotFollowRedirects());
}
catch (URISyntaxException ex) {
throw new IOException("Malformed request URI: " + ex.getMessage(), ex);
}
catch (IllegalArgumentException ex) {
throw new IOException("Unsupported HTTP method: " + ex.getMessage(), ex);
}
// System.err.println("SEND: " + this.request.getMethod() + " " + this.request.getURL());
for (Header h : request.getAllHeaders()) {
// System.err.println("SEND: " + h.getName() + ": " + h.getValue());
this.request.addHeader(new HTTPHeader(h.getName(), h.getValue()));
}
}
代码示例来源:origin: com.threewks.thundr/thundr-gae
private void addAuthorization(HttpRequestImpl request, HTTPRequest fetchRequest) {
String username = request.getUsername();
String password = request.getPassword();
String scheme = request.getScheme();
if (username != null && password != null) {
if (Authorization.Basic.equalsIgnoreCase(scheme)) {
fetchRequest.addHeader(new HTTPHeader(Header.Authorization, Authorization.createBasicHeader(username, password)));
} else {
throw new HttpRequestException("%s only currently supports %s authorization", HttpServiceImpl.class.getSimpleName(), Authorization.Basic);
}
}
}
代码示例来源:origin: GoogleCloudPlatform/appengine-gcs-client
@VisibleForTesting
HTTPRequest makeRequest(GcsFilename filename, @Nullable Map<String, String> queryStrings,
HTTPMethod method, long timeoutMillis, byte[] payload) {
HTTPRequest request = new HTTPRequest(makeUrl(filename, queryStrings), method,
FetchOptions.Builder.disallowTruncate()
.doNotFollowRedirects()
.validateCertificate()
.setDeadline(timeoutMillis / 1000.0));
for (HTTPHeader header : headers) {
request.addHeader(header);
}
request.addHeader(USER_AGENT);
if (payload != null && payload.length > 0) {
request.setHeader(new HTTPHeader(CONTENT_LENGTH, String.valueOf(payload.length)));
try {
request.setHeader(new HTTPHeader(CONTENT_MD5,
BaseEncoding.base64().encode(MessageDigest.getInstance("MD5").digest(payload))));
} catch (NoSuchAlgorithmException e) {
log.severe(
"Unable to get a MessageDigest instance, no Content-MD5 header sent.\n" + e.toString());
}
request.setPayload(payload);
} else {
request.setHeader(ZERO_CONTENT_LENGTH);
}
return request;
}
代码示例来源:origin: com.squareup.retrofit/retrofit
static HTTPRequest createRequest(Request request) throws IOException {
HTTPMethod httpMethod = getHttpMethod(request.getMethod());
URL url = new URL(request.getUrl());
HTTPRequest fetchRequest = new HTTPRequest(url, httpMethod);
for (Header header : request.getHeaders()) {
fetchRequest.addHeader(new HTTPHeader(header.getName(), header.getValue()));
}
TypedOutput body = request.getBody();
if (body != null) {
String mimeType = body.mimeType();
if (mimeType != null) {
fetchRequest.addHeader(new HTTPHeader("Content-Type", mimeType));
}
ByteArrayOutputStream baos = new ByteArrayOutputStream();
body.writeTo(baos);
fetchRequest.setPayload(baos.toByteArray());
}
return fetchRequest;
}
代码示例来源:origin: GoogleCloudPlatform/appengine-gcs-client
static HTTPRequest copyRequest(HTTPRequest in) {
HTTPRequest out = new HTTPRequest(in.getURL(), in.getMethod(), in.getFetchOptions());
for (HTTPHeader h : in.getHeaders()) {
out.addHeader(h);
}
out.setPayload(in.getPayload());
return out;
}
}
代码示例来源:origin: GoogleCloudPlatform/appengine-tck
@Test
public void testGetters() throws Exception {
HTTPRequest request = new HTTPRequest(getFetchUrl(), HTTPMethod.PATCH, FetchOptions.Builder.withDefaults());
request.addHeader(new HTTPHeader("foo", "bar"));
request.setPayload("qwerty".getBytes());
Assert.assertEquals(getFetchUrl(), request.getURL());
Assert.assertEquals(HTTPMethod.PATCH, request.getMethod());
Assert.assertNotNull(request.getFetchOptions());
Assert.assertNotNull(request.getHeaders());
Assert.assertEquals(1, request.getHeaders().size());
assertEquals(new HTTPHeader("foo", "bar"), request.getHeaders().get(0));
Assert.assertArrayEquals("qwerty".getBytes(), request.getPayload());
}
内容来源于网络,如有侵权,请联系作者删除!