IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

四、RabbitMQ-客户端源码之Frame

IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

作者:朱小厮 | 出自:https://hiddenpps.blog.csdn.net/column/info/14800

Frame是指AMQP协议层面的通信帧(一个正式定义的连接数据包)。
我们来看下Frame类中的成员变量有哪些:

/** Frame type code */
public final int type;

/** Frame channel number, 0-65535 */
public final int channel;

/** Frame payload bytes (for inbound frames) */
private final byte[] payload;

/** Frame payload (for outbound frames) */
private final ByteArrayOutputStream accumulator;

Frame里的三个成员变量:type, channel, payload是真正和报文有关的。accumulator是为了方便内部编程的一个变量。Frame类就是对这个玩意儿捯饬捯饬,没有什么难度,好奇的同学可以自己翻看下,本文主要来阐述下AMQP中的Frame的一些信息。

一个通信帧的协议层面的结构如下:

序号 名称 占用字节
1 frame type 1B
2 channel number 2B
3 payload length 4B
4 payload [0-N]B
5 FRAME_END(结束帧) 1B(0xCE)

这样可以知道:一个通信帧的最小大小为:1B+2B+4B+0B+1B=8B.

AMQP 定义了如下的帧类型:

  1. Type = 1, “METHOD”: 方法帧
  2. Type = 2, “HEADER”: 内容头帧
  3. Type = 3, “BODY”: 内容体帧.
  4. Type = 8, “HEARTBEAT”: 心跳帧.

通道编号为0的代表全局连接中的所有帧,1-65535代表特定通道的帧.

方法帧
type=1, payload包含以下内容:
classId:2B
methodId:2B
argument:NB

内容头帧
type=2,payload包含以下内容
classId:2B
weight:2B
BodySize:8B
property flags:2B
properties: NB

内容帧
type=3, payload不进行具体解析,

心跳帧
tpye=8,没有payload。心跳帧的channel number必须为0。

附录:RabbitMQ-客户端源码系列文章


Warning: A non-numeric value encountered in /data/wangzhan/tech.souyunku.com.wp/wp-content/themes/dux/functions-theme.php on line 1154
赞(100) 打赏



未经允许不得转载:搜云库技术团队 » 四、RabbitMQ-客户端源码之Frame

IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码
IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

评论 抢沙发

大前端WP主题 更专业 更方便

联系我们联系我们

觉得文章有用就打赏一下文章作者

微信扫一扫打赏

微信扫一扫打赏


Fatal error: Uncaught Exception: Cache directory not writable. Comet Cache needs this directory please: `/data/wangzhan/tech.souyunku.com.wp/wp-content/cache/comet-cache/cache/https/tech-souyunku-com/index.q`. Set permissions to `755` or higher; `777` might be needed in some cases. in /data/wangzhan/tech.souyunku.com.wp/wp-content/plugins/comet-cache/src/includes/traits/Ac/ObUtils.php:367 Stack trace: #0 [internal function]: WebSharks\CometCache\Classes\AdvancedCache->outputBufferCallbackHandler() #1 /data/wangzhan/tech.souyunku.com.wp/wp-includes/functions.php(5109): ob_end_flush() #2 /data/wangzhan/tech.souyunku.com.wp/wp-includes/class-wp-hook.php(303): wp_ob_end_flush_all() #3 /data/wangzhan/tech.souyunku.com.wp/wp-includes/class-wp-hook.php(327): WP_Hook->apply_filters() #4 /data/wangzhan/tech.souyunku.com.wp/wp-includes/plugin.php(470): WP_Hook->do_action() #5 /data/wangzhan/tech.souyunku.com.wp/wp-includes/load.php(1097): do_action() #6 [internal function]: shutdown_action_hook() #7 {main} thrown in /data/wangzhan/tech.souyunku.com.wp/wp-content/plugins/comet-cache/src/includes/traits/Ac/ObUtils.php on line 367