EventBus最佳实践：Java手撕实现ESB底层事件委托处理机制的思路，配套演示代码

package org.example.platform.esb; import org.example.platform.esb.base.BaseEvent; import org.example.platform.esb.itf.IListener; import java.lang.reflect.Method; import java.lang.reflect.ParameterizedType; import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; public class ESB { private static Map<String, List<IListener>> listeners=new LinkedHashMap<>(); public static void doEvent(BaseEvent e) { String eventType = e.getClass().getName(); Method beforeMethod = findMethod(e, "before"); if(beforeMethod!=null){ try { beforeMethod.invoke(e.getSender(),e); } catch (Exception err) { throw new RuntimeException(err); } } if(listeners.containsKey(eventType)){ for (IListener iListener : listeners.get(eventType)) { iListener.doEvent(e); } } Method afterMethod = findMethod(e, "after"); if(afterMethod!=null){ try { afterMethod.invoke(e.getSender(),e); } catch (Exception err) { throw new RuntimeException(err); } } } private static Method findMethod(BaseEvent e, String prefix) { if(e.getSender()!=null){ Object sender = e.getSender(); for (Method method : sender.getClass().getMethods()) { if((prefix + e.getClass().getSimpleName()).equals(method.getName())&& method.getParameterCount()==1 && method.getParameterTypes()[0].getName().equals(e.getClass().getName()) ){ return method; } } } return null; } public synchronized static void reg(IListener ... listenerArray) { for (IListener iListener : listenerArray) { Class type = (Class)((ParameterizedType)iListener.getClass().getGenericInterfaces()[0]).getActualTypeArguments()[0]; if(!listeners.containsKey(type.getName())){ listeners.put(type.getName(),new ArrayList<IListener>()); } if(!listeners.get(type.getName()).contains(iListener)){ listeners.get(type.getName()).add(iListener); } } } }