LaunchAdminApplicationTests.java 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package com.webflux.launchadmin;
  2. import com.plumelog.core.util.LogExceptionStackTrace;
  3. import org.junit.jupiter.api.Test;
  4. import org.springframework.boot.test.context.SpringBootTest;
  5. import reactor.core.publisher.Mono;
  6. import java.net.URI;
  7. import java.net.http.HttpClient;
  8. import java.net.http.HttpHeaders;
  9. import java.net.http.HttpRequest;
  10. import java.net.http.HttpResponse;
  11. @SpringBootTest
  12. class LaunchAdminApplicationTests {
  13. @Test
  14. public void te() {
  15. HttpClient httpClient = HttpClient.newHttpClient();
  16. HttpRequest httpRequest = HttpRequest.newBuilder()
  17. .uri(URI.create("https://c2ba.api.huachen.cn/ip?ip=58.211.174.206"))
  18. .GET()
  19. .header("Authorization", "APPCODE 757a4a0cb5234bf283d68ec584c96607")
  20. .build();
  21. try {
  22. HttpResponse<String> httpResponse = httpClient.send(httpRequest, HttpResponse.BodyHandlers.ofString());
  23. int statusCode = httpResponse.statusCode();
  24. HttpHeaders headers = httpResponse.headers();
  25. String responseBody = httpResponse.body();
  26. System.out.println("Status Code: " + statusCode);
  27. System.out.println("Headers: " + headers);
  28. System.out.println("Response Body: " + responseBody);
  29. } catch (Exception e) {
  30. e.printStackTrace();
  31. }
  32. }
  33. @Test
  34. public void testLog() {
  35. String val = "123abc";
  36. Mono.just(val).flatMap(f -> Mono.just(Integer.parseInt(f)))
  37. .onErrorResume(e -> Mono.error(new Exception(LogExceptionStackTrace.erroStackTrace(e).toString())))
  38. .subscribe(System.out::println);
  39. }
  40. }