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

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

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

Request.getPayload介绍

暂无

代码示例

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

  1. /**
  2.  * Gets the request payload as byte array.
  3.  *
  4.  * @return the request payload
  5.  */
  6. public byte[] getRequestPayload() {
  7.   return exchange.getRequest().getPayload();
  8. }

代码示例来源：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.  * Gets the request payload as byte array.
  3.  *
  4.  * @return the request payload
  5.  */
  6. public byte[] getRequestPayload() {
  7.   return exchange.getRequest().getPayload();
  8. }

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

  1. /**
  2.  * Handle device registration request.
  3.  * 
  4.  * @param tenant
  5.  * @param deviceToken
  6.  * @param exchange
  7.  */
  8. protected void handleDeviceRegistration(ITenant tenant, String deviceToken, Exchange exchange) {
  9. Map<String, Object> metadata = new HashMap<String, Object>();
  10. metadata.put(CoapJsonDecoder.META_EVENT_TYPE, Type.RegisterDevice.name());
  11. metadata.put(CoapJsonDecoder.META_DEVICE_TOKEN, deviceToken);
  12. getEventReceiver().onEventPayloadReceived(exchange.getRequest().getPayload(), metadata);
  13. createAndSendResponse(ResponseCode.CONTENT, "Device registration submitted successfully.", exchange);
  14. }

代码示例来源：origin: sitewhere/sitewhere

  1. /**
  2.  * Handle add device measurement.
  3.  * 
  4.  * @param tenant
  5.  * @param deviceToken
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleAddDeviceMeasurement(ITenant tenant, String deviceToken, List<String> paths,
  10.   Exchange exchange) {
  11. Map<String, Object> metadata = new HashMap<String, Object>();
  12. metadata.put(CoapJsonDecoder.META_EVENT_TYPE, Type.DeviceMeasurement.name());
  13. metadata.put(CoapJsonDecoder.META_DEVICE_TOKEN, deviceToken);
  14. getEventReceiver().onEventPayloadReceived(exchange.getRequest().getPayload(), metadata);
  15. createAndSendResponse(ResponseCode.CONTENT, "Device measurement submitted successfully.", exchange);
  16. }

代码示例来源：origin: sitewhere/sitewhere

  1. /**
  2.  * Handle add device alert.
  3.  * 
  4.  * @param tenant
  5.  * @param deviceToken
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleAddDeviceAlert(ITenant tenant, String deviceToken, List<String> paths, Exchange exchange) {
  10. Map<String, Object> metadata = new HashMap<String, Object>();
  11. metadata.put(CoapJsonDecoder.META_EVENT_TYPE, Type.DeviceAlert.name());
  12. metadata.put(CoapJsonDecoder.META_DEVICE_TOKEN, deviceToken);
  13. getEventReceiver().onEventPayloadReceived(exchange.getRequest().getPayload(), metadata);
  14. createAndSendResponse(ResponseCode.CONTENT, "Device alert submitted successfully.", exchange);
  15. }

代码示例来源：origin: sitewhere/sitewhere

  1. /**
  2.  * Handle add device location.
  3.  * 
  4.  * @param tenant
  5.  * @param deviceToken
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleAddDeviceLocation(ITenant tenant, String deviceToken, List<String> paths, Exchange exchange) {
  10. Map<String, Object> metadata = new HashMap<String, Object>();
  11. metadata.put(CoapJsonDecoder.META_EVENT_TYPE, Type.DeviceLocation.name());
  12. metadata.put(CoapJsonDecoder.META_DEVICE_TOKEN, deviceToken);
  13. getEventReceiver().onEventPayloadReceived(exchange.getRequest().getPayload(), metadata);
  14. createAndSendResponse(ResponseCode.CONTENT, "Device location submitted successfully.", exchange);
  15. }

代码示例来源：origin: sitewhere/sitewhere

  1. /**
  2.  * Handle add device acknowledgement.
  3.  * 
  4.  * @param tenant
  5.  * @param deviceToken
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleAddDeviceAck(ITenant tenant, String deviceToken, List<String> paths, Exchange exchange) {
  10. Map<String, Object> metadata = new HashMap<String, Object>();
  11. metadata.put(CoapJsonDecoder.META_EVENT_TYPE, Type.Acknowledge.name());
  12. metadata.put(CoapJsonDecoder.META_DEVICE_TOKEN, deviceToken);
  13. getEventReceiver().onEventPayloadReceived(exchange.getRequest().getPayload(), metadata);
  14. createAndSendResponse(ResponseCode.CONTENT, "Device acknowledgement submitted successfully.", exchange);
  15. }

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

  1. LOGGER.severe("ISO-8859-1 encoding not supported: " + e.getMessage());
  2. byte[] payload = request.getPayload();

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

  1. LOGGER.severe("ISO-8859-1 encoding not supported: " + e.getMessage());
  2. byte[] payload = request.getPayload();

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

  1. if (request.getPayload() != null && request.getPayload().length > 0) {
  2.   objectLinks = Link.parse(request.getPayload());

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

  1. if (request.getPayload() != null && request.getPayload().length > 0) {
  2.   objectLinks = LinkObject.parse(request.getPayload());

代码示例来源：origin: com.sitewhere/sitewhere-core

  1. /**
  2.  * Handle operations related to device locations.
  3.  * 
  4.  * @param tenant
  5.  * @param device
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleDeviceLocations(ITenant tenant, IDevice device, List<String> paths, Exchange exchange) {
  10. Map<String, Object> metadata = new HashMap<String, Object>();
  11. metadata.put(META_EVENT_TYPE, Type.DeviceLocation.name());
  12. metadata.put(META_HARDWARE_ID, device.getHardwareId());
  13. switch (exchange.getRequest().getCode()) {
  14. case POST: {
  15.   try {
  16.   EventProcessingLogic.processRawPayloadWithExceptionHandling(getEventReceiver(),
  17.     exchange.getRequest().getPayload(), metadata);
  18.   createAndSendResponse(ResponseCode.CONTENT, "Device location created successfully.", exchange);
  19.   } catch (EventDecodeException e) {
  20.   LOGGER.error("Unable to decode CoAP location payload.", e);
  21.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Unable to parse payload.", exchange);
  22.   }
  23.   break;
  24. }
  25. default: {
  26.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Device location operation not available.", exchange);
  27. }
  28. }
  29. }

代码示例来源：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: com.sitewhere/sitewhere-core

  1. /**
  2.  * Handle operations related to device measurements.
  3.  * 
  4.  * @param tenant
  5.  * @param device
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleDeviceMeasurements(ITenant tenant, IDevice device, List<String> paths, Exchange exchange) {
  10. Map<String, Object> metadata = new HashMap<String, Object>();
  11. metadata.put(META_EVENT_TYPE, Type.DeviceMeasurements.name());
  12. metadata.put(META_HARDWARE_ID, device.getHardwareId());
  13. switch (exchange.getRequest().getCode()) {
  14. case POST: {
  15.   try {
  16.   EventProcessingLogic.processRawPayloadWithExceptionHandling(getEventReceiver(),
  17.     exchange.getRequest().getPayload(), metadata);
  18.   createAndSendResponse(ResponseCode.CONTENT, "Device measurements created successfully.", exchange);
  19.   } catch (EventDecodeException e) {
  20.   LOGGER.error("Unable to decode CoAP measurements payload.", e);
  21.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Unable to parse payload.", exchange);
  22.   }
  23.   break;
  24. }
  25. default: {
  26.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Device measurements operation not available.", exchange);
  27. }
  28. }
  29. }

代码示例来源：origin: com.sitewhere/sitewhere-core

  1. /**
  2.  * Handle operations related to device alerts.
  3.  * 
  4.  * @param tenant
  5.  * @param device
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleDeviceAlerts(ITenant tenant, IDevice device, List<String> paths, Exchange exchange) {
  10. Map<String, Object> metadata = new HashMap<String, Object>();
  11. metadata.put(META_EVENT_TYPE, Type.DeviceAlert.name());
  12. metadata.put(META_HARDWARE_ID, device.getHardwareId());
  13. switch (exchange.getRequest().getCode()) {
  14. case POST: {
  15.   try {
  16.   EventProcessingLogic.processRawPayloadWithExceptionHandling(getEventReceiver(),
  17.     exchange.getRequest().getPayload(), metadata);
  18.   createAndSendResponse(ResponseCode.CONTENT, "Device alert created successfully.", exchange);
  19.   } catch (EventDecodeException e) {
  20.   LOGGER.error("Unable to decode CoAP alert payload.", e);
  21.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Unable to parse payload.", exchange);
  22.   }
  23.   break;
  24. }
  25. default: {
  26.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Device alert operation not available.", exchange);
  27. }
  28. }
  29. }

代码示例来源：origin: com.sitewhere/sitewhere-core

  1. /**
  2.  * Handle operations related to device command acknowledgements.
  3.  * 
  4.  * @param tenant
  5.  * @param device
  6.  * @param paths
  7.  * @param exchange
  8.  */
  9. protected void handleDeviceAcks(ITenant tenant, IDevice device, List<String> paths, Exchange exchange) {
  10. Map<String, Object> metadata = new HashMap<String, Object>();
  11. metadata.put(META_EVENT_TYPE, Type.Acknowledge.name());
  12. metadata.put(META_HARDWARE_ID, device.getHardwareId());
  13. switch (exchange.getRequest().getCode()) {
  14. case POST: {
  15.   try {
  16.   EventProcessingLogic.processRawPayloadWithExceptionHandling(getEventReceiver(),
  17.     exchange.getRequest().getPayload(), metadata);
  18.   createAndSendResponse(ResponseCode.CONTENT, "Device acknowledgement created successfully.", exchange);
  19.   } catch (EventDecodeException e) {
  20.   LOGGER.error("Unable to decode CoAP acknowledgement payload.", e);
  21.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Unable to parse payload.", exchange);
  22.   }
  23.   break;
  24. }
  25. default: {
  26.   createAndSendResponse(ResponseCode.BAD_REQUEST, "Device location operation not available.", exchange);
  27. }
  28. }
  29. }

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

  1. /**
  2.  * Create a key for the cache starting from a request and the
  3.  * content-type of the corresponding response.
  4.  * 
  5.  * @param request
  6.  * @return
  7.  * @throws URISyntaxException
  8.  */
  9. private static CacheKey fromContentTypeOption(Request request) throws URISyntaxException {
  10.   if (request == null) {
  11.     throw new IllegalArgumentException("request == null");
  12.   }
  13.   Response response = request.getResponse();
  14.   if (response == null) {
  15.     return fromAcceptOptions(request).get(0);
  16.   }
  17.   String proxyUri = request.getOptions().getProxyUri();
  18.   int mediaType = response.getOptions().getContentFormat();
  19.   if (mediaType < 0) {
  20.     // content-format option not set, use default
  21.     mediaType = MediaTypeRegistry.TEXT_PLAIN;
  22.   }
  23.   byte[] payload = request.getPayload();
  24.   // create the new cacheKey
  25.   CacheKey cacheKey = new CacheKey(proxyUri, mediaType, payload);
  26.   cacheKey.setResponse(response);
  27.   return cacheKey;
  28. }

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

  1. /**
  2.  * Create a key for the cache starting from a request and the
  3.  * content-type of the corresponding response.
  4.  * 
  5.  * @param request
  6.  * @return
  7.  * @throws URISyntaxException
  8.  */
  9. private static CacheKey fromContentTypeOption(Request request) throws URISyntaxException {
  10.   if (request == null) {
  11.     throw new IllegalArgumentException("request == null");
  12.   }
  13.   Response response = request.getResponse();
  14.   if (response == null) {
  15.     return fromAcceptOptions(request).get(0);
  16.   }
  17.   String proxyUri = request.getOptions().getProxyUri();
  18.   int mediaType = response.getOptions().getContentFormat();
  19.   if (mediaType < 0) {
  20.     // content-format option not set, use default
  21.     mediaType = MediaTypeRegistry.TEXT_PLAIN;
  22.   }
  23.   byte[] payload = request.getPayload();
  24.   // create the new cacheKey
  25.   CacheKey cacheKey = new CacheKey(proxyUri, mediaType, payload);
  26.   cacheKey.setResponse(response);
  27.   return cacheKey;
  28. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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