根據前一版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,當前只能監視,還須要完善