根据前一版DataStrom的使用,继续进行了改造和升级;前一版框架只是对服务按照名称注册和调用固化接口java
最近研究后台框架,接触了ZBUS框架,我很喜欢ZBUS的前一版,该做者继续升级,已经在向AMQ靠近;json
考虑我平时接触的项目,不会用到复杂筛选,区分等功能,因此保留最原始的处理状态,从新搭建最简单的方式框架
构形成MQ+Topic+RPC三者合一的DataStrom;尤为是RPC部分参考了ZBUS;对象
1.DataStrom 简单的代码blog
都是java最原始的代码堆积:通信加保存,没有多余的功能接口
2.引用包不多源码
当前只有fastjson与nanohttpd-2.1.0.jar;ast
3.简要功能后台
生产者发送byte[]数据到MQStrom,而后MQStrom转发给消费者序列化
生产者方发布RPC,消费者方调用RPC(RPC基于接口)
说明:因为个人须要,当前通信UDP
另外生产者与消费者没有封装对象发送,若是须要本身再封装一层,用fastjson序列化反序列化对象便可实现发送
4.通信接口
通信接口沿用上一版方式,你能够本身实现接口,而后再net文件下放置该jar,而后程序自动调用,也能够直接修改源码,在添加一组通信包
5.网页版监视器,监视MQStrom,当前只能监视,还须要完善