com.google.appengine.api.urlfetch.HTTPRequest.addHeader()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(96)

本文整理了Java中com.google.appengine.api.urlfetch.HTTPRequest.addHeader()方法的一些代码示例,展示了HTTPRequest.addHeader()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HTTPRequest.addHeader()方法的具体详情如下:
包路径:com.google.appengine.api.urlfetch.HTTPRequest
类名称:HTTPRequest
方法名:addHeader

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());
}

相关文章