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

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

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

Request.setDestinationPort介绍

暂无

代码示例

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

  1. private void buildRequestSettings(final AbstractLwM2mClientRequest request) {
  2.   timeout = request.getTimeout();
  3.   coapRequest.setDestination(serverAddress.getAddress());
  4.   coapRequest.setDestinationPort(serverAddress.getPort());
  5. }

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

  1. private void buildRequestSettings(final AbstractLwM2mClientRequest request) {
  2.   timeout = request.getTimeout();
  3.   coapRequest.setDestination(serverAddress.getAddress());
  4.   coapRequest.setDestinationPort(serverAddress.getPort());
  5. }

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

  1. setDestinationPort(port);

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

  1. @Test
  2. public void testSendRequestAddsMessageCallbackToOutboundMessage() throws Exception {
  3.   // GIVEN an outbound request
  4.   latch = new CountDownLatch(1);
  5.   Request request = Request.newGet();
  6.   request.setDestination(InetAddress.getLoopbackAddress());
  7.   request.setDestinationPort(CoAP.DEFAULT_COAP_PORT);
  8.   // WHEN sending the request to the peer
  9.   endpoint.sendRequest(request);
  10.   // THEN assert that the message delivered to the Connector contains a
  11.   // MessageCallback
  12.   assertTrue(latch.await(1, TimeUnit.SECONDS));
  13. }

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

  1. @Override
  2.   public void go() {
  3.     Request request = new Request(code);
  4.     if (destination != null) {
  5.       request.setDestination(destination.getAddress());
  6.       request.setDestinationPort(destination.getPort());
  7.     }
  8.     setProperties(request);
  9.     RawData raw = serializer.serializeRequest(request);
  10.     send(raw);
  11.   }
  12. }

代码示例来源：origin: org.eclipse.leshan/leshan-server-cf

  1. postSecurity.setConfirmable(true);
  2. postSecurity.setDestination(targetAddress);
  3. postSecurity.setDestinationPort(targetPort);
  4. postSecurity.setPayload(encoded.array());

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

  1. private static Exchange sendObserveRequest(final UdpMatcher matcher) {
  2.   Request request = Request.newGet();
  3.   request.setDestination(dest.getAddress());
  4.   request.setDestinationPort(dest.getPort());
  5.   request.setObserve();
  6.   Exchange exchange = new Exchange(request, Origin.LOCAL);
  7.   matcher.sendRequest(exchange, request);
  8.   return exchange;
  9. }

代码示例来源：origin: org.eclipse.leshan/leshan-server-cf

  1. postServer.setConfirmable(true);
  2. postServer.setDestination(targetAddress);
  3. postServer.setDestinationPort(targetPort);
  4. postServer.setPayload(encoded.array());
  5. postServer.send(e).addMessageObserver(new MessageObserver() {

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

  1. private static Exchange sendRequest(final UdpMatcher matcher, final CorrelationContext ctx) {
  2.   Request request = Request.newGet();
  3.   request.setDestination(dest.getAddress());
  4.   request.setDestinationPort(dest.getPort());
  5.   Exchange exchange = new Exchange(request, Origin.LOCAL);
  6.   exchange.setRequest(request);
  7.   matcher.sendRequest(exchange, request);
  8.   exchange.setCorrelationContext(ctx);
  9.   return exchange;
  10. }

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

  1. private Exchange sendRequest(final TcpMatcher matcher, final CorrelationContext ctx) {
  2.   Request request = Request.newGet();
  3.   request.setDestination(dest.getAddress());
  4.   request.setDestinationPort(dest.getPort());
  5.   Exchange exchange = new Exchange(request, Origin.LOCAL);
  6.   exchange.setRequest(request);
  7.   matcher.sendRequest(exchange, request);
  8.   exchange.setCorrelationContext(ctx);
  9.   return exchange;
  10. }

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

  1. Request refresh = Request.newGet();
  2. refresh.setDestination(request.getDestination());
  3. refresh.setDestinationPort(request.getDestinationPort());

代码示例来源：origin: org.eclipse.leshan/leshan-server-cf

  1. private final void setTarget(Request coapRequest, Client client, LwM2mPath path) {
  2.   coapRequest.setDestination(client.getAddress());
  3.   coapRequest.setDestinationPort(client.getPort());
  4.   // root path
  5.   if (client.getRootPath() != null) {
  6.     for (String rootPath : client.getRootPath().split("/")) {
  7.       if (!StringUtils.isEmpty(rootPath)) {
  8.         coapRequest.getOptions().addUriPath(rootPath);
  9.       }
  10.     }
  11.   }
  12.   // objectId
  13.   coapRequest.getOptions().addUriPath(Integer.toString(path.getObjectId()));
  14.   // objectInstanceId
  15.   if (path.getObjectInstanceId() == null) {
  16.     if (path.getResourceId() != null) {
  17.       coapRequest.getOptions().addUriPath("0"); // default instanceId
  18.     }
  19.   } else {
  20.     coapRequest.getOptions().addUriPath(Integer.toString(path.getObjectInstanceId()));
  21.   }
  22.   // resourceId
  23.   if (path.getResourceId() != null) {
  24.     coapRequest.getOptions().addUriPath(Integer.toString(path.getResourceId()));
  25.   }
  26. }

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

  1. Request refresh = Request.newGet();
  2. refresh.setDestination(request.getDestination());
  3. refresh.setDestinationPort(request.getDestinationPort());

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

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

  1. /**
  2.  * Verifies that canceling a message that has no MID set does not throw an exception.
  3.  * 
  4.  */
  5. @Test
  6. public void testExchangeObserverToleratesUnsentMessages() {
  7.   // GIVEN a request that has no MID and has not been sent yet
  8.   UdpMatcher matcher = newMatcher(false);
  9.   Request request = Request.newGet();
  10.   request.setDestination(dest.getAddress());
  11.   request.setDestinationPort(dest.getPort());
  12.   Exchange exchange = new Exchange(request, Origin.LOCAL);
  13.   exchange.setRequest(request);
  14.   assertFalse(request.hasMID());
  15.   matcher.observe(exchange);
  16.   // WHEN the request is canceled and thus the message exchange completes
  17.   exchange.setComplete();
  18.   // THEN the matcher's exchange observer does not throw an exception
  19. }

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

  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. }

代码示例来源：origin: org.eclipse.leshan/leshan-server-cf

  1. deleteAll.setConfirmable(true);
  2. deleteAll.setDestination(exchange.getSourceAddress());
  3. deleteAll.setDestinationPort(exchange.getSourcePort());

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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