ProbeCelery.java 1.5 KB

12345678910111213141516
  1. import java.net.*;
  2. import java.net.http.*;
  3. import java.nio.charset.StandardCharsets;
  4. import java.time.Duration;
  5. public class ProbeCelery {
  6. public static void main(String[] a) throws Exception {
  7. HttpClient c = HttpClient.newBuilder().connectTimeout(Duration.ofSeconds(15)).build();
  8. String login = "{\"tenantCode\":\"cs1\",\"username\":\"admin\",\"password\":\"Admin@123456\",\"code\":\"\",\"uuid\":\"\"}";
  9. HttpResponse<String> lr = c.send(HttpRequest.newBuilder().uri(URI.create("http://127.0.0.1:8004/login")).timeout(Duration.ofSeconds(30)).header("Content-Type","application/json; charset=utf-8").POST(HttpRequest.BodyPublishers.ofString(login, StandardCharsets.UTF_8)).build(), HttpResponse.BodyHandlers.ofString(StandardCharsets.UTF_8));
  10. String token = lr.body().replaceAll("(?s).*\"token\"\\s*:\\s*\"([^\"]+)\".*", "$1");
  11. String msg = "\u4f60\u597d\uff0c\u82b9\u83dc\u53ef\u4ee5\u6cbb\u7597\u7cd6\u5c3f\u75c5\u5417\uff1f";
  12. String body = "{\"templateId\":70,\"content\":\"" + msg.replace("\\","\\\\").replace("\"","\\\"") + "\"}";
  13. HttpResponse<String> sr = c.send(HttpRequest.newBuilder().uri(URI.create("http://127.0.0.1:8004/workflow/simulate")).timeout(Duration.ofSeconds(180)).header("Authorization","Bearer "+token).header("Content-Type","application/json; charset=utf-8").POST(HttpRequest.BodyPublishers.ofString(body, StandardCharsets.UTF_8)).build(), HttpResponse.BodyHandlers.ofString(StandardCharsets.UTF_8));
  14. System.out.println(sr.body());
  15. }
  16. }