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

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

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

Request.setToken介绍

暂无

代码示例

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

  1. public CC12(String serverURI) {
  2.   super(CC12.class.getSimpleName());
  3.   // create the request
  4.   Request request = new Request(Code.GET, Type.CON);
  5.   // request.requiresToken(false); // TODO
  6.   request.setToken(new byte[0]);
  7.   // set the parameters and execute the request
  8.   executeRequest(request, serverURI, RESOURCE_URI);
  9. }

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

  1. public CC11(String serverURI) {
  2.   super(CC11.class.getSimpleName());
  3.   // create the request
  4.   Request request = new Request(Code.GET, Type.CON);
  5.   request.setToken(new byte[]{(byte) 0xBE, (byte) 0xEF});
  6.   executeRequest(request, serverURI, RESOURCE_URI);
  7. }

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

  1. private static boolean ping(String address) {
  2.   try {
  3.     Request request = new Request(null);
  4.     request.setType(Type.CON);
  5.     request.setToken(new byte[0]);
  6.     request.setURI(address);
  7.     System.out.println("++++++ Sending Ping ++++++");
  8.     request.send().waitForResponse(5000);
  9.     return request.isRejected();
  10.   } catch (Exception e) {
  11.     e.printStackTrace();
  12.     return false;
  13.   }
  14. }

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

  1. /**
  2.  * Performs a CoAP ping and gives up after the given number of milliseconds.
  3.  * 
  4.  * @param timeout the time to wait for a pong in ms
  5.  * @return success of the ping
  6.  */
  7. public boolean ping(long timeout) {
  8.   try {
  9.     Request request = new Request(null, Type.CON);
  10.     request.setToken(new byte[0]);
  11.     request.setURI(uri);
  12.     send(request).waitForResponse(timeout);
  13.     return request.isRejected();
  14.   } catch (InterruptedException e) {
  15.     // waiting was interrupted, which is fine
  16.   }
  17.   return false;
  18. }

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

  1. /**
  2.  * Performs a CoAP ping and gives up after the given number of milliseconds.
  3.  * 
  4.  * @param timeout the time to wait for a pong in ms
  5.  * @return success of the ping
  6.  */
  7. public boolean ping(long timeout) {
  8.   try {
  9.     Request request = new Request(null, Type.CON);
  10.     request.setToken(new byte[0]);
  11.     request.setURI(uri);
  12.     send(request).waitForResponse(timeout);
  13.     return request.isRejected();
  14.   } catch (InterruptedException e) {
  15.     // waiting was interrupted, which is fine
  16.   }
  17.   return false;
  18. }

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

  1. } while (exchangesByToken.get(idByToken) != null);
  2. request.setToken(token);

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

  1. Request deregister = Request.newGet();
  2. deregister.setURI(uri);
  3. deregister.setToken(request.getToken());
  4. deregister.setObserveCancel();
  5. request = deregister;

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

  1. private void registerWithToken(final Exchange exchange) {
  2.   Request request = exchange.getCurrentRequest();
  3.   KeyToken idByToken;
  4.   if (request.getToken() == null) {
  5.     idByToken = tokenProvider.getUnusedToken(request);
  6.     request.setToken(idByToken.getToken());
  7.   } else {
  8.     idByToken = KeyToken.fromOutboundMessage(request);
  9.     // ongoing requests may reuse token
  10.     if (!(exchange.getFailedTransmissionCount() > 0 || request.getOptions().hasBlock1()
  11.         || request.getOptions().hasBlock2() || request.getOptions().hasObserve())
  12.         && tokenProvider.isTokenInUse(idByToken)) {
  13.       LOGGER.log(Level.WARNING, "Manual token overrides existing open request: {0}", idByToken);
  14.     }
  15.   }
  16.   exchangesByToken.put(idByToken, exchange);
  17. }

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

  1. Request reregister = Request.newGet();
  2. reregister.setURI(uri);
  3. reregister.setToken(request.getToken());
  4. reregister.setObserve();
  5. request = reregister;

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

  1. System.out.println("---------------\nGET /test w/o Token\n---------------");
  2. req12.setToken(new byte[0]);
  3. response = client.advanced(req12);
  4. System.out.println(response.advanced().getType() + "-" + response.getCode());

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

  1. refresh.setDestinationPort(request.getDestinationPort());
  2. refresh.setToken(request.getToken());

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

  1. refresh.setDestinationPort(request.getDestinationPort());
  2. refresh.setToken(request.getToken());

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

  1. /**
  2.  * Verifies that the getByteArray() method does not set the Message's <em>bytes</em> property.
  3.  */
  4. @Test
  5. public void testGetByteArrayDoesNotAlterMessage() {
  6.   // GIVEN a CoAP request
  7.   Request req = Request.newGet();
  8.   req.setToken(new byte[]{0x00});
  9.   req.getOptions().setObserve(0);
  10.   req.setDestination(InetAddress.getLoopbackAddress());
  11.   // WHEN serializing the request to a byte array
  12.   serializer.getByteArray(req);
  13.   // THEN the serialized byte array is not written to the request's bytes property
  14.   assertNull(req.getBytes());
  15. }

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

  1. /**
  2.  * Send request with option "cancel observe" (GET with Observe=1).
  3.  */
  4. private void sendCancelObserve() {
  5.   Request request = this.request;
  6.   Request cancel = Request.newGet();
  7.   cancel.setDestination(request.getDestination());
  8.   cancel.setDestinationPort(request.getDestinationPort());
  9.   // use same Token
  10.   cancel.setToken(request.getToken());
  11.   // copy options, but set Observe to cancel
  12.   cancel.setOptions(request.getOptions());
  13.   cancel.setObserveCancel();
  14.   // dispatch final response to the same message observers
  15.   for (MessageObserver mo : request.getMessageObservers()) {
  16.     cancel.addMessageObserver(mo);
  17.   }
  18.   endpoint.sendRequest(cancel);
  19. }

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

  1. /**
  2.    * Verifies that the serializeRequest() method sets the Message's <em>bytes</em> property.
  3.    */
  4.   @Test
  5.   public void testSerializeRequestStoresBytesInMessage() {
  7.     // GIVEN a CoAP request
  8.     Request req = Request.newGet();
  9.     req.setToken(new byte[]{0x00});
  10.     req.getOptions().setObserve(0);
  11.     req.setDestination(InetAddress.getLoopbackAddress());
  13.     // WHEN serializing the request to a RawData object
  14.     RawData raw = serializer.serializeRequest(req);
  16.     // THEN the serialized byte array is stored in the request's bytes property
  17.     assertNotNull(req.getBytes());
  18.     assertThat(raw.getBytes(), is(req.getBytes()));
  19.   }
  20. }

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

  1. /**
  2.  * Send request with option "cancel observe" (GET with Observe=1).
  3.  */
  4. private void sendCancelObserve() {
  5.   Request request = this.request;
  6.   Request cancel = Request.newGet();
  7.   cancel.setDestination(request.getDestination());
  8.   cancel.setDestinationPort(request.getDestinationPort());
  9.   // use same Token
  10.   cancel.setToken(request.getToken());
  11.   // copy options, but set Observe to cancel
  12.   cancel.setOptions(request.getOptions());
  13.   cancel.setObserveCancel();
  14.   
  15.   // dispatch final response to the same message observers
  16.   for (MessageObserver mo: request.getMessageObservers()) {
  17.     cancel.addMessageObserver(mo);
  18.   }
  19.   
  20.   endpoint.sendRequest(cancel);
  21. }

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

  1. private void sendNextBlock(final Exchange exchange, final Response response, final BlockOption block1, final BlockwiseStatus requestStatus) {
  2.   // Send next block
  3.   int currentSize = 1 << (4 + requestStatus.getCurrentSzx());
  4.   // Define new size of the block depending of preferred size block
  5.   int newSize, newSzx;
  6.   if (block1.getSize() < currentSize) {
  7.     newSize = block1.getSize();
  8.     newSzx = block1.getSzx();
  9.   } else {
  10.     newSize = currentSize;
  11.     newSzx = requestStatus.getCurrentSzx();
  12.   }
  13.   int nextNum = requestStatus.getCurrentNum() + currentSize / newSize;
  14.   LOGGER.log(Level.FINER, "Sending next Block1 num={0}", nextNum);
  15.   requestStatus.setCurrentNum(nextNum);
  16.   requestStatus.setCurrentSzx(newSzx);
  17.   Request nextBlock = getNextRequestBlock(exchange.getRequest(), requestStatus);
  18.   // indicate overall body size to peer
  19.   nextBlock.getOptions().setSize1(exchange.getRequest().getPayloadSize());
  20.   // we use the same token to ease traceability
  21.   nextBlock.setToken(response.getToken());
  22.   exchange.setCurrentRequest(nextBlock);
  23.   lower().sendRequest(exchange, nextBlock);
  24.   // do not deliver response
  25. }

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

  1. if (!response.getOptions().hasObserve()) block.setToken(response.getToken());

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

  1. Request nextBlock = getNextRequestBlock(exchange.getRequest(), status);
  2. nextBlock.setToken(response.getToken());
  3.   if (!response.getOptions().hasObserve()) block.setToken(response.getToken());

代码示例来源：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.   }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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