[大数据]第34篇 rabbitmq AMQChannel源码分析

上一篇稍微了解一下Channel, 本节我们来了解一下AMQChannel抽象类

• 这个类是AMQ通道基础类， 它继承了ShutdownNotifierComponent类
  

  文章目录

  • • 1、ShutdownNotifierComponent 类
    • • 1.1、成员变量或常量
      • 1.2、方法
    • 2、AMQChannel 抽象类
    • • 2.1、成员变量或常量
      • 2.2、方法
      • 2.3、图示
    • 3、内部类和接口
    • • 3.1、 RpcContinuation接口
      • • 3.1.1、方法
      • 3.2、BlockingRpcContinuation implements RpcContinuation
      • • 3.2.1、成员变量
        • 3.2.2、方法和构造方法
      • 3.3、SimpleBlockingRpcContinuation extends BlockingRpcContinuation

1、ShutdownNotifierComponent 类

• 这个类是ShutdownListener监听器管理类，且会记录关闭的原因，这个是Channel和Connection都有关闭监听器。

1.1、成员变量或常量

1.2、方法

2、AMQChannel 抽象类

2.1、成员变量或常量

2.2、方法

2.3、图示

1. AMQCommand exnWrappingRpc(Method m)

   • 方法就是发送请求，然后将异常包装成IO异常，上传图片，且是同步
   • 
   1. 调用rpc方法
   2. 先判断是否关闭，也就是shutdownException是否有值
   3. 入队，其实抢通道的独占锁，_channelMutex
   4. 调用socket传输Frame的数据
   5. 阻塞等待结果，也就是通过BlockingCell进行交换数据，这里有超时时间

2. handleCompleteInboundCommand(AMQCommand command)

   • 执行结束之后做后置处理
   • 
   1. 记录command的命令，一般调试用的
   2. 处理异步操作之后，是否需要继续处理
   3. 是否需要检查rpc响应类型，处理类型是否满足
   4. 唤醒下一次rpc调用，返回本次rpc结果
   5. 将结果写到交互对象，有两种方式一种是Future方式和BlockingCell方式
   6. 标记Rpc完成

3、内部类和接口

3.1、 RpcContinuation接口

3.1.1、方法

3.2、BlockingRpcContinuation implements RpcContinuation

3.2.1、成员变量

3.2.2、方法和构造方法

3.3、SimpleBlockingRpcContinuation extends BlockingRpcContinuation

• 直接复用父类的方法，且transforReply直接返回传入command的值。