ActiveMQ专题9 —— ActiveMQ的传输协议

谁践踏了优雅 2022-11-05 12:59 290阅读 0赞

## 前言 ##

如果你只是为了解在项目中如何使用activemq，以便工作中快速上手，那么前面七篇文章足矣  
[ActiveMQ专题0 —— 前言说明][ActiveMQ_0 _]  
[ActiveMQ专题1 —— 入门概述][ActiveMQ_1 _]  
[ActiveMQ专题2 —— ActiveMQ下载和安装（Linux版）][ActiveMQ_2 _ ActiveMQ_Linux]  
[ActiveMQ专题3 ——Java编码实现ActiveMQ通讯（Queue）][ActiveMQ_3 _Java_ActiveMQ_Queue]  
[ActiveMQ专题4 ——ActiveMQ专题4 ——Java编码实现ActiveMQ通讯（Topic）][ActiveMQ_4 _ActiveMQ_4 _Java_ActiveMQ_Topic]  
[ActiveMQ专题5 ——JMS规范和落地产品][ActiveMQ_5 _JMS]  
[ActiveMQ专题6 ——ActiveMQ的Broker][ActiveMQ_6 _ActiveMQ_Broker]  
[ActiveMQ专题7 —— Spring整合ActiveMQ][ActiveMQ_7 _ Spring_ActiveMQ]  
[ActiveMQ专题8 —— SpringBoot整合ActiveMQ][ActiveMQ_8 _ SpringBoot_ActiveMQ]  
 如 果 你 需 要 应 付 面 试 ， 提 升 自 己 ， 拿 到 更 好 的 薪 资 ， 那 么 你 可 以 继 续 往 下 学 习 \\color\{red\}如果你需要应付面试，提升自己，拿到更好的薪资，那么你可以继续往下学习 如果你需要应付面试，提升自己，拿到更好的薪资，那么你可以继续往下学习

## 体会面试题 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70]  
上图是Java入门程序写过的代码  
![在这里插入图片描述][20210306191124197.png]

## 查看官网 ##

[官网地址][Link 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 1]

## 怎么知道activemq默认是tcp协议，如何查看 ##

打开ActiveMQ安装目录所在的/conf/activemq.xml找到transportConnectors标签，内容如下：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 2]

由配置可知MQ的各种协议URL配置格式以及默认端口。

### 脚下留心 ###

在上文给出的配置信息中，  
URI描述信息的头部都是采用协议名称：例如  
描述amqp协议的监听端口时，采用的URI描述格式为“amqp://······”；  
描述Stomp协议的监听端口时，采用URI描述格式为“stomp://······”；  
唯独在进行openwire协议描述时，URI头却采用的“tcp://······”。  
 除 了 T C P 协 议 外 ， 其 他 协 议 的 n a m e 属 性 值 都 和 协 议 本 身 的 名 称 一 致 ， 为 何 T C P 协 议 的 n a m e 属 性 值 为 o p e n w i r e ？ \\color\{red\}除了TCP协议外，其他协议的name属性值都和协议本身的名称一致，为何TCP协议的name属性值为openwire？ 除了TCP协议外，其他协议的name属性值都和协议本身的名称一致，为何TCP协议的name属性值为openwire？

因 为 A c t i v e M Q 的 默 认 消 息 协 议 引 用 就 是 o p e n w i r e ， 所 以 其 默 认 协 议 T C P 和 默 认 端 口 61616 由 此 而 来 。 \\color\{red\}因为ActiveMQ的默认消息协议引用就是openwire，所以其默认协议TCP和默认端口61616由此而来。 因为ActiveMQ的默认消息协议引用就是openwire，所以其默认协议TCP和默认端口61616由此而来。  
 那 么 接 下 来 让 我 们 好 好 学 习 一 下 a c t i v e m q 协 议 \\color\{red\}那么接下来让我们好好学习一下activemq协议 那么接下来让我们好好学习一下activemq协议

## 协议种类 ##

#### TCP（Transmission Control Protocol） ####

1.  TCP是Broker默认配置的协议，默认监听端口是61616。 在网络传输数据前，必须要先序列化数据，消息是通过一个叫wireprotocol的来序列化成字节流。默认情况下，ActiveMQ把wireprotocol叫做OpenWire，它的目的是促使网络上的效率和数据快速交互。
2.  TCP连接的URI形式如：tcp://HostName:port?key=value&key=value，后面的参数是可选的
3.  TCP传输的的优点：

> TCP协议传输可靠性高，稳定性强 高效率：  
> 字节流方式传递，效率很高  
> 有效性、可用性：应用广泛，支持任何平台

#### NIO（New I/O API Protocol(NIO)） ####

1.  NIO协议和TCP协议类似，但NIO更侧重于底层的访问操作。它允许开发人员对同一资源可有更多的client调用和服务器端有更多的负载。
2.  适合使用NIO协议的场景：  
    2.1 可能有大量的Client去连接到Broker上，一般情况下，大量的Client去连接Broker是被操作系统的线程所限制的。因此，NIO的实现比TCP需要更少的线程去运行，所以建议使用NIO协议。  
    2.2 可能对于Broker有一个很迟钝的网络传输，NIO比TCP提供更好的性能。
3.  NIO连接的URI形式：nio://hostname:port?key=value&key=value
4.  关于Transport协议的可选配置参数可以参考官网http://activemq.apache.org/configuring-version-5-transports.html

#### AMQP（Advanced Message Queuing Protocol） ####

Advanced Message Queuing Protocol，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件限制。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 3]

#### STOMP（Streaming Text Orientation Message Protocol） ####

STOP，Streaming Text Orientation Message Protocol，是流文本定向消息协议，是一种为MOM(Message Oriented Middleware，面向消息中间件)设计的简单文本协议。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 4]

#### SSL（Secure Sockets Layer Protocol） ####

1.  SSL传输允许客户端使用TCP上的SSL连接到远程ActiveMQ代理。SSL传输允许客户端使用TCP套接字上的SSL连接到远程ActiveMQ代理。
2.  连接的URL形式： ssl://hostname:port?key=value  
    ![在这里插入图片描述][20210306193835475.png]

#### MQTT（Message Queuing Telemetry Transport） ####

MQTT，即消息队列遥测传输，是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当作传感器和致动器(比如通过Twitter让房屋联网)的通信协议。  
 可 能 会 报 错 \\color\{red\}可能会报错 可能会报错  
 原 因 是 ： 依 赖 包 和 底 层 改 变 了 \\color\{red\}原因是：依赖包和底层改变了 原因是：依赖包和底层改变了

#### VM ####

1.  VM本身不是协议。VM传输允许客户机在VM内部彼此连接，而不需要网络通信的开销。所使用的连接不是套接字连接，而是使用直接方法调用来启用高性能嵌入式消息传递系统。
2.  第一个使用VM连接的客户机将引导一个嵌入式代理。后续的连接将连接到同一代理。一旦所有到代理的VM连接都关闭了，嵌入式代理将自动关闭。

### 小总结 ###

除 了 T C P 和 N I O ， 其 他 在 生 产 用 得 特 别 少 ， 可 忽 略 \\color\{red\}除了TCP和NIO，其他在生产用得特别少，可忽略 除了TCP和NIO，其他在生产用得特别少，可忽略  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 5]

## Nio案例演示 ##

打开ActiveMQ安装目录所在的/conf/activemq.xml找到transportConnectors标签，内容如下：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 6]  
重启activemq

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 7]  
重新测试以前tcp的代码，测试成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 8]

将activemq的连接地址改为

public static final String ACTIVEMQ_URL = "nio://47.98.163.118:61618";

![在这里插入图片描述][20210306195036828.png]  
重新测试，也是能生产和消费

至 此 ， 我 们 的 n i o 整 合 完 毕 \\color\{red\}至此，我们的nio整合完毕 至此，我们的nio整合完毕

## nio案例演示增强 ##

### 目的 ###

上面是Openwire协议传输底层使用NIO网络IO模型。 如何让其他协议传输底层也使用NIO网络IO模型呢？  
![在这里插入图片描述][20210306195559181.png]  
 大 白 话 理 解 就 是 ： 在 此 之 间 T C P 使 用 61616 端 口 ， 而 n i o 使 用 61618 端 口 ， 每 次 切 换 N I O 和 T C P 时 需 要 更 换 端 口 ， 该 如 何 解 决 \\color\{red\}大白话理解就是：在此之间TCP使用61616端口，而nio使用61618端口，每次切换NIO和TCP时需要更换端口，该如何解决 大白话理解就是：在此之间TCP使用61616端口，而nio使用61618端口，每次切换NIO和TCP时需要更换端口，该如何解决  
解决方法  
![在这里插入图片描述][2021030619563167.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 9]

#### 操作步骤 ####

1.  修改配置文件activemq.xml

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 10]  
2. 测试

public static final String ACTIVEMQ_URL = "nio://47.98.163.118:61608";
    public static final String ACTIVEMQ_URL = "tcp://47.98.163.118:61608";

现 在 切 换 协 议 ， 不 需 要 改 端 口 了 \\color\{red\}现在切换协议，不需要改端口了 现在切换协议，不需要改端口了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 11]

## 连更文章 ##

[ActiveMQ专题0 —— 前言说明][ActiveMQ_0 _]  
[ActiveMQ专题1 —— 入门概述][ActiveMQ_1 _]  
[ActiveMQ专题2 —— ActiveMQ下载和安装（Linux版）][ActiveMQ_2 _ ActiveMQ_Linux]  
[ActiveMQ专题3 ——Java编码实现ActiveMQ通讯（Queue）][ActiveMQ_3 _Java_ActiveMQ_Queue]  
[ActiveMQ专题4 ——ActiveMQ专题4 ——Java编码实现ActiveMQ通讯（Topic）][ActiveMQ_4 _ActiveMQ_4 _Java_ActiveMQ_Topic]  
[ActiveMQ专题5 ——JMS规范和落地产品][ActiveMQ_5 _JMS]  
[ActiveMQ专题6 ——ActiveMQ的Broker][ActiveMQ_6 _ActiveMQ_Broker]  
[ActiveMQ专题7 —— Spring整合ActiveMQ][ActiveMQ_7 _ Spring_ActiveMQ]  
[ActiveMQ专题8 —— SpringBoot整合ActiveMQ][ActiveMQ_8 _ SpringBoot_ActiveMQ]  
[ActiveMQ专题9 —— ActiveMQ的传输协议][ActiveMQ_9 _ ActiveMQ]  
[ActiveMQ专题10 —— ActiveMQ的存储和持久化][ActiveMQ_10 _ ActiveMQ]  
[ActiveMQ专题11 —— ActiveMQ的存储和持久化2 （续篇）][ActiveMQ_11 _ ActiveMQ_2]  
[ActiveMQ专题12—— ActiveMQ之zookeeper集群][ActiveMQ_12_ ActiveMQ_zookeeper]  
[ActiveMQ专题13—— ActiveMQ高级特性][ActiveMQ_13_ ActiveMQ]  
[ActiveMQ专题14—— ActiveMQ高级特性2][ActiveMQ_14_ ActiveMQ_2]  
$\\color\{red\} 完结！后续推上有关消息队列的面试题目 $

## 小总结 ##

知 道 的 越 多 ， 不 知 道 的 越 多 ， 希 望 对 你 有 帮 助 ！ \\color\{red\}知道的越多，不知道的越多，希望对你有帮助！ 知道的越多，不知道的越多，希望对你有帮助！

[ActiveMQ_0 _]: https://blog.csdn.net/xiaozhegaa/article/details/114364355
[ActiveMQ_1 _]: https://blog.csdn.net/xiaozhegaa/article/details/114373971
[ActiveMQ_2 _ ActiveMQ_Linux]: https://blog.csdn.net/xiaozhegaa/article/details/114375436
[ActiveMQ_3 _Java_ActiveMQ_Queue]: https://blog.csdn.net/xiaozhegaa/article/details/114382174
[ActiveMQ_4 _ActiveMQ_4 _Java_ActiveMQ_Topic]: https://blog.csdn.net/xiaozhegaa/article/details/114383509
[ActiveMQ_5 _JMS]: https://blog.csdn.net/xiaozhegaa/article/details/114388827
[ActiveMQ_6 _ActiveMQ_Broker]: https://blog.csdn.net/xiaozhegaa/article/details/114449488
[ActiveMQ_7 _ Spring_ActiveMQ]: https://blog.csdn.net/xiaozhegaa/article/details/114450231
[ActiveMQ_8 _ SpringBoot_ActiveMQ]: https://blog.csdn.net/xiaozhegaa/article/details/114451603
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70]: /images/20221023/43c53265876247fd9f791af7ca22738c.png
[20210306191124197.png]: /images/20221023/f01d28daed8b4c6294287f7080aa8d56.png
[Link 1]: http://activemq.apache.org/configuring-version-5-transports.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 1]: /images/20221023/5c3c468f9ee748bc9a0493267be987e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 2]: /images/20221023/a5300383cea242a2b193a7c65b19fd0a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 3]: /images/20221023/fd157fe7286242f4a41a2392624fd4ee.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 4]: /images/20221023/e17ee126ae3d4cf58d77ed768ba9b35c.png
[20210306193835475.png]: /images/20221023/a4ee7919d5a34a308e2ac386ea652bdb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 5]: /images/20221023/1cd8c2b8a52c40ba871f8c3aa24aaf2a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 6]: /images/20221023/9906f650cfaa4802a8606b70d9588c4c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 7]: /images/20221023/f0a49bc62d3e40ba89397b88d36e0e55.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 8]: /images/20221023/597b59f2c55a46c2bc425b691d680e19.png
[20210306195036828.png]: /images/20221023/b5458d69a5954894a91df3923059e187.png
[20210306195559181.png]: /images/20221023/b3ec9d381d0648768de0299ea48b392f.png
[2021030619563167.png]: /images/20221023/ee8b0a890c8e4de49b27e95308e726de.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 9]: /images/20221023/8c9340a77f4d4c99b199833934d24d85.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 10]: /images/20221023/8d6f41fe348046d5bf769da8ccb6bc7f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW96aGVnYWE_size_16_color_FFFFFF_t_70 11]: /images/20221023/4d3f51b504124c0b91254027a9df8dab.png
[ActiveMQ_9 _ ActiveMQ]: https://blog.csdn.net/xiaozhegaa/article/details/114452474
[ActiveMQ_10 _ ActiveMQ]: https://blog.csdn.net/xiaozhegaa/article/details/114457556
[ActiveMQ_11 _ ActiveMQ_2]: https://blog.csdn.net/xiaozhegaa/article/details/114461996
[ActiveMQ_12_ ActiveMQ_zookeeper]: https://blog.csdn.net/xiaozhegaa/article/details/114464565
[ActiveMQ_13_ ActiveMQ]: https://blog.csdn.net/xiaozhegaa/article/details/114494510
[ActiveMQ_14_ ActiveMQ_2]: https://blog.csdn.net/xiaozhegaa/article/details/114500737