本文整理了Java中org.jboss.netty.handler.codec.http.HttpRequest.getUri()方法的一些代码示例，展示了HttpRequest.getUri()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HttpRequest.getUri()方法的具体详情如下：
包路径：org.jboss.netty.handler.codec.http.HttpRequest
类名称：HttpRequest
方法名：getUri

HttpRequest.getUri介绍

[英]Returns the URI (or path) of this request.
[中]返回此请求的URI（或路径）。

代码示例

代码示例来源：origin: voldemort/voldemort

/**
 * Retrieve and validate the key from the REST request.
 * 
 * @return true if present, false if missing
 */
protected boolean hasKey() {
  boolean result = false;
  String requestURI = this.request.getUri();
  parseKeys(requestURI);
  if(this.parsedKeys != null) {
    result = true;
  } else {
    logger.error("Error when validating request. No key specified.");
    RestErrorHandler.writeErrorResponse(this.messageEvent,
                      HttpResponseStatus.BAD_REQUEST,
                      "Error: No key specified !");
  }
  return result;
}

代码示例来源：origin: voldemort/voldemort

/**
 * Retrieve and validate store name from the REST request.
 * 
 * @return true if valid, false otherwise
 */
protected boolean isStoreValid() {
  boolean result = false;
  String requestURI = this.request.getUri();
  this.storeName = parseStoreName(requestURI);
  if(storeName != null) {
    result = true;
  } else {
    logger.error("Error when validating request. Missing store name.");
    RestErrorHandler.writeErrorResponse(this.messageEvent,
                      HttpResponseStatus.BAD_REQUEST,
                      "Missing store name. Critical error.");
  }
  return result;
}

代码示例来源：origin: voldemort/voldemort

String requestURI = this.request.getUri();
if(logger.isDebugEnabled()) {
  logger.debug("Request URI: " + requestURI);

代码示例来源：origin: io.netty/netty

String uri = request.getUri();
int start = uri.indexOf("://");
if (start != -1) {

代码示例来源：origin: io.netty/netty

@Override
  protected void encodeInitialLine(ChannelBuffer buf, HttpMessage message)
      throws Exception {
    HttpRequest request = (HttpRequest) message;
    buf.writeBytes(request.getMethod().toString().getBytes("ASCII"));
    buf.writeByte((byte) ' ');
    buf.writeBytes(request.getUri().getBytes("UTF-8"));
    buf.writeByte((byte) ' ');
    buf.writeBytes(request.getProtocolVersion().toString().getBytes("ASCII"));
    buf.writeByte((byte) '\r');
    buf.writeByte((byte) '\n');
  }
}

代码示例来源：origin: voldemort/voldemort

if(!readingChunks) {
  HttpRequest request = this.request = (HttpRequest) messageEvent.getMessage();
  String requestURI = this.request.getUri();
  if (logger.isDebugEnabled()) {
    logger.debug("Admin Request URI: " + requestURI);

代码示例来源：origin: apache/hive

new QueryStringDecoder(request.getUri()).getParameters();
final List<String> keepAliveList = q.get("keepAlive");
boolean keepAliveParam = false;
final List<String> dagIdQ = q.get("dag");
if (LOG.isDebugEnabled()) {
 LOG.debug("RECV: " + request.getUri() +
   "\n  mapId: " + mapIds +
   "\n  reduceId: " + reduceQ +
 return;
final String reqUri = request.getUri();
if (null == reqUri) {

代码示例来源：origin: webbit/webbit

@Override
public String uri() {
  return httpRequest.getUri();
}

代码示例来源：origin: resteasy/Resteasy

public static ResteasyUriInfo extractUriInfo(HttpRequest request, String contextPath, String protocol)
{
 String host = HttpHeaders.getHost(request, "unknown");
 String uri = request.getUri();
 String uriString = protocol + "://" + host + uri;
 URI absoluteURI = URI.create(uriString);
 return new ResteasyUriInfo(uriString, absoluteURI.getRawQuery(), contextPath);
}

代码示例来源：origin: webbit/webbit

@Override
  public String toString() {
    return messageEvent.getRemoteAddress() + " " + httpRequest.getMethod() + " " + httpRequest.getUri();
  }
}

代码示例来源：origin: webbit/webbit

private String getWebSocketLocation(HttpRequest req) {
  return  getWebSocketProtocol(req) + req.getHeader(HttpHeaders.Names.HOST) + req.getUri();
}

代码示例来源：origin: webbit/webbit

private String getWebSocketLocation(HttpRequest req) {
 return  getWebSocketProtocol(req) + req.getHeader(HttpHeaders.Names.HOST) + req.getUri();
}

代码示例来源：origin: io.netty/netty

HttpRequest httpRequest = (HttpRequest) httpMessage;
SpdyHeaders.setMethod(spdyVersion, spdySynStreamFrame, httpRequest.getMethod());
SpdyHeaders.setUrl(spdyVersion, spdySynStreamFrame, httpRequest.getUri());
SpdyHeaders.setVersion(spdyVersion, spdySynStreamFrame, httpMessage.getProtocolVersion());

代码示例来源：origin: com.ning/async-http-client

channel,
future.getNettyRequest().getHttpRequest().getMethod(),
future.getNettyRequest().getHttpRequest().getUri());

代码示例来源：origin: com.ning/async-http-client

private void writeRequest(Channel channel) {
  LOGGER.debug("Using non-cached Channel {} for {} '{}'",
      channel,
      future.getNettyRequest().getHttpRequest().getMethod(),
      future.getNettyRequest().getHttpRequest().getUri());
  Channels.setAttribute(channel, future);
  if (future.isDone()) {
    abortChannelPreemption();
    return;
  }
  if (future.getAsyncHandler() instanceof AsyncHandlerExtensions)
    AsyncHandlerExtensions.class.cast(future.getAsyncHandler()).onConnectionOpen();
  channelManager.registerOpenChannel(channel, partitionKey);
  future.attachChannel(channel, false);
  requestSender.writeRequest(future, channel);
}

代码示例来源：origin: org.jboss.resteasy/resteasy-netty

public static ResteasyUriInfo extractUriInfo(HttpRequest request, String contextPath, String protocol)
{
 String host = HttpHeaders.getHost(request, "unknown");
 String uri = request.getUri();
 String uriString = protocol + "://" + host + uri;
 URI absoluteURI = URI.create(uriString);
 URI noQuery = UriBuilder.fromUri(uriString).replaceQuery(null).build();
 return new ResteasyUriInfo(uriString, absoluteURI.getRawQuery(), contextPath);
}

代码示例来源：origin: org.webbitserver/webbit

@Override
  public String toString() {
    return messageEvent.getRemoteAddress() + " " + httpRequest.getMethod() + " " + httpRequest.getUri();
  }
}

代码示例来源：origin: cgbystrom/sockjs-netty

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
  HttpRequest request = (HttpRequest) e.getMessage();
  QueryStringDecoder qsd = new QueryStringDecoder(request.getUri());
  final List<String> c = qsd.getParameters().get("c");
  if (c == null) {
    respond(e.getChannel(), HttpResponseStatus.INTERNAL_SERVER_ERROR, "\"callback\" parameter required.");
    return;
  }
  jsonpCallback = c.get(0);
  super.messageReceived(ctx, e);
}

代码示例来源：origin: apifest/apifest-oauth20

public AuthRequest(HttpRequest request) {
  if (request.getUri() != null) {
    QueryStringDecoder dec = new QueryStringDecoder(request.getUri());
    Map<String, List<String>> params = dec.getParameters();
    this.clientId = QueryParameter.getFirstElement(params, CLIENT_ID);
    this.responseType = QueryParameter.getFirstElement(params, RESPONSE_TYPE);
    this.redirectUri = QueryParameter.getFirstElement(params, REDIRECT_URI);
    this.state = QueryParameter.getFirstElement(params, STATE);
    this.scope = QueryParameter.getFirstElement(params, SCOPE);
    this.userId = QueryParameter.getFirstElement(params, USER_ID);
  }
}

代码示例来源：origin: org.elasticsearch.plugin/transport-netty3-client

public Netty3HttpRequest(NamedXContentRegistry xContentRegistry, HttpRequest request, Channel channel) {
  super(xContentRegistry, request.getUri(), new HttpHeadersMap(request.headers()));
  this.request = request;
  this.channel = channel;
  if (request.getContent().readable()) {
    this.content = Netty3Utils.toBytesReference(request.getContent());
  } else {
    this.content = BytesArray.EMPTY;
  }
}