spring中的event listener模式和解耦

event,listener是observer模式一种体现,在spring 3.0.5中,已经能够使用annotation实现event和eventListner里。
咱们以spring-webflow里的hotel booking为例,看一下实现,步骤以下:
1,创建event
java

public class BookingCreatedEvent extends ApplicationEvent {
 private static final long serialVersionUID = 3039313222160544111L;

 private Booking booking;

 public BookingCreatedEvent(Object source) {
  super(source);
 }

 public BookingCreatedEvent(Object source, Booking booking) {
  super(source);
  this.booking = booking;
 }

 public Booking getBooking() {
  return booking;
 }
}

event须要继承ApplicationEvent。web

2,创建listener
spring

@Component
public class BookingEventsListener implements ApplicationListener<BookingCreatedEvent> {
 private static final Logger log = Logger.getLogger();

 //listener实现
 public void onApplicationEvent(BookingCreatedEvent event) {
  log.debug("bookingId:" + event.getBooking().getId());
  //do something
 }
}

listener须要实现ApplicationListener。
注意在spring 3.0.5中的ApplicationListener是带泛型的,这样BookingEventsListener只会监听BookingCreatedEvent事件。
另外能够用@Component来注册组件,这样就不须要在spring的配置文件中指定了。数据库

3,触发event
app

@Service("bookingService")
@Repository
public class JpaBookingService implements BookingService, ApplicationContextAware {

 private ApplicationContext context;

 public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
  log.debug("Autowired applicationContext");
  this.context = applicationContext;
 }

 //省略的代码
 
 @Transactional
 public void persistBooking(Booking booking) throws HibernateException, SQLException {
  em.persist(booking);
  log.debug("fire BookingCreatedEvent");
  BookingCreatedEvent bookingCreatedEvent = new BookingCreatedEvent(this, booking);
  //触发event
  this.context.publishEvent(bookingCreatedEvent);
 }
}

触发要实现ApplicationContextAware,用于引入ApplicationContext,因为bookingService也是spring组件,因此在系统启动的时候,ApplicationContext已经注入。也能够用以下方式直接注入ApplicationContext。异步

@Autowired
private ApplicationContext applicationContext;

那么event listener这种模式的好处是什么呢?举个例子,若是客人booking了hotel之后,系统要发email给客人,那咱们就能够在listener的do something处加入发送email的代码。
上面咱们讲起用@Component把listener注册成了spring的组件,这样listener的用途是在runtime的时候解耦。
而若是咱们把listener用配置文件的方式注册的话,主要的用途是在部署时解耦。
在实际应用中,两种状况都有。this

另外要注意的一点是,service和listener是同步的,在service中的persistBooking有注册@Transactional的状况下,listener中的do something和service中的persistBooking是在同一个tansaction下。
若是要作异步,须要经过MQ或者数据库中转。debug

相关文章
相关标签/搜索