七、ActiveMQ的传输协议

这篇具有很好参考价值的文章主要介绍了七、ActiveMQ的传输协议。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、是什么

  • 官网地址: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>标签之内。
      七、ActiveMQ的传输协议,# ActiveMQ,activemq
  • 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的传输协议,# ActiveMQ,activemq

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

2.重启

./bin/active
  • 去控制台查看,是否加成功了。
    七、ActiveMQ的传输协议,# ActiveMQ,activemq

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=确认模式(签收)
        //开启事务需要commit
        Session 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协议。
    七、ActiveMQ的传输协议,# ActiveMQ,activemq
  • 需要将所有的BIO模型,都替换成NIO模型,性能得到提升。

4.1 配置

  • 官网地址:https://activemq.apache.org/components/classic/documentation/auto
    七、ActiveMQ的传输协议,# ActiveMQ,activemq
  • 将下面的配置,写入到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" />

七、ActiveMQ的传输协议,# ActiveMQ,activemq文章来源地址https://www.toymoban.com/news/detail-825425.html

  • 重启
./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=确认模式(签收)
        //开启事务需要commit
        Session 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();

    }

}

到了这里,关于七、ActiveMQ的传输协议的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 如何使用ActiveMQ

    ActiveMQ是Apache的一款开源消息总线,主要用来做消息的分发。使用ActiveMQ,通常需要以下步骤: 一、启动ActiveMQ 首先需要下载ActiveMQ,然后进行启动。启动后,可以在控制台创建队列,初始用户名和密码通常为admin/admin。 二、编写生产者代码 创建一个ConnectionFactory对象,需要指

    2024年01月17日
    浏览(32)
  • 应该下那个 ActiveMQ

    最近在搞 ActiveMQ 的时候,发现有 2 个 ActiveMQ 可以下载。 应该下那个呢? JMS 即Java Message Service,是JavaEE的消息服务接口。 JMS主要有两个版本:1.1和2.0。 2.0和1.1相比,主要是简化了收发消息的代码。 所谓消息服务,就是两个进程之间,通过消息服务器传递消息。 实际上Acti

    2024年02月08日
    浏览(34)
  • 二、ActiveMQ安装

    环境:Centos7.9 安装ActiveMQ版本:5.15.9 JDK8 安装教程:https://qingsi.blog.csdn.net/article/details/136129131 ActiveMQ版本:5.15.9 任意版本下载地址 5.15.9版本下载地址 如果有防火墙,需要开通端口 http://127.0.0.1:8161/admin 默认的用户名和密码是admin/admin

    2024年02月19日
    浏览(31)
  • ActiveMQ面试题(二)

    死信队列 ActiveMQ 中的消息重发时间间隔和重发次数吗? 如果你想在消息处理失败后,不被服务器删除,还能被其他消费者处理或重试,可以关闭AUTO_ACKNOWLEDGE,将 ack 交由程序自己处理。那如果使用了 AUTO_ACKNOWLEDGE,消息是什么时候被确认的,还有没有阻止消息确认的方法?有

    2024年02月07日
    浏览(34)
  • ActiveMQ基础学习简单记录

    本文为Activemq简单入门文章 JMS即Java Message Service,是JavaEE的消息服务接口。JMS主要有两个版本:1.1和2.0。2.0和1.1相比,主要是简化了收发消息的代码。 JMS为Java程序提供了一种通用方法, 用于创建、发送、接收和读取企业消息系统中的消息。 JMS是一组接口定义,如果我们要使用

    2024年02月06日
    浏览(43)
  • Zabbix监控ActiveMQ

    当我们在线上使用了 ActiveMQ 后,我们需要对一些参数进行监控,比如 消息是否有阻塞,哪个消息队列阻塞了,总的消息数是多少等等。下面我们就通过 Zabbix 结合 Python 脚本来实现对 ActiveMQ 的监控。 一、创建 Activemq Python 监控脚本 因为 CentOS 系统默认安装的是 Python2.7 ,为了

    2024年02月14日
    浏览(38)
  • ActiveMQ 02 常用API

    事务 用来提交/回滚事务 Purge 清理消息 签收模式 签收代表接收端的session已收到消息的一次确认,反馈给broker ActiveMQ支持自动签收与手动签收 Session.AUTO_ACKNOWLEDGE 当客户端从receiver或onMessage成功返回时,Session自动签收客户端的这条消息的收条。 Session.CLIENT_ACKNOWLEDGE 客户端通过

    2024年04月16日
    浏览(58)
  • 如何使用ActiveMQ详细讲解

    ActiveMQ 是一款流行的消息中间件,支持多种通信协议和消息模式,包括点对点、发布/订阅、事务处理等。下面是使用 ActiveMQ 的基本步骤: 1. 下载和安装 ActiveMQ: 2. 启动 ActiveMQ 服务器: 3. 访问 ActiveMQ 的 Web 控制台: 4. 创建队列或主题: 5. 发送消息: 6. 接收消息: 以上是使

    2024年01月17日
    浏览(43)
  • 什么是 Apache ActiveMQ?

    ActiveMQ 是一种流行的消息传递服务,可促进企业系统中大规模的不同数据。在本 ActiveMQ 教程中,我们概述了 ActiveMQ、它的优点、它的工作原理以及何时应该使用它。 什么是 ActiveMQ? ActiveMQ 是一种流行的开源消息传递服务,它构建在 Java 之上。它用作面向消息的中间件 ( MoM

    2024年02月07日
    浏览(45)
  • Activemq存储KahaDb详解

    ActiveMQ在不提供持久化的情况下,数据保存在内存中,一旦应用崩溃或者重启之后,数据都将会丢失,这显然在大部分情况下是我们所不希望的。对此ActiveMQ提供了两种持久化方式以供选择。 kahaDB是一个基于文件,支持事务的、可靠,高性能,可扩展的消息存储器,目前是a

    2024年02月04日
    浏览(31)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包