现在的位置: 首页 > 综合 > 正文

activeMQ的网络层1

2013年12月11日 ⁄ 综合 ⁄ 共 1671字 ⁄ 字号 评论关闭

activemq网络层概念

activemq 是支持多协议的,因此,把单一协议的server抽象成更高一层,就很有意义,请看下面这张图:

在activemq中,差不多每种概念都有生命周期(见Service接口)。
这张图十分简单,实际中当然比这个要复杂。下面针对每个概念进行叙述。

Transport

Transport 应该算是很底层的概念,他封装了 Socket,职责是发送和接受连接方的信息。
同时,在Transport中,增加了同步和异步的概念。
Transport拥有一个TransportListener。

TransportListener

顾名思义,TransportListener 就是监听 Transport 事件的发生以及做出一定的反映。
在activemq中,正是利用了 TransportListener 对 Command 进行处理 —— Command 是 activemq 网络传递的形式,每个请求都会被反序列化成一个 Command。

TransportServer

就是一个server实例,他会处理外部进来的Socket,进而封装成 Transport 。此 Server 拥有一个 TransportAcceptListener 。

TransportAcceptListener

负责 Accept Transport,将 Transport 封装成 Connection,从而开启 Connection 的生命周期。
这里需要注意的是:TransportServer 将 Socket 封装成 Transport,而 TransportAcceptListener 将 Transport 封装成 Connection。

Connection

可以理解成业务层面上的连接。 Connection 会给相应的 Transport 设置 TransportListener ,从而获取底层 Socket 的活动情况,进行业务的处理。

Connector

Connector就是较高层次的抽象,它代表对外的连接器,每个连接器都可以支持不同的协议。
Connector 通过给 TransportServer 设置 TransportAcceptListener ,从而能够控制 Transport 并产生相应的 Connection。

文章到这里是引用自阿里巴巴的开源小组的文章。但是感觉分析的比较粗略。我这里进行一下补充说明。

这里都是以TCP协议为基础进行分析:

connector是用于生成和管理客户端到broker的连接。他持有了一CopyOnWriteArrayList<TransportConnection> 属性。该属性中有所有的已经start的connection。

而connection的创建是包含的connector和transport的作为参数的。

public TransportConnection(TransportConnector connector, final Transport transport, Broker broker,
                               TaskRunnerFactory taskRunnerFactory, TaskRunnerFactory stopTaskRunnerFactory)

这样,在connection进行启动的时候会调用 connector中的onStart方法,将该connection加入到connector的list中。

connector同时持有了一个TransportServer 实例。

TransportServer  中,持有了AcceptLisenter实例和serverSocket实例。serverSocket用来接收socket,并将socket封装成transport实例。AcceptLisenter则负责将transport封装成connection实例。

这样,在连接部分,职能划分更加明确。

connector负责生成和管理连接。

TransportServer 负责接收scoket连接,封装成transport并根据acceptLisener 封装成对应的connection。

抱歉!评论已关闭.