Блог

Я полный новичок в реактивном мире, поэтому, просматривая некоторые примеры реактивных репозиториев, которые я нашел ниже:

 reactiverepository.save(employee).subscribe() // subscribing to make the publisher emit the data

reactiverepository.findAll() // no subscribe() ?
 

Я знаю, что для того, чтобы издатель (поток в приведенном выше случае) передавал данные, нам нужно subscribe() к нему. Но почему у нас нет таких же subscribe() вызовов в других методах CRUD, как в приведенном выше примере? Чего мне здесь не хватает?

реактор работает с концепцией producer и consumer . consumer subscribes Для producer и nothing will happen until you subscribe .

При использовании webflux , которое в основном spring-web , но реализовано с reactor концепцией, это the final consumer is usually the one subscribing так.

Вы можете думать об этом как о базе producer данных, а вызывающий client (веб-страница, приложение react, мобильное приложение) consumer — это, и когда клиент инициирует вызов серверной части, клиент subscribes к вашему server и server , в свою очередь subscribes , к database (помните? производитель, база данных создает данные).

Таким образом, ваш сервер в основном просто пересылает данные вызывающему клиенту, что означает, что обычно вы просто берете данные и возвращаете их клиенту, а платформа автоматически обрабатывает «подписку».

Обычно это означает, что вы НЕ должны подписываться в своем приложении, вместо этого вы должны выполнять цепочку вызовов и всегда сохранять цепочку неповрежденной, чтобы ваш сервер мог создавать элементы для клиента.

Итак, когда вы должны subscribe использовать свой сервер?

Ну, одной из причин может быть то, что у вас на сервере запущено задание, которое, возможно, извлекает данные с одного сервера и вставляет их в свою базу данных. Тогда ваш сервис является инициирующим клиентом, подписывающимся на другой сервер, другой сервер выдает вам элементы, вы получаете их и вставляете в свою базу данных.

но, например, в вашем примере:

 // first we fetch all, we filter, then we save, and we return back to the calling client keeping the chain intact, and no subscriptions
return reactiverepository.findAll()
    .filter(employes -> //some criteria)
    .flatMap(employee -> reactiverepository.save(employee));
 

Во-первых, вы должны знать о горячих и холодных издателях. Я бы посоветовал ознакомиться с этой статьей

Код, который вы пишете в мире реактивного программирования, представляет собой описание того, что вы хотите сделать (в мире реактора это называется сборкой, я бы посоветовал рассмотреть эту проблему, чтобы лучше понять разницу между сборкой и выполнением) после того, как данные будут готовы и не будут выполняться точно после выполнения вашего кода.

Второе, что следует иметь в виду, это то, что вы всегда находитесь в цепочке, и вам нужна только одна подписка в этой цепочке.

Например, предположим, что вы хотите получить все данные из репозитория и отфильтровать их с помощью одного поля, а затем вернуть их внешней стороне метода. Итак, вы должны сделать что-то вроде этого:

 return reactiveRepository.findAll().filter { //filter with one field } //or doing something different with your data when they fetched from DB
 

Вы должны заметить, что до тех пор, пока вы не подпишетесь на цепочку, данные не будут извлекаться из базы данных, и ваша цепочка ничего не будет делать.