干掉 RPC（先吹嘘一波），让一切皆事件，支持分布式事件处理机制的 5.6 版本发布

此版本在5.5版本的基础上重构消息队列支持，使得在远程事件处理机制上更加广泛，您可以利用各类第三方消息队列实现分布式事件处理服务并可获得事件处理结果，亦可利用自定义协议亦或mqtt实现远端事件处理服务。
1、可根据应用场景限定远端事件处理是否为广播模式或不重复处理模式，此功能可完全由第三方消息队列限定。
2、获取事件处理结果在广播模式下仅以最先收到的处理结果为准。
3、可基于消息队列、MQTT或其它自定义用户协议实现分布式事件处理服务，如全服事件仅处理一次请优先考虑使用第三方消息队列。

以下是基于消息队列的范例代码：

 import com.kaka.Startup; import com.kaka.notice.*; import java.util.Arrays; import java.util.concurrent.Executors; /** * @author zkpursuit */ public class Remote_Test extends Startup { public static void main(String[] args) throws Exception { Facade facade = FacadeFactory.getFacade(); Remote_Test test = new Remote_Test(); test.scan("kaka.test.unit"); facade.initThreadPool(Executors.newFixedThreadPool(2)); //以下通过ActiveMQ消息队列消费处理事件，并获得事件处理结果 facade.initRemoteMessagePostman(new ActiveMQ("event_exec_before", "event_exec_after")); //此行全局一次设定 //facade.initRemoteMessagePostman(new RocketMQ("event_exec_before", "event_exec_after")); Message message = new Message("20000", "让ResultCommand接收执行"); IResult<String> result4 = message.setResult("ResultMsg", new AsynLatchResult<>()); //AsynLatchResult可用AsynResult替代 facade.sendRemoteMessage(message); // try { // System.out.println("消息队列消费处理事件结果：" + ((AsynLatchResult) result4).get(5, TimeUnit.SECONDS)); // } catch (TimeoutException ex) { // System.out.println("获取结果超时"); // } System.out.println("消息队列消费处理事件结果：" + result4.get()); //一直等待结果 facade.sendRemoteMessage(new Message("40000", "", (IResult<Object> result) -> { String clasz = ((CallbackResult<Object>) result).eventHandlerClass; StringBuilder sb = new StringBuilder("消息队列消费处理事件结果异步回调：\t" + clasz + "\t"); Object resultObj = result.get(); if (resultObj instanceof Object[]) { Object[] ps = (Object[]) resultObj; sb.append(Arrays.toString(ps)); } else { sb.append(resultObj); } System.out.println(sb); })); } }