spring Arduino + 4G HTTP请求返回码-2(ArduinoHTTPClient +调制解调器GSM)

zf2sa74q  于 2024-01-05  发布在  Spring
关注(0)|答案(1)|浏览(126)

我正在开发一个系统，其中Atmega 328充当网关，通过NRF24L01从传感器接收数据，并通过4G将其发送到Spring中的HTTP服务器。嗯，一切都很完美，直到昨天，我在Spring中的数据接收端点中编辑了一些东西，现在我的网关返回HTTP代码-2（这在标准HTTP中不存在，我查了一下，这是来自ArduinoHTTPClient库本身的代码[您正在接收HTTP响应代码-2，这意味着发送请求头1时出错]）。
嗯，我测试了4G调制解调器，它有一个信号，并连接到移动的互联网网络.我测试了一个测试端点和同样的事情，代码-2.

  1. #include <SoftwareSerial.h>
  2. #include "RF24.h"
  4. RF24 radio(7, 8);
  5. const byte radio_address[6] = "00006";
  7. #define TINY_GSM_MODEM_SIM7600
  9. #define TINY_GSM_USE_WIFI false
  11. #define GSM_PIN ""
  13. #define UART_BAUD 115200
  14. #define PIN_DTR 25
  15. #define PIN_TX 3
  16. #define PIN_RX 2
  17. #define PWR_PIN 7
  19. #define RESET_ATMEGA 6
  21. SoftwareSerial SerialAT(PIN_RX, PIN_TX);
  23. const char apn[] = "zap.vivo.com.br";
  24. const char gprsUser[] = "vivo";
  25. const char gprsPass[] = "vivo";
  27. #include <TinyGsmClient.h>
  28. #include <ArduinoHttpClient.h>
  30. #define TINY_GSM_USE_GPRS true
  32. TinyGsm modem(Serial);
  34. //AWS Spring Server Host
  35. const char server[] = "******************.compute.amazonaws.com";
  36. const char resource[] = "/data/register";
  37. const int port = 8080;
  38. const char resourceTest[] = "/data/test";
  40. const uint8_t cid = 1;
  42. TinyGsmClient client(modem);
  43. HttpClient http(client, server, port);
  45. int g = 0;
  46. bool connectedToNetwork = false;
  48. #define TRANSMISSION_DATA_PACKAGE 5
  50. struct __attribute__((__packed__)) Data {
  51.   char type;  // 'D' para Data
  52.   char key[6];
  53.   float rms[3];
  54.   float temperature;
  55. } data;
  57. struct __attribute__((__packed__)) VibrationPackage {
  58.   char type;  // 'V' para VibrationPackage
  59.   char key[6];
  60.   float dataPackage[TRANSMISSION_DATA_PACKAGE];
  61.   int start;
  62.   int end;
  63. } vibrationPackage;
  65. void initGSM() {
  66.   if (!connectedToNetwork) {
  68.     SerialAT.print("Waiting for network...");
  69.     if (!modem.waitForNetwork()) {
  70.       SerialAT.println(" fail");
  72.       delay(10000);
  73.       return;
  74.     }
  75.     SerialAT.println(" success");
  76.     connectedToNetwork = true;
  78.     if (modem.isNetworkConnected()) {
  79.       SerialAT.println("Network connected");
  80.     }
  81.   }
  83.   if (!modem.gprsConnect(apn, gprsUser, gprsPass)) {
  84.     SerialAT.println("fail");
  85.     return;
  86.   }
  88.   g = 1;
  89. }
  91. void setup() {
  92.   pinMode(RESET_ATMEGA, OUTPUT);
  93.   digitalWrite(RESET_ATMEGA, HIGH);
  94.   Serial.begin(115200);
  95.   SerialAT.begin(UART_BAUD);
  97.   pinMode(PWR_PIN, OUTPUT);
  99.   digitalWrite(PWR_PIN, LOW);
  100.   delay(100);
  101.   digitalWrite(PWR_PIN, HIGH);
  102.   delay(1000);
  103.   digitalWrite(PWR_PIN, LOW);
  105.   SerialAT.println("Wait...");
  107.   delay(11000);
  109.   SerialAT.println("Initializing modem...");
  110.   if (!modem.init()) {
  111.     SerialAT.println("Failed to restart modem, delaying 10s and retrying");
  112.     return;
  113.   }
  115.   if (GSM_PIN && modem.getSimStatus() != 3) {
  116.     modem.simUnlock(GSM_PIN);
  117.   }
  119.   if (!radio.begin()) {
  120.     SerialAT.println(F("[ERROR] Radio hardware is not responding..."));
  122.     while (1) {}
  123.   }
  125.   radio.setPALevel(RF24_PA_MAX);
  126.   radio.setDataRate(RF24_250KBPS);
  127.   radio.setChannel(76);
  128.   radio.setCRCLength(RF24_CRC_16);
  129.   radio.openReadingPipe(1, radio_address);
  130.   radio.startListening();
  131. }
  133. void httpRequest(String json) {
  134.   SerialAT.println("");
  135.   SerialAT.println("");
  137.   SerialAT.println("making POST request");
  138.   SerialAT.println(json);
  140.   http.beginRequest();
  142.   http.sendHeader("Connection", "keep-alive");
  143.   http.sendHeader("User-Agent", "ArduinoHttpClient");
  144.   http.sendHeader("Accept", "*/*");
  145.   http.sendHeader("Accept-Encoding", "gzip, deflate");
  146.   http.sendHeader("HTTP-Version", "HTTP/1.1");
  147.   http.sendHeader("Host", server);
  148.   http.sendHeader("Content-Type", "application/json");
  149.   http.sendHeader("Content-Length", json.length());
  151.   http.post(resource);
  152.   http.beginBody();
  153.   http.print(json);
  154.   http.endRequest();
  155.   http.stop();
  157.   int statusCode = http.responseStatusCode();
  158.   SerialAT.print("HTTP Response Code: ");
  159.   SerialAT.println(statusCode);
  160. }
  162. //unsigned long previousMillis = 0;
  163. //const unsigned long interval = 180000;
  164. void (*resetFunc)(void) = 0;
  165. void loop() {
  167.   if (g == 0)
  168.     initGSM();
  170.   //unsigned long currentMillis = millis();
  171.   //if (currentMillis - previousMillis >= interval) {
  172.   //SerialAT.println(F("Reset"));
  173.   //resetFunc();
  175.   //previousMillis = currentMillis;
  176.   //}
  178.   uint8_t pipe;
  179.   if (radio.available(&pipe)) {
  180.     SerialAT.println("Res ");
  181.     SerialAT.print("Recieved ");
  182.     int size = radio.getDynamicPayloadSize();
  183.     SerialAT.print(size);
  184.     SerialAT.println(" bytes on pipe");
  186.     byte packet[size];
  187.     radio.read(&packet, size);
  189.     if (packet[0] == 'D') {
  190.       memcpy(&data, &packet, sizeof(data));  //0 | Type 1-6 | Key
  191.       String dataJson = "";
  193.       dataJson += "{\"type\":\"";
  194.       dataJson += data.type;
  195.       dataJson += "\",\"key\":\"";
  196.       dataJson += data.key;
  197.       dataJson += "\",\"rms\":[";
  198.       dataJson += data.rms[0];
  199.       dataJson += ",";
  200.       dataJson += data.rms[1];
  201.       dataJson += ",";
  202.       dataJson += data.rms[2];
  203.       dataJson += "],\"temperature\":";
  204.       dataJson += data.temperature;
  205.       dataJson += "}";
  206.       httpRequest(dataJson);
  207.     } else {
  208.       memcpy(&vibrationPackage, &packet, sizeof(vibrationPackage));
  209.       String vibrationJson = "";
  211.       vibrationJson += "{\"type\":\"";
  212.       vibrationJson += vibrationPackage.type;
  213.       vibrationJson += "\",\"key\":\"";
  214.       vibrationJson += vibrationPackage.key;
  215.       vibrationJson += "\",\"dataPackage\":[";
  217.       for (int i = 0; i < TRANSMISSION_DATA_PACKAGE; i++) {
  218.         vibrationJson += vibrationPackage.dataPackage[i];
  219.         if (i < TRANSMISSION_DATA_PACKAGE - 1) {
  220.           vibrationJson += ",";
  221.         }
  222.       }
  224.       vibrationJson += "\",\"start\":\"";
  225.       vibrationJson += vibrationPackage.start;
  226.       vibrationJson += "\",\"end\":\"";
  227.       vibrationJson += vibrationPackage.end;
  229.       vibrationJson += "]}";
  230.       httpRequest(vibrationJson);
  231.     }
  232.   }
  233. }

字符串
x1c 0d1x的数据

  1. @RestController
  2. @RequestMapping("/data")
  3. public class DataController {
  5.     @Autowired
  6.     private DataRepository repository;
  7.     @Autowired
  8.     private VibrationPackageRepository vibrationPackageRepository;
  9.     @Autowired
  10.     private ClientRepository clientRepository;
  11.     @Autowired
  12.     private AssetRepository assetRepository;
  13.     @Autowired
  14.     private ApplicationContext applicationContext;
  16.     @PostMapping("/register")
  17.     public ResponseEntity<String> register(@RequestBody String object) {
  18.         System.out.println("JSON Chegou!");
  19.         try {
  20.             ObjectMapper objectMapper = new ObjectMapper();
  21.             JsonNode requestBody = objectMapper.readTree(object);
  22.             if (requestBody.has("key")) {
  23.                 String assetKey = requestBody.get("key").asText();
  24.                 Optional<Asset> assetOptional = assetRepository.findByKey(assetKey);
  25.                 if (assetOptional.isPresent()) {
  26.                     Asset asset = assetOptional.get();
  27.                     if (requestBody.has("type")) {
  28.                         String objectType = requestBody.get("type").asText();
  29.                         switch (objectType) {
  31.                         case "D":
  32.                             DataRequest dataRequest = objectMapper.treeToValue(requestBody, DataRequest.class);
  33.                             System.out.println("Objeto do tipo DataRequest: " + dataRequest.toString());
  34.                             Data data = dataRequest.getData();
  35.                             // Run FFT
  36.                             Analyzer analyzer = new Analyzer(
  37.                                     asset.getDataList(),
  38.                                     asset.getVibrationPackages(),
  39.                                     asset,
  40.                                     applicationContext
  41.                                     );
  42.                             
  43.                             asset.getVibrationPackages().clear();
  44.                             data.setAsset(asset);
  45.                         
  46.                             repository.save(data);
  47.                             assetRepository.save(asset);
  48.                         break;
  50.                         case "P":
  51.                             VibrationPackageRequest vibrationPackageRequest = objectMapper.treeToValue(requestBody,
  52.                                     VibrationPackageRequest.class);
  53.                             System.out.println("Objeto do tipo VibrationPackage: " + vibrationPackageRequest.toString());
  54.                             VibrationPackage vibrationPackage = vibrationPackageRequest.getVibrationPackage(asset);
  56.                             if (asset.getVibrationPackages().size() > 0) {
  57.                                 if (asset.getVibrationPackages().get(0).getStart() == 0) {
  58.                                     vibrationPackage.setAsset(asset);
  59.                                     vibrationPackageRepository.save(vibrationPackage);
  60.                                 } else {
  61.                                     asset.getVibrationPackages().clear();
  62.                                     assetRepository.save(asset);
  63.                                 }
  64.                             } else if (vibrationPackage.getStart() == 0)
  65.                                 vibrationPackageRepository.save(vibrationPackage);
  66.     
  67.                         break;
  69.                         default:
  70.                             System.out.println("Tipo de objeto desconhecido: " + objectType);
  71.                             return ResponseEntity.badRequest().build();
  72.                         }
  73.                         
  74.                     } else {
  75.                         System.out.println("Campo 'type' não encontrado no JSON: " + requestBody);
  76.                         return ResponseEntity.badRequest().build();
  77.                     }
  79.                 }
  80.             }
  82.         } catch (Exception e) {
  83.             System.out.println("JSON inválido: " + object);
  84.             e.printStackTrace();
  85.             return ResponseEntity.badRequest().build();
  86.         }
  88.         return ResponseEntity.ok().build();
  89.     }
  90. }

型
我不知道发生了什么事，就像我说的，昨天它是工作的。我已经对服务器进行了更改，但没有什么会导致这一点。
在服务器上使用Postman进行测试：


的


的
编辑：我添加了以下片段：

  1. http.post(resource);
  2. if (http.connected()) {
  3.     SerialAT.println("Connected to server");
  4. } else {
  5.     SerialAT.println("Connection to server failed");
  6. }

型
我收到信息说我没有连接到服务器

spring

1条答案

按热度按时间
u5i3ibmn

u5i3ibmn1#

我只是忘了支付互联网lol

赞(0）分享  回复(0）举报  2024-01-05
我来回答

相关问题

    查看更多

    热门标签

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

    最新问答

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