مشروع: عميل REST API

src/ model/ Post.java Comment.java service/ JsonPlaceholderClient.java util/ JsonParser.java Main.java

// model/Post.java package model; public record Post(int userId, int id, String title, String body) {}

// model/Comment.java package model; public record Comment(int postId, int id, String name, String email, String body) {}

// util/JsonParser.java package util; import model.Comment; import model.Post; import java.util.ArrayList; import java.util.List; import java.util.regex.Matcher; import java.util.regex.Pattern; public final class JsonParser { private JsonParser() {} /** استخرج قيمة نصية لحقل JSON مسمّى. */ public static String extractString(String json, String field) { Pattern p = Pattern.compile("\"" + field + "\"\\s*:\\s*\"(.*?)\""); Matcher m = p.matcher(json); return m.find() ? m.group(1) : ""; } /** استخرج قيمة صحيحة لحقل JSON مسمّى. */ public static int extractInt(String json, String field) { Pattern p = Pattern.compile("\"" + field + "\"\\s*:\\s*(\\d+)"); Matcher m = p.matcher(json); return m.find() ? Integer.parseInt(m.group(1)) : 0; } /** قسّم مصفوفة JSON إلى سلاسل كائنات منفردة. */ public static List<String> splitObjects(String jsonArray) { List<String> objects = new ArrayList<>(); int depth = 0; int start = -1; for (int i = 0; i < jsonArray.length(); i++) { char c = jsonArray.charAt(i); if (c == '{') { if (depth++ == 0) start = i; } else if (c == '}') { if (--depth == 0) objects.add(jsonArray.substring(start, i + 1)); } } return objects; } public static Post parsePost(String json) { return new Post( extractInt(json, "userId"), extractInt(json, "id"), extractString(json, "title"), extractString(json, "body") ); } public static Comment parseComment(String json) { return new Comment( extractInt(json, "postId"), extractInt(json, "id"), extractString(json, "name"), extractString(json, "email"), extractString(json, "body") ); } }

// service/JsonPlaceholderClient.java package service; import model.Comment; import model.Post; import util.JsonParser; import java.net.URI; import java.net.http.HttpClient; import java.net.http.HttpRequest; import java.net.http.HttpResponse; import java.time.Duration; import java.util.List; import java.util.concurrent.CompletableFuture; public class JsonPlaceholderClient { private static final String BASE = "https://jsonplaceholder.typicode.com"; private final HttpClient http; public JsonPlaceholderClient() { this.http = HttpClient.newBuilder() .connectTimeout(Duration.ofSeconds(5)) .build(); } // ── متزامن: جلب كل المنشورات ─────────────────────────────────────────── public List<Post> fetchPosts() throws Exception { HttpRequest req = HttpRequest.newBuilder() .uri(URI.create(BASE + "/posts")) .timeout(Duration.ofSeconds(10)) .GET() .build(); HttpResponse<String> res = http.send(req, HttpResponse.BodyHandlers.ofString()); requireSuccess(res); return JsonParser.splitObjects(res.body()) .stream() .map(JsonParser::parsePost) .toList(); } // ── غير متزامن: جلب منشور وتعليقاته في آنٍ واحد ────────────────────── public CompletableFuture<Post> fetchPostAsync(int id) { HttpRequest req = HttpRequest.newBuilder() .uri(URI.create(BASE + "/posts/" + id)) .GET() .build(); return http.sendAsync(req, HttpResponse.BodyHandlers.ofString()) .thenApply(res -> { requireSuccessUnchecked(res); return JsonParser.parsePost(res.body()); }); } public CompletableFuture<List<Comment>> fetchCommentsAsync(int postId) { HttpRequest req = HttpRequest.newBuilder() .uri(URI.create(BASE + "/posts/" + postId + "/comments")) .GET() .build(); return http.sendAsync(req, HttpResponse.BodyHandlers.ofString()) .thenApply(res -> { requireSuccessUnchecked(res); return JsonParser.splitObjects(res.body()) .stream() .map(JsonParser::parseComment) .toList(); }); } // ── POST: إنشاء منشور جديد ────────────────────────────────────────────── public Post createPost(int userId, String title, String body) throws Exception { String json = """ {"userId":%d,"title":"%s","body":"%s"} """.formatted(userId, title, body).strip(); HttpRequest req = HttpRequest.newBuilder() .uri(URI.create(BASE + "/posts")) .timeout(Duration.ofSeconds(10)) .header("Content-Type", "application/json") .POST(HttpRequest.BodyPublishers.ofString(json)) .build(); HttpResponse<String> res = http.send(req, HttpResponse.BodyHandlers.ofString()); requireSuccess(res); return JsonParser.parsePost(res.body()); } // ── أدوات مساعدة ───────────────────────────────────────────────────────── private void requireSuccess(HttpResponse<?> res) throws Exception { if (res.statusCode() < 200 || res.statusCode() >= 300) { throw new Exception("خطأ HTTP " + res.statusCode()); } } private void requireSuccessUnchecked(HttpResponse<?> res) { if (res.statusCode() < 200 || res.statusCode() >= 300) { throw new RuntimeException("خطأ HTTP " + res.statusCode()); } } }

// Main.java import model.Comment; import model.Post; import service.JsonPlaceholderClient; import java.util.List; import java.util.concurrent.CompletableFuture; public class Main { public static void main(String[] args) throws Exception { JsonPlaceholderClient client = new JsonPlaceholderClient(); // 1. جلب وعرض أول 5 منشورات System.out.println("=== المنشورات (أول 5) ==="); List<Post> posts = client.fetchPosts(); posts.stream().limit(5).forEach(p -> System.out.printf("[%d] %s%n", p.id(), p.title()) ); // 2. جلب المنشور رقم 1 وتعليقاته بشكل متزامن System.out.println("\n=== المنشور #1 مع التعليقات (غير متزامن) ==="); CompletableFuture<Post> postFuture = client.fetchPostAsync(1); CompletableFuture<List<Comment>> commentFuture = client.fetchCommentsAsync(1); CompletableFuture.allOf(postFuture, commentFuture).join(); Post post = postFuture.join(); List<Comment> comments = commentFuture.join(); System.out.println("العنوان : " + post.title()); System.out.println("المؤلف : userId " + post.userId()); System.out.println("التعليقات (" + comments.size() + "):"); comments.forEach(c -> System.out.println(" - " + c.name() + " <" + c.email() + ">")); // 3. إنشاء منشور جديد System.out.println("\n=== إنشاء منشور ==="); Post created = client.createPost(1, "منشوري الجديد", "مرحبًا من Java HttpClient"); System.out.println("المعرّف المُنشأ: " + created.id() + "، العنوان: " + created.title()); } }