围观：基于事件机制的内部解耦之心路历程

@EventListener
public void onEvent(ArticleReIndexEvent event) {
System.out.println(event.getId());
}
}

使用的地方只需要发布一个 Event 就可以，这个动作默认是同步的，如果我们想让这个操作不会阻塞，变成异步只需要在@EventListener 上面再增加一个@Async 注解。

// 浏览
public void visit() {
  applicationContext.publishEvent(new ArticleReIndexEvent(this, articleId));
  applicationContext.publishEvent(new XXXReIndexEvent(this, articleId));
}

// 评论
public void comment() {
  applicationContext.publishEvent(new ArticleReIndexEvent(this, articleId));
}

实现方案-荣耀黄金
秩序白银的方案在代码层面确实解耦了，但是使用者发布事件需要关注的点太多了，也就是我改了某个表的数据，我得知道有哪些索引会用到这张表的数据，我得把这些相关的事件都发送出去，这样数据才会异步进行刷新。
当业务复杂后或者有新来的同事，不是那么的了解业务，压根不可能知道说我改了这个数据对其他那些索引有影响，所以这个方案还是有优化的空间。
荣耀黄金的方案是将所有的事件都统一为一个，然后在事件里加属性来区分修改的数据是哪里的。每个数据需要同步变更的索引都有自己的监听器，去监听这个统一的事件，这样对于发布者来说我只需要发送一个事件告诉你，我这边改数据了，你要不要消费，要不要更新索引我并不关心。
定义一个数据表发生修改的事件，代码如下：

public class TableUpdateEvent extends ApplicationEvent {
  private String table;
  private String id;

  public TableUpdateEvent(Object source, String id, String table) {
    super(source);
    this.id = id;
    this.table = table;
  }

  public String getId() {
    return id;
  }

  public String getTable() {
    return table;
  }

}

然后每个索引都需要消费这个事件，只需要关注这个索引中数据的来源表有没有变动，如果有变动则去刷新索引。
比如索引 A 的数据都是 article 表中过来的，所以只要是 article 表中的数据发生了变更，索引 A 都要做对应的处理，所以索引 A 的监听器只需要关注 article 表有没有修改即可。

@Component
public class MyEventListener {

  private List<String> consumerTables = Arrays.asList("article");

  @Async
  @EventListener
  public void onEvent(TableUpdateEvent event) {
    System.out.println(event.getId() + "\t" + event.getTable());
    if (consumerTables.contains(event.getTable())) {
      System.out.println("消费自己关注的表数据变动，然后处理。。。");
    }
  }

}

比如索引 B 的数据是从 comment 和 comment_reply 两个表中过来的，所以只要是 comment 和 comment_reply 两个表的数据发生了变更，索引 B 都需要做对应的处理，所以索引 B 的监听器只需要关注 comment 和 comment_reply 两个表有没有修改即可。

@Component
public class MyEventListener2 {

  private List<String> consumerTables = Arrays.asList("comment", "comment_replay");

  @Async
  @EventListener
  public void onEvent(TableUpdateEvent event) {
    System.out.println(event.getId() + "\t" + event.getTable());
    if (consumerTables.contains(event.getTable())) {
      System.out.println("消费自己关注的表数据变动，然后处理。。。");
    }
  }

}