GitHub/Spring
1
0
Fork 0
mirror of https://github.com/OtusTeam/Spring.git synced 2026-05-30 10:50:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

spring-2019-11 - 19

Browse Source
This commit is contained in:
Yuriy Dvorzhetskiy
2020-02-11 21:55:50 +06:00
parent bcddae0fb9
commit 33049fdc74
16 changed files with 434 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2019-11/spring-19/.gitignore
+24
View File
@@ -0,0 +1,24 @@
target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/build/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
2019-11/spring-19/pom.xml
+18
View File
@@ -0,0 +1,18 @@
<?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>
<groupId>ru.otus</groupId>
<artifactId>spring-19</artifactId>
<version>1.0</version>
<packaging>pom</packaging>
<modules>
<module>spring-19-web-flux</module>
<module>spring-19-reactor</module>
<module>spring-19-reactive-spring-data</module>
</modules>
</project>
2019-11/spring-19/spring-19-reactive-spring-data/pom.xml
+51
View File
@@ -0,0 +1,51 @@
<?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>
<groupId>ru.otus</groupId>
<artifactId>spring-19-reactive-spring-data</artifactId>
<version>1.0</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.4.RELEASE</version>
<relativePath/>
</parent>
<properties>
<maven.compiler.target>11</maven.compiler.target>
<maven.compiler.source>11</maven.compiler.source>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
</dependency>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver-reactivestreams</artifactId>
</dependency>
<dependency>
<groupId>de.flapdoodle.embed</groupId>
<artifactId>de.flapdoodle.embed.mongo</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2019-11/spring-19/spring-19-reactive-spring-data/src/main/java/ru/otus/spring/Main.java
+37
View File
@@ -0,0 +1,37 @@
package ru.otus.spring;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.data.mongo.MongoDataAutoConfiguration;
import org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration;
import org.springframework.boot.autoconfigure.mongo.embedded.EmbeddedMongoAutoConfiguration;
import org.springframework.context.ApplicationContext;
import org.springframework.data.mongodb.repository.config.EnableReactiveMongoRepositories;
import reactor.core.Disposable;
import reactor.core.publisher.Flux;
import ru.otus.spring.domain.Person;
import ru.otus.spring.repostory.PersonRepository;
@SpringBootApplication
public class Main {
public static void main(String[] args) throws InterruptedException {
ApplicationContext context = SpringApplication.run(Main.class);
PersonRepository repository = context.getBean(PersonRepository.class);
repository.saveAll(
Flux.fromArray(new String[]{"Pushkin", "Lermontov"})
.map(Person::new)
).subscribe();
Disposable flux = repository.findAll()
.subscribe(p -> System.out.println(p.getName()));
Thread.sleep(20000);
flux.dispose();
}
}
2019-11/spring-19/spring-19-reactive-spring-data/src/main/java/ru/otus/spring/domain/Person.java
+27
View File
@@ -0,0 +1,27 @@
package ru.otus.spring.domain;
public class Person {
private String id;
private String name;
public Person(String name) {
this.name = name;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
2019-11/spring-19/spring-19-reactive-spring-data/src/main/java/ru/otus/spring/repostory/PersonRepository.java
+17
View File
@@ -0,0 +1,17 @@
package ru.otus.spring.repostory;
import org.springframework.data.mongodb.repository.Query;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import org.springframework.data.repository.reactive.ReactiveCrudRepository;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import ru.otus.spring.domain.Person;
public interface PersonRepository extends ReactiveMongoRepository<Person, String> {
Flux<Person> findByName(String name);
@Query("{ 'name': ?0 }")
Mono<Person> findFirstByName(String name);
}
2019-11/spring-19/spring-19-reactive-spring-data/src/main/resources/application.yml
View File
2019-11/spring-19/spring-19-reactor/pom.xml
+42
View File
@@ -0,0 +1,42 @@
<?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>
<groupId>ru.otus</groupId>
<artifactId>spring-19-reactor</artifactId>
<version>1.0</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.4.RELEASE</version>
<relativePath/>
</parent>
<properties>
<maven.compiler.target>11</maven.compiler.target>
<maven.compiler.source>11</maven.compiler.source>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-core</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2019-11/spring-19/spring-19-reactor/src/main/java/ru/otus/spring/Main.java
+20
View File
@@ -0,0 +1,20 @@
package ru.otus.spring;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import ru.otus.spring.reactor.FluxService;
@SpringBootApplication
public class Main {
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(Main.class);
FluxService service = context.getBean(FluxService.class);
service.printHello("Ivan");
}
}
2019-11/spring-19/spring-19-reactor/src/main/java/ru/otus/spring/reactor/FluxService.java
+49
View File
@@ -0,0 +1,49 @@
package ru.otus.spring.reactor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import reactor.core.Disposable;
import reactor.core.publisher.DirectProcessor;
import reactor.core.publisher.Mono;
@Service
public class FluxService {
private final Logger logger = LoggerFactory.getLogger(FluxService.class);
private final NonFluxService nonFluxService;
private final DirectProcessor<Message> processor;
private final Disposable flow;
@Autowired
public FluxService(NonFluxService nonFluxService) {
this.nonFluxService = nonFluxService;
// Создаём процессор - это reactor-овская реализация reactive-stream интерфейса
// Direct processor, кстати - это простой последовательный вызов методов)
processor = DirectProcessor.create();
// Здесь мы настриваем flow
flow = Mono.from(processor)
.map(nonFluxService::nonFluxSayHello)
.subscribe(this::printMessage);
}
/**
* Этот метод будет инициировать асинзронную обрабтку сообщения
*
* @param name это имя будет приходить из не-reactor окружения
*/
public void printHello(String name) {
processor.onNext(new Message(name));
}
/**
* А это терминальный шаг для сообщения
*
* @param message а это финальный шаг для сообщения, отсюда можно вернуть рзультат в не-реактив окружение
*/
private void printMessage(Message message) {
logger.info("Message received: {}", message.getValue());
}
}
2019-11/spring-19/spring-19-reactor/src/main/java/ru/otus/spring/reactor/Message.java
+14
View File
@@ -0,0 +1,14 @@
package ru.otus.spring.reactor;
public class Message {
private final String value;
public Message(String value) {
this.value = value;
}
public String getValue() {
return value;
}
}
2019-11/spring-19/spring-19-reactor/src/main/java/ru/otus/spring/reactor/NonFluxService.java
+24
View File
@@ -0,0 +1,24 @@
package ru.otus.spring.reactor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
@Service
public class NonFluxService {
private final Logger logger = LoggerFactory.getLogger(NonFluxService.class);
public Message nonFluxSayHello(Message message) {
logger.info("Message received in non-flux service: {}", message.getValue());
final String name = message.getValue();
final String withHello = "Hello, " + name + "!";
try {
Thread.sleep(1000);
return new Message(withHello);
} catch (InterruptedException ex) {
return new Message(withHello);
}
}
}
2019-11/spring-19/spring-19-web-flux/pom.xml
+44
View File
@@ -0,0 +1,44 @@
<?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>
<groupId>ru.otus</groupId>
<artifactId>spring-19-web-flux</artifactId>
<version>1.0</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.4.RELEASE</version>
<relativePath/>
</parent>
<properties>
<maven.compiler.target>11</maven.compiler.target>
<maven.compiler.source>11</maven.compiler.source>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
<!-- работает и без неё, но нужна нам, для RxJava методов -->
<dependency>
<groupId>io.reactivex.rxjava2</groupId>
<artifactId>rxjava</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2019-11/spring-19/spring-19-web-flux/src/main/java/ru/otus/spring/Main.java
+14
View File
@@ -0,0 +1,14 @@
package ru.otus.spring;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Main {
public static void main(String[] args) {
SpringApplication.run(Main.class);
}
}
2019-11/spring-19/spring-19-web-flux/src/main/java/ru/otus/spring/ReactorController.java
+33
View File
@@ -0,0 +1,33 @@
package ru.otus.spring;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.time.Duration;
@RestController
public class ReactorController {
@GetMapping("/flux/one")
public Mono<String> one() {
return Mono.just("one");
}
@GetMapping("/flux/ten")
public Flux<Integer> list() {
return Flux.range(1, 10);
}
@GetMapping(path = "/flux/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<String> stream() {
return Flux.generate(() -> 0, (state, emitter) -> {
emitter.next(state);
return state + 1;
})
.delayElements(Duration.ofSeconds(1L))
.map(Object::toString);
}
}
2019-11/spring-19/spring-19-web-flux/src/main/java/ru/otus/spring/RxJava2Controller.java
+20
View File
@@ -0,0 +1,20 @@
package ru.otus.spring;
import io.reactivex.Flowable;
import io.reactivex.Single;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class RxJava2Controller {
@GetMapping("/rx/one")
public Single<String> single() {
return Single.just("one");
}
@GetMapping("/rx/ten")
public Flowable<Integer> list() {
return Flowable.range(1, 10);
}
}