1. import java.util.HashMap;
  2. import java.util.Map;
  3. import java.util.Timer;
  4. import java.util.TimerTask;
  6. public class HeaderPerformanceMonitor {
  8. private static final int MEASUREMENT_INTERVAL = 1000; // milliseconds
  9. private static final String STAGING_ENVIRONMENT = "staging"; //Environment to monitor
  11. private static Map<String, Long> headerResponseTimes = new HashMap<>(); // Stores response times for headers
  12. private static Timer timer = new Timer();
  13. private static boolean isRunning = false;
  17. public static void startMonitoring() {
  18. if (isRunning) {
  19. System.out.println("Monitoring already running.");
  20. return;
  21. }
  23. isRunning = true;
  24. timer.scheduleAtFixedRate(new TimerTask() {
  25. @Override
  26. public void run() {
  27. measureHeaderResponseTimes();
  28. }
  29. }, 0, MEASUREMENT_INTERVAL);
  30. System.out.println("Header performance monitoring started for " + STAGING_ENVIRONMENT);
  31. }
  34. public static void stopMonitoring() {
  35. if (!isRunning) {
  36. System.out.println("Monitoring not running.");
  37. return;
  38. }
  40. isRunning = false;
  41. timer.cancel();
  42. System.out.println("Header performance monitoring stopped.");
  43. }
  46. private static void measureHeaderResponseTimes() {
  47. try {
  48. // Simulate making a request to a staging endpoint. Replace with your actual endpoint.
  49. long startTime = System.currentTimeMillis();
  50. String responseHeaders = getResponseHeadersFromStagingEnvironment(); // Function to get response headers
  51. long endTime = System.currentTimeMillis();
  53. if (responseHeaders != null) {
  54. for (Map.Entry<String, Long> entry : headerResponseTimes.entrySet()) {
  55. long existingTime = entry.getValue();
  56. headerResponseTimes.put(entry.getKey(), (endTime - startTime) + existingTime); // Accumulate time
  57. }
  58. headerResponseTimes.put("Total", (endTime - startTime)); //Track Total time
  59. } else {
  60. System.err.println("Error: Could not retrieve response headers from staging environment."); //Error Logging
  61. }
  64. } catch (Exception e) {
  65. System.err.println("Error during header performance measurement: " + e.getMessage()); //Error Logging
  66. e.printStackTrace();
  67. }
  68. }
  71. private static String getResponseHeadersFromStagingEnvironment() {
  72. // Replace this with your actual logic to fetch headers from the staging environment.
  73. // This is a placeholder. You'd typically use a library like HttpClient, OkHttp, or RestAssured.
  74. // Example using a mock:
  75. if (STAGING_ENVIRONMENT.equals("staging")) {
  76. return "Content-Type: application/json\n" +
  77. "X-Custom-Header: value\n" +
  78. "Server: StagingServer";
  79. } else {
  80. return null; // Simulate an error
  81. }
  82. }
  84. public static void main(String[] args) throws InterruptedException {
  85. startMonitoring();
  86. Thread.sleep(60000); // Run for 60 seconds.
  87. stopMonitoring();
  88. System.out.println("Final Header Response Times: " + headerResponseTimes);
  89. }
  93. }

Add your comment