Noark入门之异步事件

引入异步事件主要是为了各模块的解耦，每当完成一个动作时，向系统发布一个事件，由关心的模块自己监听处理，可选择同步处理，异步处理，延迟处理。

何时发布事件，当其他模块关心此动作时<br> 比如获得道具时，任务系统模块要判定完成进度，BI模块需要上报等等都可以监听此事件，已达模块解耦

0x00事件源

一个实现xyz.noark.core.event.Event接口的实现类

1public class ItemIncrEvent extends AbstractPlayerEvent {
2	private String itemcode;
3	private int count;
4	private IncrSource source;
5
6	public ItemIncrEvent(long playerId, String itemcode, int count, IncrSource source) {
7		super(playerId);
8		this.itemcode = itemcode;
9		this.count = count;
10		this.source = source;
11	}
12}

0x01发布事件

在我们获得道具逻辑下面发布此事件

1@Autowired
2private EventManager eventManager;
3
4eventManager.publish(new ItemIncrEvent(playerId, item.getTemplateId(), e.getValue(), source));

0x02处理事件

在对应的模块入口类中，也就是前面提到的Controller类.

1@EventListener(ItemIncrEvent.class)
2public void handleItemIncrEvent(ItemIncrEvent event) {}

这样便完成的事件处理逻辑.

0x03同步处理

注解@xyz.noark.core.annotation.controller.EventListener#async标识是否异步执行，默认为true

如果设置为false,此处理事件的逻辑将同步进行，如果有需要的话

如果要关闭事件显示的话，可以设置printLog=false

@EventListener(value = ItemIncrEvent.class, printLog = false)

0x04多事件异步有序执行

请在监听处理方法上添加@Order，值越小就越先执行.

0x05线程模型

在这里有必要聊一下线程问题，大多数异步事件功能的实现，都是在独立的线程池中执行的，这是一个区别

在0x02处理事件提到的Controller类，是不是我们的事件处理线程也遵循线程模型的划分呢，答案是肯定的

由于ItemIncrEvent实现了xyz.noark.core.event.PlayerEvent接口，如果Controller类上的标识为玩家线程组执行，则会自动派发给此玩家ID所对应的线程来执行.

eventManager在这里仅仅是一个调度者的身份，正式执行的任务线程是取决于Controller入口注解的线程组。

事件功能在冥冥之中响应了前面的线程模型的规划...

评论区

加载中...