spark.Request.ip()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(135)

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

Request.ip介绍

[英]Returns the client's IP address
[中]返回客户端的IP地址

代码示例

代码示例来源:origin: perwendel/spark

@Override
public String ip() {
  return delegate.ip();
}

代码示例来源:origin: bwssytems/ha-bridge

filledTemplate = String.format(hueTemplate, theSettings.getUpnpConfigAddress(), portNumber, theSettings.getUpnpConfigAddress(), bridgeIdMac, bridgeIdMac);
if(theSettings.isTraceupnp())
  log.info("Traceupnp: request of description.xml from: " + request.ip() + ":" + request.port() + " filled in with address: " + theSettings.getUpnpConfigAddress() + ":" + portNumber);
else
  log.debug("request of description.xml from: " + request.ip() + ":" + request.port() + " filled in with address: " + theSettings.getUpnpConfigAddress() + ":" + portNumber);

代码示例来源:origin: bwssytems/ha-bridge

log.debug("bridge settings requested from " + request.ip());
response.status(HttpStatus.SC_OK);
response.type("application/json");
log.debug("save bridge settings requested from " + request.ip() + " with body: " + request.body());
BridgeSettingsDescriptor newBridgeSettings = new Gson().fromJson(request.body(), BridgeSettingsDescriptor.class);
if(newBridgeSettings.getUpnpsenddelay() > 15000)

代码示例来源:origin: bwssytems/ha-bridge

response.type("application/json");
  response.status(HttpStatus.SC_OK);
  return groupsListHandler(request.params(":userid"),  request.ip());
} , new JsonTransformer());
  response.type("application/json");
  response.status(HttpStatus.SC_OK);
  return  groupsIdHandler(request.params(":groupid"), request.params(":userid"), request.ip());
} , new JsonTransformer());
  response.type("application/json");
  response.status(HttpStatus.SC_OK);
  return addGroup(request.params(":userid"), request.ip(), request.body());
});
  response.type("application/json");
  response.status(HttpStatus.SC_OK);
  return deleteGroup(request.params(":userid"), request.params(":groupid"), request.ip());
});
  response.type("application/json");
  response.status(HttpStatus.SC_OK);
  return modifyGroup(request.params(":userid"), request.params(":groupid"), request.ip(), request.body());
});
  response.type("application/json");
  response.status(HttpStatus.SC_OK);
  return changeGroupState(request.params(":userid"), request.params(":groupid"), request.body(), request.ip(), false);
});

代码示例来源:origin: cinchapi/concourse

@Override
public String ip() {
  return delegate.ip();
}

代码示例来源:origin: com.sparkjava/spark-core

@Override
public String ip() {
  return delegate.ip();
}

代码示例来源:origin: dessalines/torrenttunes-client

public static void allowOnlyLocalHeaders(Request req, Response res) {
  log.debug("req ip = " + req.ip());
  //		res.header("Access-Control-Allow-Origin", "http://mozilla.com");
  //		res.header("Access-Control-Allow-Origin", "null");
  //		res.header("Access-Control-Allow-Origin", "*");
  //		res.header("Access-Control-Allow-Credentials", "true");
  if (!isLocalIP(req.ip())) {
    throw new NoSuchElementException("Not a local ip, can't access");
  }
}

代码示例来源:origin: simplesteph/ec2-masterclass-sampleapp

private static String hello(Request request, Response response) throws UnknownHostException {
  StringBuilder sb = new StringBuilder();
  String myHostname = InetAddress.getLocalHost().getHostName();
  sb.append("Hello World By: ").append(myHostname).append("<br/>");
  String sourceIP = request.ip();
  sb.append("Receive Request From: ").append(sourceIP).append("<br/>");
  return sb.toString();
}

代码示例来源:origin: org.opentcs/opentcs-kernel-extension-http-services

public Object handleDeleteKernel(Request request, Response response) {
 LOG.info("Initiating kernel shutdown as requested from {}...", request.ip());
 kernelExecutor.schedule(() -> kernel.setState(Kernel.State.SHUTDOWN), 1, TimeUnit.SECONDS);
 return "";
}

代码示例来源:origin: simplesteph/ec2-masterclass-sampleapp

private static String details(Request request, Response response) throws UnknownHostException {
  StringBuilder sb = new StringBuilder();
  String myHostname = InetAddress.getLocalHost().getHostName();
  sb.append("Hello World By: ").append(myHostname).append("<br/>");
  String sourceIP = request.ip();
  sb.append("Receive Request From: ").append(sourceIP).append("<br/>");
  sb.append("Request Headers are: ").append("<br/>");
  request.headers().forEach(header -> sb.append(header).append(": ").append(request.headers(header)).append("<br/>"));
  return sb.toString();
}

代码示例来源:origin: yeriomin/token-dispenser

static long getIp(Request request) {
  String requestIp = request.headers("X-Forwarded-For");
  return ipToLong((null == requestIp || requestIp.isEmpty()) ? request.ip() : requestIp);
}

代码示例来源:origin: dessalines/torrenttunes-client

public static void logRequestInfo(Request req) {
  String origin = req.headers("Origin");
  String origin2 = req.headers("origin");
  String host = req.headers("Host");
  log.debug("request host: " + host);
  log.debug("request origin: " + origin);
  log.debug("request origin2: " + origin2);
  //		System.out.println("origin = " + origin);
  //		if (DataSources.ALLOW_ACCESS_ADDRESSES.contains(req.headers("Origin"))) {
  //			res.header("Access-Control-Allow-Origin", origin);
  //		}
  for (String header : req.headers()) {
    log.debug("request header | " + header + " : " + req.headers(header));
  }
  log.debug("request ip = " + req.ip());
  log.debug("request pathInfo = " + req.pathInfo());
  log.debug("request host = " + req.host());
  log.debug("request url = " + req.url());
}

代码示例来源:origin: CogComp/cogcomp-nlp

if (rate > 0) {
  resetServer();
  String ip = request.ip();
  int callsSofar = (Integer) clients.getOrDefault(ip, 0);
  if (callsSofar > rate) canServe = false;
if (rate > 0) {
  resetServer();
  String ip = request.ip();
  int callsSofar = (Integer) clients.getOrDefault(ip, 0);
  if (callsSofar > rate) canServe = false;
    if (rate > 0) {
      resetServer();
      String ip = request.ip();
      int callsSofar = (Integer) clients.getOrDefault(ip, 0);
      if (callsSofar > rate) canServe = false;
    if (rate > 0) {
      resetServer();
      String ip = request.ip();
      int callsSofar = (Integer) clients.getOrDefault(ip, 0);
      if (callsSofar > rate) canServe = false;

代码示例来源:origin: edu.illinois.cs.cogcomp/illinois-nlp-pipeline

if (rate > 0) {
  resetServer();
  String ip = request.ip();
  int callsSofar = (Integer) clients.getOrDefault(ip, 0);
  if (callsSofar > rate) canServe = false;
if (rate > 0) {
  resetServer();
  String ip = request.ip();
  int callsSofar = (Integer) clients.getOrDefault(ip, 0);
  if (callsSofar > rate) canServe = false;
    if (rate > 0) {
      resetServer();
      String ip = request.ip();
      int callsSofar = (Integer) clients.getOrDefault(ip, 0);
      if (callsSofar > rate) canServe = false;
    if (rate > 0) {
      resetServer();
      String ip = request.ip();
      int callsSofar = (Integer) clients.getOrDefault(ip, 0);
      if (callsSofar > rate) canServe = false;

代码示例来源:origin: CogComp/cogcomp-nlp

if(rate > 0) {
  resetServer();
  String ip = request.ip();
  int callsSofar = (Integer) clients.getOrDefault(ip, 0);
  if( callsSofar > rate ) canServe = false;
    if(rate > 0) {
      resetServer();
      String ip = request.ip();
      int callsSofar = (Integer) clients.getOrDefault(ip, 0);
      if( callsSofar > rate ) canServe = false;

代码示例来源:origin: edu.illinois.cs.cogcomp/external-commons

if(rate > 0) {
  resetServer();
  String ip = request.ip();
  int callsSofar = (Integer) clients.getOrDefault(ip, 0);
  if( callsSofar > rate ) canServe = false;
    if(rate > 0) {
      resetServer();
      String ip = request.ip();
      int callsSofar = (Integer) clients.getOrDefault(ip, 0);
      if( callsSofar > rate ) canServe = false;

代码示例来源:origin: apache/james-project

@Override
  public void handle(Request request, Response response) throws Exception {
    Closeable mdcCloseable = MDCBuilder.create()
      .addContext(MDCBuilder.IP, request.ip())
      .addContext(MDCBuilder.HOST, request.host())
      .addContext(VERB, request.requestMethod())
      .addContext(MDCBuilder.PROTOCOL, "webadmin")
      .addContext(MDCBuilder.ACTION, request.pathInfo())
      .addContext(MDCBuilder.USER, request.attribute(AuthenticationFilter.LOGIN))
      .build();
    request.attribute(MDC_CLOSEABLE, mdcCloseable);
  }
}

代码示例来源:origin: avaire/avaire

@Override
public Object handle(Request request, Response response) throws Exception {
  log.info("Vote route has been hit by {} with the body: {}",
    request.ip(), request.body()
  );

代码示例来源:origin: langurmonkey/gaiasky

logger.debug("  command = ", request.params(":cmd"));
logger.debug("* Request:");
logger.debug("  client IP = {}", request.ip());
logger.debug("  host = {}", request.host());
logger.debug("  userAgent = {}", request.userAgent());

相关文章