集群通信组件tribes之应用程序处理入口
2015-08-09 15:05
218 查看
Tribes为了更清晰更好地划分职责,它被设计成用IO层和应用层,IO层专心负责网络传输方面的逻辑处理,把接收到的数据往应用层传送,当然应用层发送的数据也是通过此IO层发送,数据传往应用层后必须要留一些处理入口供应用层进行逻辑处理,而考虑系统解耦,这个入口最好的方式是使用监听器模式,在底层发生各种事件时触发所有安装好的监听器,使之执行监听器里面的处理逻辑。这些事件主要包含了集群成员的加入和退出、消息报文接收完毕等信息,所以整个消息流转过程被分成两类监听器,一类是跟集群成员的变化相关的监听器MembershipListener,另外一类是跟集群消息接收发送相关的监听器ChannelListener。应用层只要关注这两个接口就行了,写好各种处理逻辑的监听器添加到通道中即可。
下面是这两个监听器的接口,从接口定义的方法可以很清晰地看到各个方法被调用的时机,MembershipListener类型中memberadd是有成员加入时调用的方法,memberDisappeared是成员退出时调用的方法,ChannelListener类型中accept用于判断是否接受消息,messageReceived用于对消息处理的方法,应用层把逻辑分别写到这几个方法就可以在对应时刻执行相应的逻辑。
public interface MembershipListener {
public void memberAdded(Member member);
public void memberDisappeared(Member member);
}
public interface ChannelListener {
public void messageReceived(Serializable msg, Member sender);
public boolean accept(Serializable msg, Member sender);
}
我们可以在应用层自定义若干监听器并且添加到GroupChannel中的两个监听器列表中,GroupChannel其实可以看成是一个封装了IO层的抽象容器,它会在各个适当的时期遍历监听器列表中的所有监听器并调用监听器对应的方法,即执行应用层定义的业务逻辑,至此完成了数据从IO层流向应用层并完成处理。两种类型的监听器给应用层提供了处理入口,应用层只需关注逻辑处理,而其他的IO操作则交由IO层,这两层通过监听器模式串联起来,优雅地将模块解耦。
喜欢java的可以交个朋友:
下面是这两个监听器的接口,从接口定义的方法可以很清晰地看到各个方法被调用的时机,MembershipListener类型中memberadd是有成员加入时调用的方法,memberDisappeared是成员退出时调用的方法,ChannelListener类型中accept用于判断是否接受消息,messageReceived用于对消息处理的方法,应用层把逻辑分别写到这几个方法就可以在对应时刻执行相应的逻辑。
public interface MembershipListener {
public void memberAdded(Member member);
public void memberDisappeared(Member member);
}
public interface ChannelListener {
public void messageReceived(Serializable msg, Member sender);
public boolean accept(Serializable msg, Member sender);
}
我们可以在应用层自定义若干监听器并且添加到GroupChannel中的两个监听器列表中,GroupChannel其实可以看成是一个封装了IO层的抽象容器,它会在各个适当的时期遍历监听器列表中的所有监听器并调用监听器对应的方法,即执行应用层定义的业务逻辑,至此完成了数据从IO层流向应用层并完成处理。两种类型的监听器给应用层提供了处理入口,应用层只需关注逻辑处理,而其他的IO操作则交由IO层,这两层通过监听器模式串联起来,优雅地将模块解耦。
喜欢java的可以交个朋友:
相关文章推荐
- 重复子串问题(三):输出一个字符串中出现频率最高的子串
- android中联系人以及 ContactsContract类大全
- SSM框架——使用MyBatis Generator自动创建代码
- 重庆成为新能源汽车生产基地沈阳2017年新增2990辆新能源公交车
- BZOJ 2789: [Poi2012]Letters( BIT )
- Linux之gdb调试
- android 开发如何做内存优化
- python中json模块的使用
- HDU 1983 BFS&&DFS
- web高性能动画
- Android中Cursor类总结-概念和用法
- iOS 第九课 IOS 点击空白处隐藏键盘的几种方法
- 快速排序
- mysql 锁机制
- bzoj1115: [POI2009]石子游戏Kam
- 设置ECSHOP支持货到付款
- leetcode 109 —— Convert Sorted List to Binary Search Tree
- 选择排序
- WPF QuickStart系列之数据绑定(Data Binding)
- hdu 4044 2011北京赛区网络赛E 树形dp ****