Код: Выделить всё
@RestController
@RequestMapping("/users")
public class MyController {
@Autowired
UserService service;
@GetMapping
public Mono getUser() {
// note, the non-reactive call is wrapped into Mono.just
return Mono.just(new ResponseEntity(service.getUser(), ...);
}
}
// both service and dao (below) are non reactive
@Service
public class UserService {
@Autowired
UserDao dao;
User getUser() {
// some logic (everything is in memory, nothing is io-bound)
return dao.getUser();
}
}
@Repository
public class UserDao {
public User getUser() {
// call the non-reactive relational db and get the user
// it takes 99% of the time I believe
// return this user;
}
}
Я использовал базу данных в качестве пример операции с привязкой к вводу-выводу, но иногда в коде также присутствуют вызовы удаленных служб (REST), а также они не являются реактивными...
Эти операции с БД/вызовы удаленного отдыха, я считаю, выглядят примерно так: 99% времени выполнения, поэтому это делает приложение хорошим кандидатом для реактивной реализации.
Однако меня смущает текущая ситуация с кодом:
- Контроллер реактивный
- Сервис/DAO/Удаленные вызовы нет
В Насколько я понимаю, если я хочу использовать реактивный подход веб-потока, весь мой код должен быть реактивным вплоть до вызова базы данных/удаленного отдыха (включая их, конечно), в противном случае я эффективно сохраню потоки цикла событий netty занята, и я не могу этого сделать... Так что в двух словах мне это кажется неправильным, но я не уверен, что на самом деле происходит в этом коде. Я правильно понимаю или я что-то упускаю?
Подробнее здесь: https://stackoverflow.com/questions/786 ... pring-boot