Merge pull request '合并更新版本到本地服务' (#12) from active_mq into main

Reviewed-on: https://src.isharkfly.com/iSharkFly-Docs/java-tutorials/pulls/12

Author: honeymoose

.github/ISSUE_TEMPLATE/issue_report.md

@@ -0,0 +1,32 @@
+---
+name: Issue Report
+about: Report an issue to help us improve
+title: '[ISSUE] '
+---
+
+**Article and Module Links**
+A link to the affected article and the affected module. You can find the link to the module in the Conclusion section in the "on Github" standard phase.
+
+**Describe the Issue**
+A clear and concise description of what the issue is.
+
+**To Reproduce**
+Steps to reproduce the behavior:
+1. Go to '...'
+2. Click on '....'
+3. Scroll down to '....'
+4. See error
+
+**Expected Behavior**
+A clear and concise description of what you expected to happen.
+
+**Screenshots**
+If applicable, add screenshots to help explain your problem.
+
+**Environment (please complete the following information):**
+- OS: [e.g. Windows]
+- Browser [e.g. chrome, safari]
+- Version [e.g. 22]
+
+**Additional Context**
+Add any other context about the issue here.

.idea/compiler.xml

@@ -0,0 +1,11 @@
+# Contributing to Baeldung Tutorials
+First off, thank you for considering contributing to Baeldung Tutorials.
+
+## Reporting Issues
+Before you submit an issue, please review the guidelines below:
+
+1. **No Custom Modifications:** If your issue arises from any custom modifications you've made to the code in the repository, we won't be able to assist. We can only help if the issue is reproducible with the untouched codebase from this repo. If you're working with a modified version, consider asking for help on StackOverflow or other relevant forums.
+2. **Use a clear and descriptive title** for the issue to identify the problem.
+3. **Include a link to the article** you're having issues with.
+4. **Describe the exact steps which reproduce the problem** in as many details as possible.
+5. **Additional Details:** Offer any other context or descriptions that could be useful. Screenshots, error messages, copy/pasteable snippets, or logs can be immensely helpful.

CONTRIBUTING.md

@@ -0,0 +1,3 @@
+## Akka 
+
+This module contains modules about Akka. 

akka-modules/README.md

@@ -0,0 +1,7 @@
+## Akka HTTP
+
+This module contains articles about Akka actors. 
+
+### Relevant articles:
+
+- [Introduction to Akka Actors in Java](https://www.baeldung.com/akka-actors-java)

akka-modules/akka-actors/README.md

@@ -0,0 +1,33 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>akka-actors</artifactId>
+    <name>akka-actors</name>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>akka-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.typesafe.akka</groupId>
+            <artifactId>akka-actor_${scala.version}</artifactId>
+            <version>${typesafe-akka.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.typesafe.akka</groupId>
+            <artifactId>akka-testkit_${scala.version}</artifactId>
+            <version>${typesafe-akka.version}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <properties>
+        <typesafe-akka.version>2.5.11</typesafe-akka.version>
+    </properties>
+
+</project>

akka-modules/akka-actors/pom.xml

@@ -0,0 +1,32 @@
+package com.baeldung.akkaactors;
+
+import akka.actor.AbstractActor;
+import akka.actor.Props;
+import akka.event.Logging;
+import akka.event.LoggingAdapter;
+
+public class FirstActor extends AbstractActor {
+
+    private final LoggingAdapter log = Logging.getLogger(getContext().getSystem(), this);
+
+    public static Props props() {
+        return Props.create(FirstActor.class);
+    }
+
+    @Override
+    public void preStart() {
+        log.info("Actor started");
+    }
+
+    @Override
+    public void postStop() {
+        log.info("Actor stopped");
+    }
+
+    // Messages will not be handled
+    @Override
+    public Receive createReceive() {
+        return receiveBuilder()
+                .build();
+    }
+}

akka-modules/akka-actors/src/main/java/com/baeldung/akkaactors/FirstActor.java

@@ -0,0 +1,24 @@
+package com.baeldung.akkaactors;
+
+import akka.actor.AbstractActor;
+import akka.event.Logging;
+import akka.event.LoggingAdapter;
+
+public class MyActor extends AbstractActor {
+
+    private final LoggingAdapter log = Logging.getLogger(getContext().getSystem(), this);
+
+    @Override
+    public void postStop() {
+        log.info("Stopping actor {}", this);
+    }
+
+    public Receive createReceive() {
+        return receiveBuilder()
+                .matchEquals("printit", p -> {
+                    System.out.println("The address of this actor is: " + getSelf());
+                    getSender().tell("Got Message", getSelf());
+                })
+                .build();
+    }
+}

akka-modules/akka-actors/src/main/java/com/baeldung/akkaactors/MyActor.java

@@ -0,0 +1,45 @@
+package com.baeldung.akkaactors;
+
+import akka.actor.AbstractActor;
+import akka.actor.Props;
+import akka.event.Logging;
+import akka.event.LoggingAdapter;
+
+public class PrinterActor extends AbstractActor {
+
+    private final LoggingAdapter log = Logging.getLogger(getContext().getSystem(), this);
+
+    public static Props props(String text) {
+        return Props.create(PrinterActor.class, text);
+    }
+
+    public static final class PrintFinalResult {
+        Integer totalNumberOfWords;
+
+        public PrintFinalResult(Integer totalNumberOfWords) {
+            this.totalNumberOfWords = totalNumberOfWords;
+        }
+    }
+
+    @Override
+    public void preStart() {
+        log.info("Starting PrinterActor {}", this);
+    }
+
+    @Override
+    public void postStop() {
+        log.info("Stopping PrinterActor {}", this);
+    }
+
+
+    @Override
+    public Receive createReceive() {
+        return receiveBuilder()
+                .match(PrinterActor.PrintFinalResult.class,
+                        r -> {
+                            log.info("Received PrintFinalResult message from " + getSender());
+                            log.info("The text has a total number of {} words", r.totalNumberOfWords);
+                        })
+                .build();
+    }
+}

akka-modules/akka-actors/src/main/java/com/baeldung/akkaactors/PrinterActor.java

@@ -0,0 +1,73 @@
+package com.baeldung.akkaactors;
+
+import akka.actor.AbstractActor;
+import akka.actor.ActorRef;
+import akka.actor.Props;
+import akka.event.Logging;
+import akka.event.LoggingAdapter;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+
+import static akka.pattern.PatternsCS.ask;
+
+public class ReadingActor extends AbstractActor {
+
+    private final LoggingAdapter log = Logging.getLogger(getContext().getSystem(), this);
+
+    private String text;
+
+    public ReadingActor(String text) {
+        this.text = text;
+    }
+
+    public static Props props(String text) {
+        return Props.create(ReadingActor.class, text);
+    }
+
+    public static final class ReadLines {
+    }
+
+    @Override
+    public void preStart() {
+        log.info("Starting ReadingActor {}", this);
+    }
+
+    @Override
+    public void postStop() {
+        log.info("Stopping ReadingActor {}", this);
+    }
+
+    @Override
+    public Receive createReceive() {
+        return receiveBuilder()
+                .match(ReadLines.class, r -> {
+
+                    log.info("Received ReadLines message from " + getSender());
+
+                    String[] lines = text.split("\n");
+                    List<CompletableFuture> futures = new ArrayList<>();
+
+                    for (int i = 0; i < lines.length; i++) {
+                        String line = lines[i];
+                        ActorRef wordCounterActorRef = getContext().actorOf(Props.create(WordCounterActor.class), "word-counter-" + i);
+
+                        CompletableFuture<Object> future =
+                                ask(wordCounterActorRef, new WordCounterActor.CountWords(line), 1000).toCompletableFuture();
+                        futures.add(future);
+                    }
+
+                    Integer totalNumberOfWords = futures.stream()
+                            .map(CompletableFuture::join)
+                            .mapToInt(n -> (Integer) n)
+                            .sum();
+
+                    ActorRef printerActorRef = getContext().actorOf(Props.create(PrinterActor.class), "Printer-Actor");
+                    printerActorRef.forward(new PrinterActor.PrintFinalResult(totalNumberOfWords), getContext());
+//                    printerActorRef.tell(new PrinterActor.PrintFinalResult(totalNumberOfWords), getSelf());
+
+                })
+                .build();
+    }
+}