看如何利用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)

     //业务逻辑

}

下文待续。。。。

相关推荐