Энтони Гонсалвес - Изучаем Java EE 7

··@Inject

··private NumberGenerator numberGenerator;

··@Inject

··private Event bookAddedEvent;

··public Book createBook(String title, Float price, String description) {

····Book book = new Book(title, price, description);

····book.setIsbn(numberGenerator.generateNumber());

····bookAddedEvent.fire(book);

····return book;

··}

}

События инициируются производителем событий и на них подписываются наблюдатели. Наблюдатель — это компонент с одним или несколькими «отслеживающими» методами. Каждый из этих методов наблюдателя берет в качестве параметра событие определенного типа, сопровождаемое аннотацией @Observers и опциональными квалификаторами. Метод наблюдателя оповещается о событии, если объект события соответствует типу и всем квалификаторам. В листинге 2.37 показана служба инвентаризации, задача которой — отслеживать новые книжные поступления, дополняя информацию о книжном фонде. Там используется метод addBook, который наблюдает за каждым событием с типом Book. Аннотированный параметр называется параметром события. Поэтому, как только событие инициируется компонентом BookService, контейнер CDI приостанавливает выполнение и передает событие любому зарегистрированному наблюдателю. В нашем случае в листинге 2.37 будет вызван метод addBook, который обновит список книг, а затем контейнер продолжит выполнение кода с того места, где он остановился в компоненте BookService. Это означает, что события в CDI не рассматриваются асинхронно.

public class InventoryService {

··@Inject

··private Logger logger;

··List inventory = new ArrayList<>();

··public void addBook(@Observes Book book) {

····logger.info("Adding book " + book.getTitle() + "to inventory");

····inventory.add(book);

··}

}

Как и большинство CDI, производство события и подписка являются типобезопасными и позволяют квалификаторам определять, какие наблюдатели событий будут использоваться. Событию может быть назначен один или несколько квалификаторов (с членами либо без таковых), которые позволяют наблюдателям отличить его от остальных событий такого же типа. Листинг 2.38 возвращается к компоненту BookService, добавив туда дополнительное событие. При создании книги инициируется событие bookAddedEvent, а при удалении — событие bookRemovedEvent, оба с типом Book. Чтобы можно было отличать эти события, каждое из них сопровождается аннотацией @Added или @Removed. Код этих квалификаторов идентичен коду в листинге 2.7: аннотация без членов и аннотированная @Qualifier.

public class BookService {

··@Inject

··private NumberGenerator numberGenerator;

··@Inject @Added

··private Event bookAddedEvent;

··@Inject @Removed

··private Event bookRemovedEvent;

··public Book createBook(String title, Float price, String description) {

····Book book = new Book(title, price, description);

····book.setIsbn(numberGenerator.generateNumber());

····bookAddedEvent.fire(book);

····return book;

··}

··public void deleteBook(Book book) {

····bookRemovedEvent.fire(book);

··}

}

InventoryService в листинге 2.39 наблюдает за обоими событиями, объявив два отдельных метода, один из которых наблюдает за событием о добавлении книги (@Observes @Added Book), а другой — за событием о ее удалении (@Observes @Removed Book).

public class InventoryService {

··@Inject

··private Logger logger;

··List inventory = new ArrayList<>();

··public void addBook(@Observes @Added Book book) {

····logger.warning("Книга " + book.getTitle() + " добавлена в список");

····inventory.add(book);

··}

··public void removeBook(@Observes @Removed Book book) {

····logger.warning("Книга " + book.getTitle() + " удалена из списка");

····inventory.remove(book);

··}

}

Поскольку модель события использует квалификаторы, вам было бы целесообразно задавать поля квалификаторов или агрегировать их. Следующий код наблюдает за всеми добавленными книгами, цена которых превышает 100:

void addBook(@Observes @Added @Price(greaterThan=100) Book book)

А теперь совместим некоторые из этих понятий, напишем несколько компонентов, производителей, используем внедрение, квалификаторы, альтернативы и связывание с перехватчиком. В этом примере применяется контейнер Weld для запуска класса Main в Java SE, а также интеграционный тест для проверки правильности внедрения.

Рисунок 2.7 показывает схему со всеми классами, необходимыми для запуска этого образца кода, и описывает все точки внедрения.