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

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

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

Request.getMID介绍

暂无

代码示例

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

  1. @Override
  2. public void sendRequest(final Exchange exchange, final Request request) {
  3.   observe(exchange);
  4.   exchangeStore.registerOutboundRequest(exchange);
  5.   if (LOGGER.isLoggable(Level.FINER)) {
  6.     LOGGER.log(
  7.         Level.FINER,
  8.         "Tracking open request [MID: {0}, Token: {1}]",
  9.         new Object[] { request.getMID(), request.getTokenString() });
  10.   }
  11. }

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

  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 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 onCancel() {
  3.     if (!exchange.isComplete()) {
  4.       LOGGER.log(Level.FINE, "completing canceled request [MID={0}, token={1}]",
  5.           new Object[]{ exchange.getRequest().getMID(), exchange.getRequest().getTokenString() });
  6.       exchange.setComplete();
  7.     }
  8.   }
  9. }

代码示例来源：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. protected boolean checkResponse(Request request, Response response) {
  2.     boolean success = true;
  4.     success &= checkType(Type.ACK, response.getType());
  5.     success &= checkInt(EXPECTED_RESPONSE_CODE.value,
  6.         response.getCode().value, "code");
  7.     success &= checkInt(request.getMID(), response.getMID(), "MID");
  9.     return success;
  10.   }
  11. }

代码示例来源：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. protected boolean checkResponse(Request request, Response response) {
  2.     boolean success = true;
  4.     success &= checkType(Type.ACK, response.getType());
  5.     // Code = 65(2.01 Created) or 68 (2.04 changed)
  6.     success &= checkInts(expectedResponseCodes,
  7.         response.getCode().value, "code");
  8.     success &= checkInt(request.getMID(), response.getMID(), "MID");
  10.     return success;
  11.   }
  12. }

代码示例来源：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: eclipse/californium

  1. protected boolean checkResponse(Request request, Response response) {
  2.     boolean success = true;
  4.     success &= checkType(Type.ACK, response.getType());
  5.     // Code = 68 (2.04 Changed) or 65 (2.01 Created)
  6.     success &= checkInts(expectedResponseCodes,
  7.         response.getCode().value, "code");
  8.     success &= checkInt(request.getMID(), response.getMID(), "MID");
  10.     return success;
  11.   }
  12. }

代码示例来源：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: eclipse/californium

  1. protected boolean checkResponse(Request request, Response response) {
  2.     boolean success = true;
  4.     success &= checkType(Type.ACK, response.getType());
  5.     success &= checkInt(EXPECTED_RESPONSE_CODE.value,
  6.         response.getCode().value, "code");
  7.     success &= checkInt(request.getMID(), response.getMID(), "MID");
  8.     success &= hasContentType(response);
  9.     success &= hasNonEmptyPalyoad(response);
  11.     return success;
  12.   }
  13. }

代码示例来源：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: eclipse/californium

  1. /**
  2.  * Serializes a request to the wire format.
  3.  * <p>
  4.  * The main difference between this and the <em>serializeRequest</em> method is that this method
  5.  * does <em>not</em> cache the byte array in the request's <em>bytes</em> property.
  6.  * 
  7.  * @param request The request to serialize.
  8.  * @return The encoded request.
  9.  */
  10. public final byte[] getByteArray(final Request request) {
  11.   DatagramWriter writer = new DatagramWriter();
  12.   byte[] body = serializeOptionsAndPayload(request);
  13.   MessageHeader header = new MessageHeader(CoAP.VERSION, request.getType(), request.getToken(),
  14.       request.getRawCode(), request.getMID(), body.length);
  15.   serializeHeader(writer, header);
  16.   writer.writeBytes(body);
  17.   return writer.toByteArray();
  18. }

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

  1. @Test
  2. public void testRegisterOutboundRequestAssignsMid() {
  3.   Exchange exchange = newOutboundRequest();
  4.   // WHEN registering the outbound request
  5.   store.registerOutboundRequest(exchange);
  6.   // THEN the request gets assigned an MID and is put to the store
  7.   assertNotNull(exchange.getCurrentRequest().getMID());
  8.   KeyMID key = KeyMID.fromOutboundMessage(exchange.getCurrentRequest());
  9.   assertThat(store.get(key), is(exchange));
  10. }

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

  1. @Test
  2. public void testRegisterOutboundRequestRejectsOtherRequestWithAlreadyUsedMid() {
  3.   Exchange exchange = newOutboundRequest();
  4.   store.registerOutboundRequest(exchange);
  5.   // WHEN registering another request with the same MID
  6.   Exchange newExchange = newOutboundRequest();
  7.   newExchange.getCurrentRequest().setMID(exchange.getCurrentRequest().getMID());
  8.   try {
  9.     store.registerOutboundRequest(newExchange);
  10.     fail("should have thrown IllegalArgumentException");
  11.   } catch (IllegalArgumentException e) {
  12.     // THEN the newExchange is not put to the store
  13.     KeyMID key = KeyMID.fromOutboundMessage(exchange.getCurrentRequest());
  14.     Exchange exchangeFromStore = store.get(key);
  15.     assertThat(exchangeFromStore, is(exchange));
  16.     assertThat(exchangeFromStore, is(not(newExchange)));
  17.   }
  18. }

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

  1. @Test public void testRequestParsing() {
  2.     Request request = new Request(Code.POST);
  3.     request.setType(Type.NON);
  4.     request.setMID(expectedMid);
  5.     request.setToken(new byte[] { 11, 82, -91, 77, 3 });
  6.     request.getOptions().addIfMatch(new byte[] { 34, -17 }).addIfMatch(new byte[] { 88, 12, -2, -99, 5 })
  7.         .setContentFormat(40).setAccept(40);
  9.     RawData rawData = serializer.serializeRequest(request);
  10. //        MessageHeader header = parser.parseHeader(rawData);
  11. //        assertTrue(CoAP.isRequest(header.getCode()));
  12. //
  13. //        Request result = parser.parseRequest(rawData);
  14.     Request result = (Request) parser.parseMessage(rawData);
  15.     assertEquals(request.getMID(), result.getMID());
  16.     assertArrayEquals(request.getToken(), result.getToken());
  17.     assertEquals(request.getOptions().asSortedList(), result.getOptions().asSortedList());
  18.   }

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

  1. private static Response responseFor(final Request request) {
  2.     Response response = new Response(ResponseCode.CONTENT);
  3.     response.setMID(request.getMID());
  4.     response.setToken(request.getToken());
  5.     response.setBytes(new byte[]{});
  6.     response.setSource(request.getDestination());
  7.     response.setSourcePort(request.getDestinationPort());
  8.     response.setDestination(request.getSource());
  9.     response.setDestinationPort(request.getSourcePort());
  10.     return response;
  11.   }
  12. }

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

  1. private Response responseFor(final Request request) {
  2.     Response response = new Response(ResponseCode.CONTENT);
  3.     response.setMID(request.getMID());
  4.     response.setToken(request.getToken());
  5.     response.setBytes(new byte[]{});
  6.     response.setSource(request.getDestination());
  7.     response.setSourcePort(request.getDestinationPort());
  8.     response.setDestination(request.getSource());
  9.     response.setDestinationPort(request.getSourcePort());
  10.     return response;
  11.   }
  12. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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