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

2022-11 spring-31 SI

Browse Source
This commit is contained in:
Vladimir Ivanov
2023-03-28 11:14:43 +03:00
parent f8cd4570f6
commit b2301a96c1
26 changed files with 594 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2022-11/spring-31/.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/
2022-11/spring-31/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-31</artifactId>
<version>1.0</version>
<packaging>pom</packaging>
<modules>
<module>spring-31-exercise</module>
<module>spring-31-solution</module>
</modules>
</project>
2022-11/spring-31/spring-31-exercise/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-31-exercise</artifactId>
<version>1.0-SNAPSHOT</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.9</version>
<relativePath/>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.7</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/App.java
+16
View File
@@ -0,0 +1,16 @@
package ru.otus.spring.integration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import ru.otus.spring.integration.services.OrderService;
@SpringBootApplication
public class App {
public static void main(String[] args) {
ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args);
OrderService orderService = ctx.getBean(OrderService.class);
orderService.startGenerateOrdersLoop();
}
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/Cafe.java
+12
View File
@@ -0,0 +1,12 @@
package ru.otus.spring.integration;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
// TODO: add messaging gateway annotation
public interface Cafe {
// TODO: add gateway annotation with required channels
Food process(OrderItem orderItem);
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java
+33
View File
@@ -0,0 +1,33 @@
package ru.otus.spring.integration.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.channel.PublishSubscribeChannel;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.dsl.MessageChannels;
@Configuration
public class IntegrationConfig {
@Bean
public QueueChannel itemsChannel() {
return MessageChannels.queue(10).get();
}
@Bean
public PublishSubscribeChannel foodChannel() {
return MessageChannels.publishSubscribe().get();
}
// TODO: create default poller
@Bean
public IntegrationFlow cafeFlow() {
return IntegrationFlows.from(itemsChannel())
// TODO: cook OrderItem in the kitchen
// TODO*: add splitter and aggregator
// TODO: forward it to the publish subscriber channel
.get();
}
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/Food.java
+15
View File
@@ -0,0 +1,15 @@
package ru.otus.spring.integration.domain;
public class Food {
private final String name;
public Food(String name) {
this.name = name;
}
public String getName() {
return name;
}
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/OrderItem.java
+14
View File
@@ -0,0 +1,14 @@
package ru.otus.spring.integration.domain;
public class OrderItem {
private final String itemName;
public OrderItem(String itemName) {
this.itemName = itemName;
}
public String getItemName() {
return itemName;
}
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/CafeGateway.java
+12
View File
@@ -0,0 +1,12 @@
package ru.otus.spring.integration.services;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
// TODO: add messaging gateway annotation
public interface CafeGateway {
// TODO: add gateway annotation with required channels
Food process(OrderItem orderItem);
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenService.java
+9
View File
@@ -0,0 +1,9 @@
package ru.otus.spring.integration.services;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
public interface KitchenService {
Food cook(OrderItem orderItem);
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java
+29
View File
@@ -0,0 +1,29 @@
package ru.otus.spring.integration.services;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
@Service
@Slf4j
public class KitchenServiceImpl implements KitchenService {
@Override
public Food cook(OrderItem orderItem) {
log.info("Cooking {}", orderItem.getItemName());
delay();
log.info("Cooking {} done", orderItem.getItemName());
return new Food(orderItem.getItemName());
}
private static void delay() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderService.java
+5
View File
@@ -0,0 +1,5 @@
package ru.otus.spring.integration.services;
public interface OrderService {
void startGenerateOrdersLoop();
}
2022-11/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java
+45
View File
@@ -0,0 +1,45 @@
package ru.otus.spring.integration.services;
import org.apache.commons.lang3.RandomUtils;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
@Service
@Slf4j
public class OrderServiceImpl implements OrderService {
private static final String[] MENU = {"coffee", "tea", "smoothie", "whiskey", "beer", "cola", "water"};
private final CafeGateway cafe;
public OrderServiceImpl(CafeGateway cafe) {
this.cafe = cafe;
}
@Override
public void startGenerateOrdersLoop() {
for (int i = 0; i < 10; i++) {
delay();
OrderItem orderItem = generateOrderItem();
int num = i + 1;
log.info("{}, New orderItem: {}", num, orderItem.getItemName());
Food food = cafe.process(orderItem);
log.info("{}, Ready food: {}", num, food.getName());
}
}
private static OrderItem generateOrderItem() {
return new OrderItem(MENU[RandomUtils.nextInt(0, MENU.length)]);
}
private void delay() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
2022-11/spring-31/spring-31-exercise/src/main/resources/application.yml
+5
View File
@@ -0,0 +1,5 @@
logging:
level:
root: info
org.springframework.integration: debug
2022-11/spring-31/spring-31-solution/pom.xml
+79
View File
@@ -0,0 +1,79 @@
<?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-31-solution</artifactId>
<version>1.0-SNAPSHOT</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.9</version>
<relativePath/>
</parent>
<properties>
<maven.compiler.target>11</maven.compiler.target>
<maven.compiler.source>11</maven.compiler.source>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<checkstyle-plugin.version>3.1.2</checkstyle-plugin.version>
<checkstyle.version>10.9.1</checkstyle.version>
<checkstyle.config.url>https://raw.githubusercontent.com/OtusTeam/Spring/master/checkstyle.xml</checkstyle.config.url>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.7</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
<version>${checkstyle-plugin.version}</version>
<dependencies>
<dependency>
<groupId>com.puppycrawl.tools</groupId>
<artifactId>checkstyle</artifactId>
<version>${checkstyle.version}</version>
</dependency>
</dependencies>
<configuration>
<configLocation>${checkstyle.config.url}</configLocation>
</configuration>
<executions>
<execution>
<goals>
<goal>check</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/App.java
+18
View File
@@ -0,0 +1,18 @@
package ru.otus.spring.integration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import ru.otus.spring.integration.services.OrderService;
@SpringBootApplication
public class App {
public static void main(String[] args) {
ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args);
OrderService orderService = ctx.getBean(OrderService.class);
orderService.startGenerateOrdersLoop();
}
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/Cafe.java
+16
View File
@@ -0,0 +1,16 @@
package ru.otus.spring.integration;
import org.springframework.integration.annotation.Gateway;
import org.springframework.integration.annotation.MessagingGateway;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
import java.util.Collection;
@MessagingGateway
public interface Cafe {
@Gateway(requestChannel = "itemsChannel", replyChannel = "foodChannel")
Collection<Food> process(Collection<OrderItem> orderItem);
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java
+44
View File
@@ -0,0 +1,44 @@
package ru.otus.spring.integration.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.channel.PublishSubscribeChannel;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.dsl.MessageChannels;
import org.springframework.integration.dsl.Pollers;
import org.springframework.integration.scheduling.PollerMetadata;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.services.KitchenService;
@Configuration
public class IntegrationConfig {
@Bean
public QueueChannel itemsChannel() {
return MessageChannels.queue(10).get();
}
@Bean
public PublishSubscribeChannel foodChannel() {
return MessageChannels.publishSubscribe().get();
}
@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerMetadata poller() {
return Pollers.fixedRate(100).maxMessagesPerPoll(2).get();
}
@Bean
public IntegrationFlow cafeFlow(KitchenService kitchenService) {
return IntegrationFlows.from(itemsChannel())
.split()
.handle(kitchenService, "cook")
.<Food, Food>transform(f -> new Food(f.getName().toUpperCase()))
.aggregate()
.channel(foodChannel())
.get();
}
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/Food.java
+15
View File
@@ -0,0 +1,15 @@
package ru.otus.spring.integration.domain;
public class Food {
private final String name;
public Food(String name) {
this.name = name;
}
public String getName() {
return name;
}
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/OrderItem.java
+14
View File
@@ -0,0 +1,14 @@
package ru.otus.spring.integration.domain;
public class OrderItem {
private final String itemName;
public OrderItem(String itemName) {
this.itemName = itemName;
}
public String getItemName() {
return itemName;
}
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/CafeGateway.java
+16
View File
@@ -0,0 +1,16 @@
package ru.otus.spring.integration.services;
import org.springframework.integration.annotation.Gateway;
import org.springframework.integration.annotation.MessagingGateway;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
import java.util.Collection;
@MessagingGateway
public interface CafeGateway {
@Gateway(requestChannel = "itemsChannel", replyChannel = "foodChannel")
Collection<Food> process(Collection<OrderItem> orderItem);
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenService.java
+9
View File
@@ -0,0 +1,9 @@
package ru.otus.spring.integration.services;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
public interface KitchenService {
Food cook(OrderItem orderItem);
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java
+28
View File
@@ -0,0 +1,28 @@
package ru.otus.spring.integration.services;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
@Service
@Slf4j
public class KitchenServiceImpl implements KitchenService {
@Override
public Food cook(OrderItem orderItem) {
log.info("Cooking {}", orderItem.getItemName());
delay();
log.info("Cooking {} done", orderItem.getItemName());
return new Food(orderItem.getItemName());
}
private static void delay() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderService.java
+5
View File
@@ -0,0 +1,5 @@
package ru.otus.spring.integration.services;
public interface OrderService {
void startGenerateOrdersLoop();
}
2022-11/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java
+66
View File
@@ -0,0 +1,66 @@
package ru.otus.spring.integration.services;
import org.apache.commons.lang3.RandomUtils;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
import ru.otus.spring.integration.domain.Food;
import ru.otus.spring.integration.domain.OrderItem;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.ForkJoinPool;
import java.util.stream.Collectors;
@Service
@Slf4j
public class OrderServiceImpl implements OrderService {
private static final String[] MENU = {"coffee", "tea", "smoothie", "whiskey", "beer", "cola", "water"};
private final CafeGateway cafe;
public OrderServiceImpl(CafeGateway cafe) {
this.cafe = cafe;
}
@Override
public void startGenerateOrdersLoop() {
ForkJoinPool pool = ForkJoinPool.commonPool();
for (int i = 0; i < 10; i++) {
delay();
int num = i + 1;
pool.execute(() -> {
Collection<OrderItem> items = generateOrderItems();
log.info("{}, New orderItems: {}", num,
items.stream().map(OrderItem::getItemName)
.collect(Collectors.joining(",")));
Collection<Food> food = cafe.process(items);
log.info("{}, Ready food: {}", num, food.stream()
.map(Food::getName)
.collect(Collectors.joining(",")));
});
}
}
private static OrderItem generateOrderItem() {
return new OrderItem(MENU[RandomUtils.nextInt(0, MENU.length)]);
}
private static Collection<OrderItem> generateOrderItems() {
List<OrderItem> items = new ArrayList<>();
for (int i = 0; i < RandomUtils.nextInt(1, 5); ++i) {
items.add(generateOrderItem());
}
return items;
}
private void delay() {
try {
Thread.sleep(7000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
2022-11/spring-31/spring-31-solution/src/main/resources/application.yml
+5
View File
@@ -0,0 +1,5 @@
logging:
level:
root: info
org.springframework.integration: info