看如何利用mina等实现一个分布式流式计算系统

写在前面，这个系统是同事开发的，我只不过check代码过来研究研究，在此记录下，喔，纵观我所撰写的文章，大抵标题党，一部分源于没有系统的时间去深入研究，一部分只是把一些知识面或者技术点记录下，如陶式不求甚解始终不大好，后面希望慢慢提高撰写博客的质量，望各位见谅。

 

组建这个流失框架的网络通信层是采用了mina，但由于mina太过于底层，不带有语义（业务无关性，或者说基本的request-response都没有直接支持），如果直接使用到业务当中，直接面向业务的api不是太友善，所以做些一层简单封装，让大家不用太关注底层的通信过程与原理，比如只需要在handleRequest方法中编写业务代码就可以了，并注册到服务器就可以，这里就再啰嗦下，这与servlet api，jdbc api等，提供一个规范api给大家，譬如servlet api中就提供了service()方法给业务，或者更细分点是get()或者post()等，使用到web程序不用关于web容器底层的处理流程，只用在提供的api中编写自己的业务逻辑，我相信这种编程方法或者思想到处可见，是由一个纯业务式应用走向一个平台式应用的编程范式，如理解错误，勿喷。

 

例如这样：

 

public RemoteServer{

 

 @override

public Class<Request> interest(){

  return Request.class;

}

@override

public void handleRequest(Request request,Reponse response)

     //业务逻辑

}

 

 

下文待续。。。。