io.netty.handler.codec.http.FullHttpRequest.getUri()方法的使用及代码示例

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

FullHttpRequest.getUri介绍

暂无

代码示例

代码示例来源：origin: ffay/lanproxy

@Override
public void preRequest(FullHttpRequest request) {
String COOKIEHeader = request.headers().get(HttpHeaders.Names.COOKIE);
boolean authenticated = false;
if (COOKIEHeader != null) {
String[] COOKIEs = COOKIEHeader.split(";");
for (String COOKIE : COOKIEs) {
String[] COOKIEArr = COOKIE.split("=");
if (AUTH_COOKIE_KEY.equals(COOKIEArr[0].trim())) {
if (COOKIEArr.length == 2 && COOKIEArr[1].equals(token)) {
authenticated = true;
}
}
}
}
String auth = request.headers().get(HttpHeaders.Names.AUTHORIZATION);
if (!authenticated && auth != null) {
String[] authArr = auth.split(" ");
if (authArr.length == 2 && authArr[0].equals(ProxyConfig.getInstance().getConfigAdminUsername()) && authArr[1].equals(ProxyConfig.getInstance().getConfigAdminPassword())) {
authenticated = true;
}
}
if (!request.getUri().equals("/login") && !authenticated) {
throw new ContextException(ResponseInfo.CODE_UNAUTHORIZED);
}
logger.info("handle request for api {}", request.getUri());
}
});

代码示例来源：origin: weibocom/motan

@Override
public Object handle(Channel channel, Object message) {
FullHttpRequest httpRequest = (FullHttpRequest) message;
String uri = httpRequest.getUri();
int index = uri.indexOf("?");// should not be null
String requestPath = uri;

代码示例来源：origin: ffay/lanproxy

URI uri = new URI(request.getUri());
RequestHandler handler = routes.get(uri.getPath());
ResponseInfo respOnseInfo= null;

代码示例来源：origin: weibocom/motan

@Override
protected void channelRead0(final ChannelHandlerContext ctx, final FullHttpRequest httpRequest) throws Exception {
if(BAD_REQUEST.equals(httpRequest.getUri())){
sendResponse(ctx, buildDefaultResponse("bad request!", HttpResponseStatus.BAD_REQUEST));
return;
if(ROOT_PATH.equals(httpRequest.getUri()) || STATUS_PATH.equals(httpRequest.getUri())){
if(isSwitchOpen()){// 200
sendResponse(ctx, buildDefaultResponse("ok!", HttpResponseStatus.OK));

代码示例来源：origin: ffay/lanproxy

URI uri = new URI(request.getUri());
String uriPath = uri.getPath();
uriPath = uriPath.equals("/") ? "/index.html" : uriPath;

代码示例来源：origin: normanmaurer/netty-in-action

@Override
public void channelRead0(ChannelHandlerContext ctx,
FullHttpRequest request) throws Exception {
if (wsUri.equalsIgnoreCase(request.getUri())) {
ctx.fireChannelRead(request.retain());
} else {

代码示例来源：origin: rackerlabs/blueflood

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

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

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

代码示例来源：origin: rackerlabs/blueflood

@Override
public void handle(ChannelHandlerContext context, FullHttpRequest request) {
final Set supportedMethods = routeMatcher.getSupportedMethodsForURL(request.getUri());
StringBuilder result = new StringBuilder();
for(String string : supportedMethods) {
result.append(string);
result.append(",");
}
final String methodsAllowed = result.length() > 0 ? result.substring(0, result.length() - 1): "";
response.headers().add("Allow", methodsAllowed);
log.error(String.format("UnsupportedMethodHandler: URL is [%s]", request.getUri()));
log.error(String.format("UnsupportedMethodHandler: method is [%s]", request.getMethod()));
HttpResponder.getInstance().respond(context, request, response);
}
}

代码示例来源：origin: rackerlabs/blueflood

private FullHttpRequest updateRequestHeaders(FullHttpRequest request, PatternRouteBinding binding) {
Matcher m = binding.pattern.matcher(request.getUri());
if (m.matches()) {
Map headers = new HashMap(m.groupCount());
if (binding.paramsPositionMap != null) {
for (String header : binding.paramsPositionMap.keySet()) {
headers.put(header, m.group(binding.paramsPositionMap.get(header)));
}
} else {
for (int i = 0; i headers.put("param" + i, m.group(i + 1));
}
}
for (Map.Entry header : headers.entrySet()) {
request.headers().add(header.getKey(), header.getValue());
}
}
return request;
}

代码示例来源：origin: rackerlabs/blueflood

public void route(ChannelHandlerContext context, FullHttpRequest request) {
final String method = request.getMethod().name();
final String URI = request.getUri();

代码示例来源：origin: rackerlabs/blueflood

public static HttpRequestWithDecodedQueryParams create(FullHttpRequest request) {
final QueryStringDecoder decoder = new QueryStringDecoder(request.getUri());
request.setUri(decoder.path());
return new HttpRequestWithDecodedQueryParams(request, decoder.parameters());
}

代码示例来源：origin: co.paralleluniverse/comsat-actors-netty

private void initUri() {
if (uri == null) {
try {
uri = new URI(req.getUri());
} catch (final URISyntaxException e) {
throw new RuntimeException(e);
}
}
}

代码示例来源：origin: outbrain/ob1k

@Override
public boolean acceptInboundMessage(final Object msg) throws Exception {
if (!(msg instanceof FullHttpRequest))
return false;
final FullHttpRequest request = (FullHttpRequest) msg;
final String uri = request.getUri();
return pathResolver.isStaticPath(uri);
}

代码示例来源：origin: gugemichael/nesty

@Override
public String[] visitTerms() {
String termsUrl = HttpUtils.truncateUrl(request.getUri());
return FluentIterable.from(Splitter.on('/').omitEmptyStrings().trimResults().split(termsUrl)).toArray(String.class);
}

代码示例来源：origin: co.cask.cdap/cdap-explore

protected T decodeArguments(FullHttpRequest request, Class argsType, T defaultValue) throws IOException {
ByteBuf cOntent= request.content();
if (!content.isReadable()) {
return defaultValue;
}
try (Reader reader = new InputStreamReader(new ByteBufInputStream(content), StandardCharsets.UTF_8)) {
T args = GSON.fromJson(reader, argsType);
return (args == null) ? defaultValue : args;
} catch (JsonSyntaxException e) {
LOG.info("Failed to parse runtime arguments on {}", request.getUri(), e);
throw e;
}
}

代码示例来源：origin: co.paralleluniverse/comsat-actors-netty

@Override
public final Multimap getParameters() {
QueryStringDecoder queryStringDecoder;
if (params == null) {
queryStringDecoder = new QueryStringDecoder(req.getUri());
final ImmutableMultimap.Builder builder = ImmutableMultimap.builder();
final Map> parameters = queryStringDecoder.parameters();
for (final String k : parameters.keySet())
builder.putAll(k, parameters.get(k));
params = builder.build();
}
return params;
}

代码示例来源：origin: aerogear/aerogear-simplepush-server

private void handleHttpRequest(final ChannelHandlerContext ctx, final FullHttpRequest req) throws Exception {
if (isHttpRequestValid(req, ctx.channel())) {
executorServer.submit(new Notifier(req.getUri(), req.content()));
sendHttpResponse(OK, req, ctx.channel());
}
}

代码示例来源：origin: org.jboss.aerogear/aerogear-simplepush-server-netty

private void handleHttpRequest(final ChannelHandlerContext ctx, final FullHttpRequest req) throws Exception {
if (isHttpRequestValid(req, ctx.channel())) {
executorServer.submit(new Notifier(req.getUri(), req.content()));
sendHttpResponse(OK, req, ctx.channel());
}
}

代码示例来源：origin: org.jboss.aerogear/aerogear-netty-codec-sockjs

@Override
public void messageReceived(final ChannelHandlerContext ctx, final FullHttpRequest request) throws Exception {
final String path = new QueryStringDecoder(request.getUri()).path();
for (SockJsServiceFactory factory : factories.values()) {
if (path.startsWith(factory.config().prefix())) {
handleService(factory, request, ctx);
return;
}
}
writeNotFoundResponse(request, ctx);
}