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

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

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

Request.waitForResponse介绍

[英]Wait for the response. This function blocks until there is a response or the request has been canceled.
[中]等待回应。此功能会一直阻止，直到有响应或请求被取消。

代码示例

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

  1. /**
  2.  * Wait for the response. This function blocks until there is a response or
  3.  * the request has been canceled.
  4.  * 
  5.  * @return the response
  6.  * @throws InterruptedException
  7.  *             the interrupted exception
  8.  */
  9. public Response waitForResponse() throws InterruptedException {
  10.   return waitForResponse(0);
  11. }

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

  1. /**
  2.  * Wait for the response. This function blocks until there is a response or
  3.  * the request has been canceled.
  4.  * 
  5.  * @return the response
  6.  * @throws InterruptedException
  7.  *             the interrupted exception
  8.  */
  9. public Response waitForResponse() throws InterruptedException {
  10.   return waitForResponse(0);
  11. }

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

  1. public static void selfTest() {
  2.     try {
  3.       Request request = Request.newGet();
  4.       request.setURI("localhost:5683/benchmark");
  5.       request.send();
  6.       Response response = request.waitForResponse(1000);
  7.       System.out.println("received "+response);
  8.     } catch (Exception e) {
  9.       e.printStackTrace();
  10.     }
  11.   }
  12. }

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

  1. private CoapResponse synchronous(Request request, Endpoint outEndpoint) {
  2.   try {
  3.     Response response = send(request, outEndpoint).waitForResponse(getTimeout());
  4.     if (response == null) return null;
  5.     else return new CoapResponse(response);
  6.   } catch (InterruptedException e) {
  7.     throw new RuntimeException(e);
  8.   }
  9. }

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

  1. private CoapResponse synchronous(Request request, Endpoint outEndpoint) {
  2.   try {
  3.     Response response = send(request, outEndpoint).waitForResponse(getTimeout());
  4.     if (response == null) {
  5.       // Cancel request so appropriate clean up can happen.
  6.       request.cancel();
  7.       return null;
  8.     } else {
  9.       return new CoapResponse(response);
  10.     }
  11.   } catch (InterruptedException e) {
  12.     throw new RuntimeException(e);
  13.   }
  14. }

代码示例来源：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. Response incomingResponse = outgoingRequest.waitForResponse(timeout);

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

  1. private void sendRequestAndExpect(String expected) throws Exception {
  2.   System.out.println();
  3.   Thread.sleep(100);
  4.   Request request = Request.newGet();
  5.   request.setURI("localhost:"+serverPort+"/res");
  6.   String response = request.send().waitForResponse(1000).getPayloadString();
  7.   Assert.assertEquals(expected, response);
  8. }

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

  1. /**
  2.  * Verifies that the server cleans up all exchanges after serving a NON GET.
  3.  * 
  4.  * @throws Exception if the test fails.
  5.  */
  6. @Test
  7. public void testSimpleNONGet() throws Exception {
  8.   String uri = uriOf(URI);
  9.   LOGGER.log(Level.FINE, "Test simple NON GET to {0}", uri);
  10.   String currentResponseText = "simple NON GET";
  11.   resource.setResponse(currentResponseText, Mode.PIGGY_BACKED_RESPONSE);
  12.   Request request = Request.newGet();
  13.   request.setURI(uri);
  14.   request.setType(Type.NON);
  15.   Response response = request.send(clientEndpoint).waitForResponse(ACK_TIMEOUT);
  16.   assertThat("Client did not receive response to NON request in time", response, is(notNullValue()));
  17.   LOGGER.log(Level.FINE, "Client received response [{0}] with msg type [{1}]", new Object[]{response.getPayloadString(), response.getType()});
  18.   assertThat(response.getPayloadString(), is(currentResponseText));
  19.   assertThat(response.getType(), is(Type.NON));
  20. }

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

  1. @Test
  2. public void testNonconfirmable() throws Exception {
  3.   createSimpleServer();
  4.   // send request
  5.   Request request = new Request(CoAP.Code.POST);
  6.   request.setConfirmable(false);
  7.   request.setDestination(InetAddress.getLoopbackAddress());
  8.   request.setDestinationPort(serverPort);
  9.   request.setPayload("client says hi");
  10.   request.send();
  11.   System.out.println("client sent request");
  12.   // receive response and check
  13.   Response response = request.waitForResponse(1000);
  14.   assertNotNull("Client received no response", response);
  15.   System.out.println("client received response");
  16.   assertEquals(response.getPayloadString(), SERVER_RESPONSE);
  17. }

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

  1. String resp1 = Request.newGet().setURI(base+NAME_1).send().waitForResponse(1000).getPayloadString();
  2. Assert.assertEquals(PAYLOAD, resp1);
  3. String resp2 = Request.newGet().setURI(base+NAME_1+"/"+CHILD).send().waitForResponse(1000).getPayloadString();
  4. Assert.assertEquals(CHILD_PAYLOAD, resp2);
  5. String resp3 = Request.newGet().setURI(base+NAME_2).send().waitForResponse(1000).getPayloadString();
  6. Assert.assertEquals(PAYLOAD, resp3);
  7. String resp4 = Request.newGet().setURI(base+NAME_2+"/"+CHILD).send().waitForResponse(1000).getPayloadString();
  8. Assert.assertEquals(CHILD_PAYLOAD, resp4);
  9. ResponseCode code1 = Request.newGet().setURI(base+NAME_1).send().waitForResponse(1000).getCode();
  10. Assert.assertEquals(ResponseCode.NOT_FOUND, code1);
  11. ResponseCode code2 = Request.newGet().setURI(base+NAME_1+"/"+CHILD).send().waitForResponse(1000).getCode();
  12. Assert.assertEquals(ResponseCode.NOT_FOUND, code2);

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

  1. private void executePOSTRequest(final boolean shortRequest, final boolean respondShort) throws Exception {
  2.   String payload = "--no payload--";
  3.   try {
  4.     interceptor.clear();
  5.     Request request = Request.newPost().setURI(getUri(serverEndpoint, RESOURCE_TEST));
  6.     if (shortRequest) {
  7.       request.setPayload(SHORT_POST_REQUEST);
  8.       request.getOptions().addUriQuery(PARAM_SHORT_REQ);
  9.     } else {
  10.       request.setPayload(LONG_POST_REQUEST);
  11.     }
  12.     if (respondShort) {
  13.       request.getOptions().addUriQuery(PARAM_SHORT_RESP);
  14.     }
  15.     clientEndpoint.sendRequest(request);
  16.     // receive response and check
  17.     Response response = request.waitForResponse(2000);
  18.     assertNotNull("Client received no response", response);
  19.     payload = response.getPayloadString();
  20.     if (respondShort) {
  21.       assertEquals(SHORT_POST_RESPONSE, payload);
  22.     } else {
  23.       assertEquals(LONG_POST_RESPONSE, payload);
  24.     }
  25.   } finally {
  26.     Thread.sleep(100); // Quickly wait until last ACKs arrive
  27.     System.out.println("Client received payload [" + payload + "]" + System.lineSeparator()
  28.       + interceptor.toString() + System.lineSeparator());
  29.   }
  30. }

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

  1. @Test
  2. public void testConfirmable() throws Exception {
  3.   // send request
  4.   Request req2acc = new Request(Code.POST);
  5.   req2acc.setConfirmable(true);
  6.   req2acc.setURI(getUri(ACC_RESOURCE));
  7.   req2acc.setPayload("client says hi");
  8.   req2acc.send();
  9.   // receive response and check
  10.   Response response = req2acc.waitForResponse(1000);
  11.   assertPayloadIsOfCorrectType(response, SERVER_RESPONSE, Type.CON);
  12.   Request req2noacc = new Request(Code.POST);
  13.   req2noacc.setConfirmable(true);
  14.   req2noacc.setURI(getUri(NO_ACC_RESOURCE));
  15.   req2noacc.setPayload("client says hi");
  16.   req2noacc.send();
  17.   // receive response and check
  18.   response = req2noacc.waitForResponse(1000);
  19.   assertPayloadIsOfCorrectType(response, SERVER_RESPONSE, Type.ACK);
  20. }

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

  1. @Test
  2. public void testNonConfirmable() throws Exception {
  3.   // send request
  4.   Request req2acc = new Request(Code.POST);
  5.   req2acc.setConfirmable(false);
  6.   req2acc.setURI(getUri(ACC_RESOURCE));
  7.   req2acc.setPayload("client says hi");
  8.   req2acc.send();
  9.   // receive response and check
  10.   Response response = req2acc.waitForResponse(1000);
  11.   assertPayloadIsOfCorrectType(response, SERVER_RESPONSE, Type.NON);
  12.   Request req2noacc = new Request(Code.POST);
  13.   req2noacc.setConfirmable(false);
  14.   req2noacc.setURI(getUri(NO_ACC_RESOURCE));
  15.   req2noacc.setPayload("client says hi");
  16.   req2noacc.send();
  17.   // receive response and check
  18.   response = req2noacc.waitForResponse(1000);
  19.   assertPayloadIsOfCorrectType(response, SERVER_RESPONSE, Type.NON);
  20. }

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

  1. request.getOptions().setBlock2(szx, false, num);
  2. Response response = request.send().waitForResponse(1000);
  3. Assert.assertNotNull("Client received no response", response);
  4. Assert.assertEquals(expectations[i], response.getPayloadString());

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

  1. server.sendResponse(ACK, CONTENT).loadBoth("C").block2(2, false, 128).payload(respPayload.substring(256, 300)).go();
  2. Response response = request.waitForResponse(1000);
  3. assertResponseContainsExpectedPayload(response, respPayload);

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

  1. server.expectEmpty(ACK, mid).go();
  2. Response response = request.waitForResponse(1000);
  3. printServerLog(clientInterceptor);
  4. server.expectEmpty(ACK, mid).go();
  5. response = request.waitForResponse(1000);
  6. printServerLog(clientInterceptor);

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

  1. server.sendResponse(ACK, CONTENT).loadBoth("B").payload("possible conflict").go();
  2. Response response = request.waitForResponse(500);
  3. assertResponseContainsExpectedPayload(response, CONTENT, payload);
  4. response = request.waitForResponse(500);
  5. assertNull("Client received duplicate", response);

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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