Ein Beispiel für eine hexagonale Architektur in Java

Einführung in die hexagonale Architektur

• Domain . Die Schicht enthält die Kerngeschäftslogik. Er muss die Details der Implementierung der äußeren Schichten nicht kennen.
• Anwendung . Eine Schicht fungiert als Brücke zwischen den Schichten einer Domäne und der Infrastruktur.
• Infrastruktur . Die Implementierung der Interaktion der Domäne mit der Außenwelt. Die inneren Schichten sehen für ihn wie eine Black Box aus.

Beispiel

public interface IUserInput {
    public void handleUserInput(Object userCommand);
}

public interface IFetchMovieReviews {
    public List<MovieReview> fetchMovieReviews(MovieSearchRequest movieSearchRequest);
}

public interface IPrintMovieReviews {
    public void writeMovieReviews(List<MovieReview> movieReviewList);
}

public class ConsolePrinter implements IPrintMovieReviews {
    @Override
    public void writeMovieReviews(List<MovieReview> movieReviewList) {
        movieReviewList.forEach(movieReview -> {
            System.out.println(movieReview.toString());
        });
    }
}

public class MovieReviewsRepo implements IFetchMovieReviews {
    private Map<String, List<MovieReview>> movieReviewMap;

    public MovieReviewsRepo() {
        initialize();
    }

    public List<MovieReview> fetchMovieReviews(MovieSearchRequest movieSearchRequest) {

        return Optional.ofNullable(movieReviewMap.get(movieSearchRequest.getMovieName()))
            .orElse(new ArrayList<>());
    }

    private void initialize() {
        this.movieReviewMap = new HashMap<>();
        movieReviewMap.put("StarWars", Collections.singletonList(new MovieReview("1", 7.5, "Good")));
        movieReviewMap.put("StarTreck", Arrays.asList(new MovieReview("1", 9.5, "Excellent"), new MovieReview("1", 8.5, "Good")));
    }
}

Domain

public class MovieApp implements Consumer<MovieSearchRequest> {
    private IFetchMovieReviews fetchMovieReviews;
    private IPrintMovieReviews printMovieReviews;
    private static Random rand = new Random();

    public MovieApp(IFetchMovieReviews fetchMovieReviews, IPrintMovieReviews printMovieReviews) {
        this.fetchMovieReviews = fetchMovieReviews;
        this.printMovieReviews = printMovieReviews;
    }

    private List<MovieReview> filterRandomReviews(List<MovieReview> movieReviewList) {
        List<MovieReview> result = new ArrayList<MovieReview>();
        // logic to return random reviews
        for (int index = 0; index < 5; ++index) {
            if (movieReviewList.size() < 1)
                break;
            int randomIndex = getRandomElement(movieReviewList.size());
            MovieReview movieReview = movieReviewList.get(randomIndex);
            movieReviewList.remove(movieReview);
            result.add(movieReview);
        }
        return result;
    }

    private int getRandomElement(int size) {
        return rand.nextInt(size);
    }

    public void accept(MovieSearchRequest movieSearchRequest) {
        List<MovieReview> movieReviewList = fetchMovieReviews.fetchMovieReviews(movieSearchRequest);
        List<MovieReview> randomReviews = filterRandomReviews(new ArrayList<>(movieReviewList));
        printMovieReviews.writeMovieReviews(randomReviews);
    }
}

public class CommandMapperModel {
    private static final Class<MovieSearchRequest> searchMovies = MovieSearchRequest.class;

    public static Model build(Consumer<MovieSearchRequest> displayMovies) {
        Model model = Model.builder()
            .user(searchMovies)
            .system(displayMovies)
            .build();

        return model;
    }
}

Steueranschlussadapter

public class UserCommandBoundary implements IUserInput {
    private Model model;

    public UserCommandBoundary(IFetchMovieReviews fetchMovieReviews, IPrintMovieReviews printMovieReviews) {
        MovieApp movieApp = new MovieApp(fetchMovieReviews, printMovieReviews);
        model = CommandMapperModel.build(movieApp);
    }

    public void handleUserInput(Object userCommand) {
        new ModelRunner().run(model)
            .reactTo(userCommand);
    }
}

public class MovieUser {
    private IUserInput userInputDriverPort;

    public MovieUser(IUserInput userInputDriverPort) {
        this.userInputDriverPort = userInputDriverPort;
    }

    public void processInput(MovieSearchRequest movieSearchRequest) {
        userInputDriverPort.handleUserInput(movieSearchRequest);
    }
}

Anwendung

public class Main {

    public static void main(String[] args) {
        IFetchMovieReviews fetchMovieReviews = new MovieReviewsRepo();
        IPrintMovieReviews printMovieReviews = new ConsolePrinter();
        IUserInput userCommandBoundary = new UserCommandBoundary(fetchMovieReviews, printMovieReviews);
        MovieUser movieUser = new MovieUser(userCommandBoundary);
        MovieSearchRequest starWarsRequest = new MovieSearchRequest("StarWars");
        MovieSearchRequest starTreckRequest = new MovieSearchRequest("StarTreck");

        System.out.println("Displaying reviews for movie " + starTreckRequest.getMovieName());
        movieUser.processInput(starTreckRequest);
        System.out.println("Displaying reviews for movie " + starWarsRequest.getMovieName());
        movieUser.processInput(starWarsRequest);
    }

}

Was verbessert werden kann, ändert sich

• In unserer Implementierung können Sie problemlos von einem Datenspeicher zu einem anderen wechseln. Die Speicherimplementierung kann in den Code eingefügt werden, ohne die Geschäftslogik zu ändern. Sie können beispielsweise Daten aus dem Speicher in eine Datenbank übertragen, indem Sie einen Datenbankadapter schreiben.
• Anstelle der Ausgabe an die Konsole können Sie einen „Drucker“ implementieren, der Daten in eine Datei schreibt. In einer solchen mehrschichtigen Anwendung wird es einfacher, Funktionen hinzuzufügen und Fehler zu beheben.
• Um die Geschäftslogik zu testen, können Sie komplexe Tests schreiben. Adapter können isoliert getestet werden. Somit ist es möglich, die gesamte Testabdeckung zu erhöhen.

Fazit

• Begleitung - lose gekoppelte und unabhängige Schichten. Es wird einfach, einer Ebene neue Funktionen hinzuzufügen, ohne andere Ebenen zu beeinflussen.
• Testbarkeit - Unit-Tests werden einfach und schnell geschrieben. Sie können Tests für jede Ebene mit Stub-Objekten schreiben, die Abhängigkeiten simulieren. Zum Beispiel können wir die Abhängigkeit von der Datenbank entfernen, indem wir ein Data Warehouse im Speicher erstellen.
• Anpassungsfähigkeit - Die Hauptgeschäftslogik wird unabhängig von Änderungen an externen Objekten. Wenn Sie beispielsweise in eine andere Datenbank migrieren müssen, müssen wir keine Änderungen an der Domäne vornehmen. Wir können einen geeigneten Adapter für die Datenbank erstellen.

Verweise

• Sechseckige Architektur (Alistair Cockburn)
• Hexagonal Architecture-Wiki
• Ports und Adapter Architektur
• Giphy