1. import org.json.JSONArray;
  2. import org.json.JSONObject;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.util.concurrent.Executors;
  7. import java.util.concurrent.ScheduledExecutorService;
  8. import java.util.concurrent.TimeUnit;
  10. public class JsonStreamer {
  12. private final String jsonUrl;
  13. private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
  15. public JsonStreamer(String jsonUrl) {
  16. this.jsonUrl = jsonUrl;
  17. }
  19. public void startStreaming() {
  20. scheduler.scheduleAtFixedRate(this::fetchAndPrintJson, 0, 10, TimeUnit.SECONDS); // Run every 10 seconds
  21. }
  23. private void fetchAndPrintJson() {
  24. try (InputStream inputStream = java.net.URL.openConnection().getInputStream()) {
  25. String jsonString = readJsonFromStream(inputStream);
  27. if (jsonString != null) {
  28. try {
  29. JSONArray jsonArray = new JSONArray(jsonString);
  30. for (int i = 0; i < jsonArray.length(); i++) {
  31. JSONObject jsonObject = jsonArray.getJSONObject(i);
  32. System.out.println(jsonObject.toString(2)); // Print with indentation
  33. }
  34. } catch (Exception e) {
  35. System.err.println("Error parsing JSON: " + e.getMessage());
  36. e.printStackTrace();
  37. }
  38. } else {
  39. System.err.println("Failed to retrieve JSON data.");
  40. }
  41. } catch (IOException e) {
  42. System.err.println("Error fetching JSON: " + e.getMessage());
  43. e.printStackTrace();
  44. }
  45. }
  47. private String readJsonFromStream(InputStream inputStream) throws IOException {
  48. StringBuilder sb = new StringBuilder();
  49. int bufferSize = 1024;
  50. byte[] buffer = new byte[bufferSize];
  51. int bytesRead;
  52. while ((bytesRead = inputStream.read(buffer)) != -1) {
  53. sb.append(new String(buffer, 0, bytesRead));
  54. }
  55. return sb.toString();
  56. }
  58. public void stopStreaming() {
  59. scheduler.shutdown();
  60. }
  62. public static void main(String[] args) throws IOException {
  63. String jsonUrl = "https://jsonplaceholder.typicode.com/todos"; // Example JSON URL
  64. JsonStreamer streamer = new JsonStreamer(jsonUrl);
  65. streamer.startStreaming();
  67. // Keep the main thread alive for a while to allow streaming
  68. try {
  69. Thread.sleep(60000); // Run for 60 seconds
  70. } catch (InterruptedException e) {
  71. e.printStackTrace();
  72. }
  73. streamer.stopStreaming();
  74. }
  75. }

Add your comment