event插件如何让用户关注某主题

[Rekoe]

@qinerg
RT

[Rekoe]

另外 同一个类型的 监听 允许定义多个 ?

subscribeTopic

[qinerg]

用户需要自行实现 EventListener 接口，并通过 subscribeTopic() 方法，返回自己关注的主题。EventBus 会在该主题被发布时主动去调用监听类的 onEvent(Event e) 方法。
具体的实现可以参考 test 下的测试用例。

目前一个事件的处理类只能处理单一类型的事件，为降低代码的耦合性也建议一个类只处理一种事件。
如果未来发现有什么特别的好处，可以考虑一个类处理多种类型的事件。

[Rekoe]

@qinerg 你的意思是在EventListener里维护所有的订阅者么

[qinerg]

EventListener负责消费事件，EventBus里维护所有主题的订阅者，当事件发生后，EventBus负责将消息推送至每一个订阅了此主题的EventListener消费者。
举个实例说明吧：
有两个消费者同时订阅了reg-user（用户注册）事件：

/**
 * 注册成功后，给用户增加积分
 */
@IocBean
public class AddCreditsListener implements EventListener {
	@Inject
	private CreditsService creditsService;

	@Override
	public String subscribeTopic() {
		return "reg-user";
	}

	@Async
	@Override
	public void onEvent(Event e) {
		NutMap user = (NutMap) e.getParam();
		Long uid = user.getLong("id");
		creditsService.addCredits(uid, 100); // 给用户增加100个金豆
	}
}`

`/**
 * 日志跟踪消费者
 */
@IocBean
public class LogEventListener implements EventListener {

	private Log log = Logs.get();

	@Override
	public String subscribeTopic() {
		return "reg-user";
	}

	@Override
	public void onEvent(Event e) {
		log.debugf("->new user event: %s", Json.toJson(e.getParam(), JsonFormat.compact()));
	}
}

当注册事件触发时：
Event e1 = new Event("reg-user", newUser);
eventBus.fireEvent(e1);
这时eventBus会将此消息通知到 AddCreditsListener 和 LogEventListener 两个消费者消费。
灵活使用事件机制，可降低代码的耦合度。一旦业务变更，如注册的同时要发送邮件通知，我们不需要修改原来的注册流程，只需要新增加一个 EmailListener 消费者即可，无需修改任何代码。

[Rekoe]

@qinerg 你QQ 或微信是什么 我有问题请教下

[wendal]

我想改名叫eventbus

[Rekoe]

还是没弄明白 整个流程 我加 下作者咨询下

[Rekoe]

public void fireEvent(Event event)

这个方法负责把消息分发给所有订阅的用户么 ？
@wendal

[Rekoe]

好像明白点了 ……

[qinerg]

@Rekoe 有疑问的话，在 nutz.cn 上发贴问吧，你可以把你的所有疑惑说出来，我尽力解答。
在 nutz.cn 上发贴的话，也希望引起更多人对这个插件的关注。
其实“事件”机制就类似于生产者消费者模式，很多场景都会用到，不难理解。

[qinerg]

@wendal 改名我无意见，呵呵