org.eclipse.californium.core.coap.Request.getCode()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(11.1k)|赞(0)|评价(0)|浏览(261)

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

Request.getCode介绍

[英]Gets the request code.
[中]获取请求代码。

代码示例

代码示例来源：origin: org.eclipse.californium/californium-core

  1. private boolean requiresBlockwise(final Request request) {
  2.   if (request.getCode() == Code.PUT || request.getCode() == Code.POST) {
  3.     return request.getPayloadSize() > max_message_size;
  4.   } else {
  5.     return false;
  6.   }
  7. }

代码示例来源：origin: eclipse/californium

  1. /**
  2.  * Gets the request code: <tt>GET</tt>, <tt>POST</tt>, <tt>PUT</tt> or
  3.  * <tt>DELETE</tt>.
  4.  * 
  5.  * @return the request code
  6.  */
  7. public Code getRequestCode() {
  8.   return exchange.getRequest().getCode();
  9. }

代码示例来源：origin: org.eclipse.californium/californium-core

  1. /**
  2.  * Gets the request code: <tt>GET</tt>, <tt>POST</tt>, <tt>PUT</tt> or
  3.  * <tt>DELETE</tt>.
  4.  * 
  5.  * @return the request code
  6.  */
  7. public Code getRequestCode() {
  8.   return exchange.getRequest().getCode();
  9. }

代码示例来源：origin: eclipse/californium

  1. private boolean requiresBlockwise(final Request request) {
  2.   boolean blockwiseRequired = false;
  3.   if (request.getCode() == Code.PUT || request.getCode() == Code.POST) {
  4.     blockwiseRequired = request.getPayloadSize() > maxMessageSize;
  5.   }
  6.   if (blockwiseRequired) {
  7.     LOGGER.log(Level.FINE, "request body [{0}/{1}] requires blockwise transfer",
  8.         new Object[]{request.getPayloadSize(), maxMessageSize});
  9.   }
  10.   return blockwiseRequired;
  11. }

代码示例来源：origin: eclipse/californium

  1. /**
  2.  * Formats a {@link Request} into a readable String representation. 
  3.  * 
  4.  * @param r the Request
  5.  * @return the pretty print
  6.  */
  7. public static String prettyPrint(Request r) {
  8.   StringBuilder sb = new StringBuilder();
  9.   sb.append("==[ CoAP Request ]=============================================").append(System.lineSeparator());
  10.   sb.append(String.format("MID    : %d", r.getMID())).append(System.lineSeparator());
  11.   sb.append(String.format("Token  : %s", r.getTokenString())).append(System.lineSeparator());
  12.   sb.append(String.format("Type   : %s", r.getType().toString())).append(System.lineSeparator());
  13.   sb.append(String.format("Method : %s", r.getCode().toString())).append(System.lineSeparator());
  14.   sb.append(String.format("Options: %s", r.getOptions().toString())).append(System.lineSeparator());
  15.   sb.append(String.format("Payload: %d Bytes", r.getPayloadSize())).append(System.lineSeparator());
  16.   if (r.getPayloadSize() > 0 && MediaTypeRegistry.isPrintable(r.getOptions().getContentFormat())) {
  17.     sb.append("---------------------------------------------------------------").append(System.lineSeparator());
  18.     sb.append(r.getPayloadString());
  19.     sb.append(System.lineSeparator());
  20.   }
  21.   sb.append("===============================================================");
  22.   return sb.toString();
  23. }

代码示例来源：origin: eclipse/californium

  1. @Override
  2.   public void handleGET(CoapExchange exchange) {
  4.     // get request to read out details
  5.     Request request = exchange.advanced().getRequest();
  6.     
  7.     StringBuilder payload = new StringBuilder();
  8.     payload.append(String.format("Type: %d (%s)\nCode: %d (%s)\nMID: %d\n",
  9.                    request.getType().value,
  10.                    request.getType(),
  11.                    request.getCode().value,
  12.                    request.getCode(),
  13.                    request.getMID()
  14.                   ));
  15.     payload.append("?").append(request.getOptions().getUriQueryString());
  16.     if (payload.length()>64) {
  17.       payload.delete(63, payload.length());
  18.       payload.append('»');
  19.     }
  20.     
  21.     // complete the request
  22.     exchange.respond(CONTENT, payload.toString(), TEXT_PLAIN);
  23.   }
  24. }

代码示例来源：origin: eclipse/californium

  1. @Override
  2.   public void handleGET(CoapExchange exchange) {
  3.     Request request = exchange.advanced().getRequest();
  4.     
  5.     String payload = String.format("Long path resource\n" +
  6.                     "Type: %d (%s)\nCode: %d (%s)\nMID: %d",
  7.                     request.getType().value,
  8.                     request.getType(),
  9.                     request.getCode().value,
  10.                     request.getCode(),
  11.                     request.getMID()
  12.                    );
  13.     
  14.     // complete the request
  15.     exchange.respond(CONTENT, payload, TEXT_PLAIN);
  16.   }
  17. }

代码示例来源：origin: eclipse/californium

  1. @Override
  2. public void handleGET(CoapExchange exchange) {
  3.   // Check: Type, Code
  4.   StringBuilder payload = new StringBuilder();
  5.   Request request = exchange.advanced().getRequest();
  6.   payload.append(String.format("Type: %d (%s)\nCode: %d (%s)\nMID: %d", 
  7.       request.getType().value, 
  8.       request.getType(), 
  9.       request.getCode().value, 
  10.       request.getCode(), 
  11.       request.getMID()));
  12.   if (request.getToken().length > 0) {
  13.     payload.append("\nToken: ");
  14.     StringBuilder tok = new StringBuilder(request.getToken()==null?"null":"");
  15.     if (request.getToken()!=null) for(byte b:request.getToken()) tok.append(String.format("%02x", b&0xff));
  16.     payload.append(tok);
  17.   }
  18.   if (payload.length() > 64) {
  19.     payload.delete(62, payload.length());
  20.     payload.append('»');
  21.   }
  22.   
  23.   // complete the request
  24.   exchange.setMaxAge(30);
  25.   exchange.respond(CONTENT, payload.toString(), TEXT_PLAIN);
  26. }

代码示例来源：origin: org.eclipse.californium/californium-core

  1. public byte[] serializeRequest(Request request) {
  2.   writer = new DatagramWriter();
  3.   Code code = request.getCode();
  4.   serializeMessage(request, code == null ? 0 : code.value);
  5.   return writer.toByteArray();
  6. }

代码示例来源：origin: org.eclipse.californium/californium-core

  1. @Override
  2. public String toString() {
  3.   String payload = getPayloadTracingString();
  4.   return String.format("%s-%-6s MID=%5d, Token=%s, OptionSet=%s, %s", getType(), getCode(), getMID(), getTokenString(), getOptions(), payload);
  5. }

代码示例来源：origin: eclipse/californium

  1. @Override
  2.   public void handleGET(CoapExchange exchange) {
  4.     // promise the client that this request will be acted upon by sending an Acknowledgement
  5.     exchange.accept();
  7.     // do the time-consuming computation
  8.     try {
  9.       Thread.sleep(1000);
  10.     } catch (InterruptedException e) {
  11.     }
  13.     // get request to read out details
  14.     Request request = exchange.advanced().getRequest();
  16.     String payload = String.format("Type: %d (%s)\nCode: %d (%s)\nMID: %d\n",
  17.                    request.getType().value,
  18.                    request.getType(),
  19.                    request.getCode().value,
  20.                    request.getCode(),
  21.                    request.getMID()
  22.                   );
  24.     // complete the request
  25.     exchange.respond(CONTENT, payload, TEXT_PLAIN);
  26.   }
  27. }

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

  1. /**
  2.  * Handle a request for device-specific functionality.
  3.  * 
  4.  * @param tenant
  5.  * @param paths
  6.  * @param exchange
  7.  */
  8. protected void handleDeviceRequest(ITenant tenant, List<String> paths, Exchange exchange) {
  9. if (paths.size() == 0) {
  10.   createAndSendResponse(ResponseCode.BAD_REQUEST, "No device token specified.", exchange);
  11. } else {
  12.   String deviceToken = paths.remove(0);
  13.   switch (exchange.getRequest().getCode()) {
  14.   case POST: {
  15.   handlePerDevicePostRequest(tenant, deviceToken, paths, exchange);
  16.   break;
  17.   }
  18.   default: {
  19.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Operation not available for device.", exchange);
  20.   }
  21.   }
  22. }
  23. }

代码示例来源：origin: eclipse/californium

  1. @Override
  2. public String toString() {
  3.   String payload = getPayloadTracingString();
  4.   return String.format("%s-%-6s MID=%5d, Token=%s, OptionSet=%s, %s", getType(), getCode(), getMID(), getTokenString(), getOptions(), payload);
  5. }

代码示例来源：origin: eclipse/californium

  1. public void check(Request request) {
  2.     assertEquals(code, request.getCode());
  3.     print("Correct code: " + code + " (" + code.value + ")");
  4.   }
  5. });

代码示例来源：origin: eclipse/leshan

  1. public CoapMessage(Request request, boolean incoming) {
  2.   this(incoming, request.getType(), request.getMID(), request.getTokenString(), request.getOptions(), request
  3.       .getPayload());
  4.   this.code = request.getCode().toString();
  5. }

代码示例来源：origin: org.github.leshan/leshan-client

  1. @Override
  2. public void deliverRequest(final Exchange exchange) {
  3.   final Request request = exchange.getRequest();
  4.   final List<String> path = request.getOptions().getUriPath();
  5.   final Code code = request.getCode();
  6.   final Resource resource = findResource(path, code);
  7.   if (resource != null) {
  8.     checkForObserveOption(exchange, resource);
  9.     // Get the executor and let it process the request
  10.     final Executor executor = resource.getExecutor();
  11.     if (executor != null) {
  12.       executor.execute(new Runnable() {
  13.         @Override
  14.         public void run() {
  15.           resource.handleRequest(exchange);
  16.         }
  17.       });
  18.     } else {
  19.       resource.handleRequest(exchange);
  20.     }
  21.   } else {
  22.     LOGGER.info("Did not find resource " + path.toString());
  23.     exchange.sendResponse(new Response(ResponseCode.NOT_FOUND));
  24.   }
  25. }

代码示例来源：origin: eclipse/californium

  1. protected final void appendRequestDetails(final Request request) {
  2.   if (request.isCanceled()) {
  3.     buffer.append("CANCELED ");
  4.   }
  5.   buffer.append(request.getType()).append(" [MID=").append(request.getMID())
  6.     .append(", T=").append(request.getTokenString()).append("], ")
  7.     .append(request.getCode()).append(", /").append(request.getOptions().getUriPathString());
  8.   appendBlockOption(1, request.getOptions().getBlock1());
  9.   appendBlockOption(2, request.getOptions().getBlock2());
  10.   appendObserveOption(request.getOptions());
  11.   appendSize1(request.getOptions());
  12.   appendEtags(request.getOptions());
  13. }

代码示例来源：origin: org.eclipse.californium/californium-core

  1. /**
  2.  * Handles any request in the given exchange. By default it responds
  3.  * with a 4.05 (Method Not Allowed). Override this method if your
  4.  * resource handler requires advanced access to the internal Exchange class. 
  5.  * Most developer should be better off with overriding the called methods
  6.  * {@link #handleGET(CoapExchange)}, {@link #handlePOST(CoapExchange)},
  7.  * {@link #handlePUT(CoapExchange)}, and {@link #handleDELETE(CoapExchange)},
  8.  * which provide a better API through the {@link CoapExchange} class.
  9.  * 
  10.  * @param exchange the exchange with the request
  11.  */
  12. @Override
  13. public void handleRequest(final Exchange exchange) {
  14.   Code code = exchange.getRequest().getCode();
  15.   switch (code) {
  16.     case GET:	handleGET(new CoapExchange(exchange, this)); break;
  17.     case POST:	handlePOST(new CoapExchange(exchange, this)); break;
  18.     case PUT:	handlePUT(new CoapExchange(exchange, this)); break;
  19.     case DELETE: handleDELETE(new CoapExchange(exchange, this)); break;
  20.   }
  21. }

代码示例来源：origin: eclipse/californium

  1. /**
  2.  * Handles any request in the given exchange. By default it responds
  3.  * with a 4.05 (Method Not Allowed). Override this method if your
  4.  * resource handler requires advanced access to the internal Exchange class. 
  5.  * Most developer should be better off with overriding the called methods
  6.  * {@link #handleGET(CoapExchange)}, {@link #handlePOST(CoapExchange)},
  7.  * {@link #handlePUT(CoapExchange)}, and {@link #handleDELETE(CoapExchange)},
  8.  * which provide a better API through the {@link CoapExchange} class.
  9.  * 
  10.  * @param exchange the exchange with the request
  11.  */
  12. @Override
  13. public void handleRequest(final Exchange exchange) {
  14.   Code code = exchange.getRequest().getCode();
  15.   switch (code) {
  16.     case GET:	handleGET(new CoapExchange(exchange, this)); break;
  17.     case POST:	handlePOST(new CoapExchange(exchange, this)); break;
  18.     case PUT:	handlePUT(new CoapExchange(exchange, this)); break;
  19.     case DELETE: handleDELETE(new CoapExchange(exchange, this)); break;
  20.   }
  21. }

代码示例来源：origin: eclipse/californium

  1. private static Request getNextRequestBlock(final Request request, final BlockwiseStatus status) {
  2.   int num = status.getCurrentNum();
  3.   int szx = status.getCurrentSzx();
  4.   Request block = new Request(request.getCode());
  5.   // do not enforce CON, since NON could make sense over SMS or similar transports
  6.   block.setType(request.getType());
  7.   block.setDestination(request.getDestination());
  8.   block.setDestinationPort(request.getDestinationPort());
  9.   // copy options
  10.   block.setOptions(new OptionSet(request.getOptions()));
  11.   // copy message observers so that a failing blockwise request also notifies observers registered with
  12.   // the original request
  13.   block.addMessageObservers(request.getMessageObservers());
  14.   int currentSize = 1 << (4 + szx);
  15.   int from = num * currentSize;
  16.   int to = Math.min((num + 1) * currentSize, request.getPayloadSize());
  17.   int length = to - from;
  18.   byte[] blockPayload = new byte[length];
  19.   System.arraycopy(request.getPayload(), from, blockPayload, 0, length);
  20.   block.setPayload(blockPayload);
  21.   boolean m = (to < request.getPayloadSize());
  22.   block.getOptions().setBlock1(szx, m, num);
  23.   status.setComplete(!m);
  24.   return block;
  25. }

内容来源于网络，如有侵权，请联系作者删除！

request

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Request类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com