DataStrom框架深造

Posted 2020-10-07 jinyuttt

根据前一版DataStrom的使用，继续进行了改造和升级;前一版框架只是对服务按照名称注册和调用固化接口

最近研究后台框架，接触了ZBUS框架，我很喜欢ZBUS的前一版，该作者继续升级，已经在向AMQ靠近；

考虑我平时接触的项目，不会用到复杂筛选，区分等功能，所以保留最原始的处理状态，重新搭建最简单的方式

构造成MQ+Topic+RPC三者合一的DataStrom；尤其是RPC部分参考了ZBUS;

1.DataStrom 简单的代码

  都是java最原始的代码堆积：通讯加保存，没有多余的功能

2.引用包很少

   当前只有fastjson与nanohttpd-2.1.0.jar;

3.简要功能

  生产者发送byte[]数据到MQStrom,然后MQStrom转发给消费者

  生产者方发布RPC,消费者方调用RPC(RPC基于接口)

说明：由于我的需要，当前通讯UDP

           另外生产者与消费者没有封装对象发送，如果需要自己再封装一层，用fastjson序列化反序列化对象即可实现发送

4.通讯接口

   通讯接口沿用上一版方式，你可以自己实现接口，然后再net文件下放置该jar,然后程序自动调用，也可以直接修改源码，在添加一组通讯包

5.网页版监视器，监视MQStrom，当前只能监视，还需要完善