HttpClientDemo.java

import org.apache.http.HttpVersion;
import org.apache.http.client.fluent.Request;
import org.apache.http.entity.ContentType;

import java.io.IOException;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadLocalRandom;

public class HttpClientDemo {

  public static void main(String[] args) throws InterruptedException {
    final var executorService = Executors.newFixedThreadPool(5);
    final var random = ThreadLocalRandom.current();
    for (int i = 0; i < 5; i++) {

      executorService.execute(() -> {
        final String string;
        try {
          final String name = Thread.currentThread().getName();
          System.out.println("Stasrt thread " + name);
          string = Request.Post(String.format("http://localhost:%s/piu", 8080))
              .version(HttpVersion.HTTP_1_0)
              .bodyString(name, ContentType.TEXT_PLAIN)
              .execute()
              .handleResponse(response -> {
                final var entity = response.getEntity();
                final var inputStream = entity.getContent();
                return new String(inputStream.readAllBytes());
              });
          System.out.println(string);
        } catch (IOException e) {
          e.printStackTrace();
        }
      });
      Thread.sleep(random.nextInt(1_000, 10_000));
    }
    executorService.shutdown();
  }
}