七、ActiveMQ的传输协议

ActiveMQ的传输协议

  • 一、是什么
  • 二、协议
    • 1.TCP(默认)
    • 2.NIO
    • 3.AMQP
    • 4.STOMP
    • 5.SSL
    • 6.MQTT
    • 7 WS
  • 三、NIO配置案例
    • 1.修改activemq.xml
    • 2.重启
    • 3.生产者/消费者
    • 4.性能提升
    • 4.1 配置
    • 4.2 生产者/消费者

一、是什么

  • 官网地址：http://activemq.apache.org/configuring-version-5-transports.html
  • ActiveMQ支持的client-broker通讯协议有：TVP、NIO、UDP、SSL、Http(s)、VM。
    • 其中配置Transport Connector的文件在ActiveMQ安装目录的conf/activemq.xml中的<transportConnectors>标签之内。
      在这里插入图片描述
  • URI描述信息的头部都是采用协议名称，唯独在进行openwire协议描述时，URI头却采用的“tcp://······”。这是因为ActiveMQ中默认的消息协议就是openwire。

二、协议

1.TCP(默认)

  • Transmission Control Protocol(TCP)
    • 1.这是默认的Broker配置，TCP的Client监听端口61616
    • 2.在网络传输数据前，必须要先序列化数据，消息是通过一个叫wire protocol的来序列化成字节流。
    • 3.TCP连接的URI形式如：tcp://HostName:port?key=value&key=value，后面的参数是可选的。
    • 4.TCP传输的的优点：
      • TCP协议传输可靠性高，稳定性强
      • 高效率：字节流方式传递，效率很高
      • 有效性、可用性：应用广泛，支持任何平台
  • 协议参数文档地址：https://activemq.apache.org/components/classic/documentation/tcp-transport-reference

2.NIO

  • New I/O API Protocol(NIO)
    • 1.NIO协议和TCP协议类似，但NIO更侧重于底层的访问操作。它允许开发人员对同一资源可有更多的client调用和服务器端有更多的负载。
    • 2.适合使用NIO协议的场景：
      • 可能有大量的Client去连接到Broker上，一般情况下，大量的Client去连接Broker是被操作系统的线程所限制的。因此，NIO的实现比TCP需要更少的线程去运行，所以建议使用NIO协议。
      • 可能对于Broker有一个很迟钝的网络传输，NIO比TCP提供更好的性能。
    • 3.NIO连接的URI形式：nio://hostname:port?key=value&key=value
  • 协议参数文档地址：https://activemq.apache.org/components/classic/documentation/nio-transport-reference
  • 默认端口：61618
  • NIO和TCP协议的编码是一样的，所以只需要替换URL的协议即可实现切换。

3.AMQP

  • Advanced Message Queuing Protocol（AMQP）
    • 一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件限制。
  • 默认端口：5672
  • 注意：编码和TCP不一样

4.STOMP

  • Streaming Text Orientation Message Protocol（STOMP）
    • 是流文本定向消息协议，是一种为MOM(Message Oriented Middleware，面向消息中间件)设计的简单文本协议。
  • 默认端口：61613

5.SSL

  • Secure Sockets Layer Protocol（SSL）

6.MQTT

  • Message Queuing Telemetry Transport（MQTT）：消息队列遥测传输)
    • IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当作传感器和致动器(比如通过Twitter让房屋联网)的通信协议。
  • 默认端口：1883
  • 扩展：https://github.com/fusesource/mqtt-client

7 WS

  • websocket(WS)
  • 默认端口：61614

三、NIO配置案例

1.修改activemq.xml

  • 打开activemq的配置文件，在active安装目录下：conf/activemq.xml
  • 将下面的内容复制到<transportConnectors>标签内
<transportConnector name="nio" uri="nio://0.0.0.0:61618?trace=true" />

在这里插入图片描述

  • 如果你不特别指定ActiveMQ的网络监听端口，那么这些端口都讲使用BIO网络IO模型
  • 所以为了首先提高单节点的网络吞吐性能，我们需要明确指定ActiveMQ网络IO模型。
  • 如上所示：URI格式头以“nio”开头，表示这个端口使用以TCP协议为基础的NIO网络IO模型。

2.重启

./bin/active
  • 去控制台查看，是否加成功了。
    在这里插入图片描述

3.生产者/消费者

  • NIO和TCP协议的编码是一样的，所以只需要替换URL的协议即可实现切换。
package com.qingsi.activemq;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class JmsProduce {// ACTIVEMQ_URL重点看public static final String ACTIVEMQ_URL = "nio://192.168.86.128:61618";public static final String QUEUE_NAME = "transport_nio";public static void main(String[] args) throws JMSException {//1.创建连接工厂，按照给定的URL，采用默认的用户名密码ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2.通过连接工厂,获得connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3.创建会话session//两个参数transacted=事务,acknowledgeMode=确认模式(签收)//开启事务需要commitSession session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4.创建目的地(具体是队列queue还是主题topic)Queue queue = session.createQueue(QUEUE_NAME);//5.创建消息的生产者,并设置不持久化消息MessageProducer producer = session.createProducer(queue);//6.通过使用消息生产者,生产三条消息,发送到MQ的队列里面// 7.发送消息for (int i = 0; i < 3; i++) {TextMessage textMessage = session.createTextMessage("tx msg--" + i);producer.send(textMessage);}//8.关闭资源producer.close();session.close();connection.close();}}

4.性能提升

  • 问题：URI格式以"nio"开头，代表这个端口使用TCP协议为基础的NIO网络模型。但是这样的设置方式，只能使这个端口支持Openwire协议。
    在这里插入图片描述
  • 需要将所有的BIO模型，都替换成NIO模型，性能得到提升。

4.1 配置

  • 官网地址：https://activemq.apache.org/components/classic/documentation/auto
    在这里插入图片描述
  • 将下面的配置，写入到activemq.xml
<transportConnector name="auto+nio" uri="auto+nio://0.0.0.0:61608?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600&amp;org.apache.activemq.transport.nio.SelectorManager.corePoolSize=20&amp;org.apache.activemq.transport.nio.SelectorManager.maximumPoolSize=50" />

在这里插入图片描述

  • 重启
./bin/activemq restart

4.2 生产者/消费者

  • 都是只改动了URL，其他的代码一样。所以下面举例了生产者的URL
  • 只要
package com.qingsi.activemq;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class JmsProduce {// ACTIVEMQ_URL：下面就是 NIO协议+NIO模型public static final String ACTIVEMQ_URL = "nio://192.168.86.128:61608";// public static final String ACTIVEMQ_URL = "tcp://192.168.86.128:61608"; 这样就是 TCP协议+NIO模型public static final String QUEUE_NAME = "nio_auto";public static void main(String[] args) throws JMSException {//1.创建连接工厂，按照给定的URL，采用默认的用户名密码ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2.通过连接工厂,获得connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3.创建会话session//两个参数transacted=事务,acknowledgeMode=确认模式(签收)//开启事务需要commitSession session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4.创建目的地(具体是队列queue还是主题topic)Queue queue = session.createQueue(QUEUE_NAME);//5.创建消息的生产者,并设置不持久化消息MessageProducer producer = session.createProducer(queue);//6.通过使用消息生产者,生产三条消息,发送到MQ的队列里面// 7.发送消息for (int i = 0; i < 3; i++) {TextMessage textMessage = session.createTextMessage("tx msg--" + i);producer.send(textMessage);}//8.关闭资源producer.close();session.close();connection.close();}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/686611.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Mysql知识点汇总

Mysql知识点汇总

Mysql知识点汇总 1. Mysql基本场景的简单语句。2. Mysql的增删改查&#xff0c;统计表中的成绩最好的两个同学的名字&#xff0c;年级等。3&#xff1a;请使用多种方法查询每个学生的每门课分数>80的学生姓名4、order by&#xff0c;group by&#xff0c;子查询4.1、having和…
阅读更多...
Apache Httpd 常见漏洞解析（全）

Apache Httpd 常见漏洞解析（全）

一、Apache HTTPD 换行解析漏洞 漏洞编号&#xff1a;CVE-2017-15715 Apache HTTPD是一款HTTP服务器&#xff0c;它可以通过mod_php来运行PHP网页。 其2.4.0~2.4.29版本中存在一个解析漏洞。 在解析PHP时&#xff0c;1.php\x0A将被按照PHP后缀进行解析&#xff0c;导致绕过…
阅读更多...
XSS数据接收平台

XSS数据接收平台

一.使用xss数据接收平台的好处&#xff1a; 正常执行反射型xss和存储型xss&#xff0c;反射型xss在执行poc时&#xff0c;会直接在页面弹出执行注入的poc代码&#xff1b;存储型则是&#xff0c;在将poc代码注入用户的系统中后&#xff0c;用户访问有存储型xss的地方&#xff…
阅读更多...
SpringCloud-Nacos集群搭建

SpringCloud-Nacos集群搭建

本文详细介绍了如何在SpringCloud环境中搭建Nacos集群&#xff0c;为读者提供了一份清晰而详尽的指南。通过逐步演示每个关键步骤&#xff0c;包括安装、配置以及Nginx的负载均衡设置&#xff0c;读者能够轻松理解并操作整个搭建过程。 一、Nacos集群示意图 Nacos&#xff0…
阅读更多...
机器学习西瓜书之决策树

机器学习西瓜书之决策树

目录 算法原理剪枝处理连续值处理缺失值处理多变量决策树 算法原理 从逻辑角度&#xff1a;通过一系列if-else语句进行多重判断&#xff0c;比如白富美的判断条件&#xff08;“白”“富”“美”&#xff09;。 从几何角度&#xff1a;根据定义的标准进行样本空间的划分。 以二…
阅读更多...
MySQL数据库基础（六）：DDL数据库操作

MySQL数据库基础（六）：DDL数据库操作

文章目录 DDL数据库操作 一、MySQL的组成结构 二、数据库的基本操作 1、创建数据库 2、查询数据库 3、删除数据库 4、选择数据库 三、总结 DDL数据库操作 一、MySQL的组成结构 注&#xff1a;我们平常说的MySQL&#xff0c;其实主要指的是MySQL数据库管理软件。 一个M…
阅读更多...
【C++航海王：追寻罗杰的编程之路】string类

【C++航海王：追寻罗杰的编程之路】string类

目录 1 -> 为什么学习string类&#xff1f; 1.1 -> C语言中的字符串 2 -> 标准库中的string类 2.1 -> string类 2.2 -> string类的常用接口 3 -> string类的模拟实现 3.1 -> 经典的string类问题 3.2 -> 浅拷贝 3.3 -> 深拷贝 3.3.1 ->…
阅读更多...
【大厂AI课学习笔记】【2.1 人工智能项目开发规划与目标】（5）数据管理

【大厂AI课学习笔记】【2.1 人工智能项目开发规划与目标】（5）数据管理

今天学习了数据管理&#xff0c;以及数据管理和数据治理的区别和联系。 数据管理&#xff1a;利用计算机硬件和软件技术对数据进行有效的收集、存储、处理和应用的过程其目的在于充分有效地发挥数据的作用。 实现数据有效管理的关键是数据组织。 数据管理和数据治理的区别&am…
阅读更多...
《Go 简易速速上手小册》第9章：数据库交互（2024 最新版）

《Go 简易速速上手小册》第9章：数据库交互（2024 最新版）

文章目录 9.1 连接数据库 - Go 语言的海底宝藏之门9.1.1 基础知识讲解安装数据库驱动数据库连接 9.1.2 重点案例&#xff1a;用户信息管理系统准备数据库Go 代码实现连接数据库添加新用户查询用户信息用户登录验证主函数 9.1.3 拓展案例 1&#xff1a;批量添加用户准备数据库Go…
阅读更多...
mpack简明教程

mpack简明教程

文章目录 摘要MessagePack简介MPACK的简单使用在定长的buffer存储不定长的数据读取截断的数据 摘要 本文先简单介绍MessagePack的基本概念。 然后&#xff0c;介绍一个MessagePack C API - MPack的通常使用。 接着尝试对MPack截断数据的读取。 注&#xff1a;本文完整代码见…
阅读更多...
【制作100个unity游戏之25】3D背包、库存、制作、快捷栏、存储系统、砍伐树木获取资源、随机战利品宝箱9（附带项目源码）

【制作100个unity游戏之25】3D背包、库存、制作、快捷栏、存储系统、砍伐树木获取资源、随机战利品宝箱9（附带项目源码）

效果演示 文章目录 效果演示系列目录前言箱子库存源码完结 系列目录 前言 欢迎来到【制作100个Unity游戏】系列&#xff01;本系列将引导您一步步学习如何使用Unity开发各种类型的游戏。在这第25篇中&#xff0c;我们将探索如何用unity制作一个3D背包、库存、制作、快捷栏、存…
阅读更多...
信号系统之卷积性质

信号系统之卷积性质

1 常见的脉冲响应 最简单的脉冲响应是一个δ函数&#xff0c;如图7-1所示。也就是说&#xff0c;输入上的脉冲在输出上产生相同的脉冲。这意味着所有信号都毫无变化地通过系统。将任何信号与 δ函数进行卷积都会产生完全相同的信号。从数学上来说&#xff0c;可以这样写&#…
阅读更多...
元器件焊盘的PCB处理方式分析与总结

元器件焊盘的PCB处理方式分析与总结

对于高速信号走线的特性阻抗&#xff0c;都需要按照实际要求进行精度控制&#xff0c;所以&#xff0c;任何因设计因素带来的阻抗波动都应该进行优化&#xff0c;如下图所示&#xff0c;为一个12层板设计中的50Ω微带走线&#xff0c;需要在走线之上放置电感&#xff1b; 但是&…
阅读更多...
枚举（C/C++）

枚举（C/C++）

没有什么成套的算法&#xff0c;直接上例题&#xff01;&#xff01; 例题1&#xff1a;赢球票 代码&#xff1a; #include <bits/stdc.h> using namespace std;const int maxn 105; int n,num1[maxn],num2[maxn],cnt,cnt1,sum,ans;int check1()//检查剩余个数 {cnt1…
阅读更多...
Guava RateLimiter单机实战指南

Guava RateLimiter单机实战指南

欢迎来到我的博客&#xff0c;代码的世界里&#xff0c;每一行都是一个故事 Guava RateLimiter单机实战指南 前言maven坐标引入业务实现重要参数和方法关于warmupPeriod实战 前言 想象一下你是一位大厨&#xff0c;正在烹饪美味佳肴。突然之间&#xff0c;前来就餐的人潮如潮水…
阅读更多...
得物面试：Redis用哈希槽，而不是一致性哈希，为什么？

得物面试：Redis用哈希槽，而不是一致性哈希，为什么？

尼恩说在前面 在40岁老架构师 尼恩的读者交流群(50)中&#xff0c;最近有小伙伴拿到了一线互联网企业如得物、阿里、滴滴、极兔、有赞、希音、百度、网易、美团的面试资格&#xff0c;遇到很多很重要的面试题&#xff1a; Redis为何用哈希槽而不用一致性哈希&#xff1f; 最近…
阅读更多...
WebServer 之 http连接处理（下）

WebServer 之 http连接处理（下）

目录 ✊请求报文--解析 流程图 && 状态机 状态机 -- 状态转移图 主状态机 从状态机 http 报文解析 HTTP_CODE 含义 从状态机 逻辑 主状态机 逻辑 &#x1f41e;请求报文--响应 基础API stat mmap iovec writev 流程图 HTTP_CODE 含义(2) 代码分析 …
阅读更多...
图表示学习 Graph Representation Learning chapter2 背景知识和传统方法

图表示学习 Graph Representation Learning chapter2 背景知识和传统方法

图表示学习 Graph Representation Learning chapter2 背景知识和传统方法 2.1 图统计和核方法2.1.1 节点层次的统计和特征节点的度 节点中心度聚类系数Closed Triangles, Ego Graphs, and Motifs 图层次的特征和图的核节点袋Weisfieler–Lehman核Graphlets和基于路径的方法 邻域…
阅读更多...
qt-C++笔记之捕获鼠标滚轮事件并输出滚轮角度增量

qt-C++笔记之捕获鼠标滚轮事件并输出滚轮角度增量

qt-C笔记之捕获鼠标滚轮事件并输出滚轮角度增量 code review! 文章目录 qt-C笔记之捕获鼠标滚轮事件并输出滚轮角度增量1.运行2.main.cpp3.main.pro 1.运行 2.main.cpp #include <QApplication> #include <QWidget> #include <QWheelEvent> #include <…
阅读更多...
Android 回退页面不是上个页面

Android 回退页面不是上个页面

问题 Android 回退页面不是上个页面 详细问题 笔者进行Android 开发&#xff0c;点击返回上一层&#xff0c;显示页面不是上个页面&#xff0c;而是之前的某个页面 页面跳转代码 private void navigateToActivity(Context context, Class<?> targetActivityClass) {I…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023