干掉 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...
