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

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

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

Request.getDestination介绍

暂无

代码示例

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

  1. @Override
  2. public void sendRequest(Request request) {
  3.   LOGGER.log(Level.INFO, "{0}:{1} <== req {2}", new Object[]{request.getDestination(), request.getDestinationPort(), request});
  4. }

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

  1. private void assignClientUriIfEmpty(Request request) {
  2.   // request.getUri() is a computed getter and never returns null so checking destination
  3.   if (request.getDestination() == null) {
  4.     request.setURI(uri);
  5.   }
  6. }

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

  1. /**
  2.  * Validate before sending that there is a destination set.
  3.  */
  4. private void validateBeforeSending() {
  5.   if (getDestination() == null)
  6.     throw new NullPointerException("Destination is null");
  7.   if (getDestinationPort() == 0)
  8.     throw new NullPointerException("Destination port is 0");
  9. }

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

  1. /**
  2.  * Validate before sending that there is a destination set.
  3.  */
  4. private void validateBeforeSending() {
  5.   if (getDestination() == null)
  6.     throw new NullPointerException("Destination is null");
  7.   if (getDestinationPort() == 0)
  8.     throw new NullPointerException("Destination port is 0");
  9. }

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

  1. @Override
  2. public void sendRequest(Request request) {
  3.   LOGGER.info(String.format("%s:%d <== req %s", request.getDestination(), request.getDestinationPort(), request));
  4. }

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

  1. /**
  2.  * Serializes the specified request. Message identifier, message code,
  3.  * token, options and payload are converted into a byte array and wrapped in
  4.  * a {@link RawData} object. The request's destination address and port are
  5.  * stored as address and port in the RawData object.
  6.  * 
  7.  * @param request
  8.  *            the request
  9.  * @return the request as raw data
  10.  */
  11. public RawData serialize(Request request) {
  12.   byte[] bytes = request.getBytes();
  13.   if (bytes == null)
  14.     bytes = new DataSerializer().serializeRequest(request);
  15.   request.setBytes(bytes);
  16.   return new RawData(bytes, request.getDestination(), request.getDestinationPort());
  17. }

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

  1. /**
  2.  * Serializes a request and caches the result on the request object to skip future serializations.
  3.  * <p>
  4.  * NB: The byte array cached in the message is encoded according to the specific serializer implementation's
  5.  * supported wire format. Any subsequent invocation of this method with the same request object will therefore
  6.  * simply return the cached byte array. This may cause problems when the first invocation was done on a different
  7.  * type of serializer than the second.
  8.  * <p>
  9.  * Clients should use the {@link #getByteArray(Request)} method in order to prevent caching of the resulting
  10.  * byte array.
  11.  * 
  12.  * @param request The request to serialize.
  13.  * @param outboundCallback The callback to invoke once the message's correlation context
  14.  *                         has been established. 
  15.  * @return The object containing the serialized request and the callback.
  16.  */
  17. public final RawData serializeRequest(final Request request, final MessageCallback outboundCallback) {
  18.   if (request.getBytes() == null) {
  19.     request.setBytes(getByteArray(request));
  20.   }
  21.   return RawData.outbound(
  22.           request.getBytes(),
  23.           new InetSocketAddress(request.getDestination(),
  24.           request.getDestinationPort()),
  25.           outboundCallback,
  26.           false);
  27. }

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

  1. /**
  2.  * Returns the endpoint responsible for the given exchange.
  3.  * @param exchange the exchange
  4.  * @return the endpoint for the exchange
  5.  */
  6. public RemoteEndpoint getRemoteEndpoint(Exchange exchange){ //int remotePort, InetAddress remoteAddress){
  7.   
  8.   InetAddress remoteAddress = exchange.getRequest().getDestination();
  9.   int remotePort = exchange.getRequest().getDestinationPort();
  10.   
  11.   // TODO: One IP-Address is considered to be a destination endpoint, for higher granularity (portnumber) changes are necessary
  12.   if (!remoteEndpointsList.containsKey(remoteAddress)){
  13.     RemoteEndpoint unusedRemoteEndpoint = new RemoteEndpoint(remotePort, remoteAddress, config);
  14.     remoteEndpointsList.put(remoteAddress,unusedRemoteEndpoint);
  15.     
  16.     //System.out.println("Number of RemoteEndpoint objects stored:" + remoteEndpointsList.size());
  17.   }
  18.   
  19.   return remoteEndpointsList.get(remoteAddress);
  20. }

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

  1. /**
  2.  * Returns the endpoint responsible for the given exchange.
  3.  * @param exchange the exchange
  4.  * @return the endpoint for the exchange
  5.  */
  6. public RemoteEndpoint getRemoteEndpoint(Exchange exchange){ //int remotePort, InetAddress remoteAddress){
  7.   
  8.   InetAddress remoteAddress = exchange.getRequest().getDestination();
  9.   int remotePort = exchange.getRequest().getDestinationPort();
  10.   
  11.   // TODO: One IP-Address is considered to be a destination endpoint, for higher granularity (portnumber) changes are necessary
  12.   if (!remoteEndpointsList.containsKey(remoteAddress)){
  13.     RemoteEndpoint unusedRemoteEndpoint = new RemoteEndpoint(remotePort, remoteAddress, config);
  14.     remoteEndpointsList.put(remoteAddress,unusedRemoteEndpoint);
  15.     
  16.     //System.out.println("Number of RemoteEndpoint objects stored:" + remoteEndpointsList.size());
  17.   }
  18.   
  19.   return remoteEndpointsList.get(remoteAddress);
  20. }

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

  1. @Override
  2. public void sendRequest(Exchange exchange, Request request) {
  3.   if (request.getDestination() == null)
  4.     throw new NullPointerException("Request has no destination address");
  5.   if (request.getDestinationPort() == 0)

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

  1. @Test
  2. public void testSetURISetsDestination() {
  3.   InetSocketAddress dest = InetSocketAddress.createUnresolved("192.168.0.1", 12000);
  4.   Request req = Request.newGet().setURI("coap://192.168.0.1:12000");
  5.   assertThat(req.getDestination().getHostAddress(), is(dest.getHostString()));
  6.   assertThat(req.getDestinationPort(), is(dest.getPort()));
  7. }

代码示例来源：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: 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. @Test
  2. public void testSetURISetsUriHostOptionToHostName() {
  3.   assumeTrue(dnsIsWorking());
  4.   Request req = Request.newGet().setURI("coaps://localhost");
  5.   assertNotNull(req.getDestination());
  6.   assertThat(req.getDestinationPort(), is(CoAP.DEFAULT_COAP_SECURE_PORT));
  7.   assertThat(req.getOptions().getUriHost(), is("localhost"));
  8. }

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

  1. refresh.setDestination(request.getDestination());
  2. refresh.setDestinationPort(request.getDestinationPort());

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

  1. Level.WARNING,
  2.       "exchange observer has been completed on unregistered exchange [peer: {0}:{1}, origin: {2}]",
  3.       new Object[]{ originRequest.getDestination(), originRequest.getDestinationPort(),
  4.           exchange.getOrigin()});
  5. } else {

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