配置ActiveMQ的Transport Connectors

2024-04-23 07:38

本文主要是介绍配置ActiveMQ的Transport Connectors,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、概念
从broker的角度来看,transport connector是用于接受和监听来自客户端的连接请求的一种机制。比如在”conf/activemq.xml“这个配置文件中可以找到:
[html]  view plain copy
  1. <!-- The transport connectors ActiveMQ will listen to -->  
  2.     <transportConnectors>  
  3.         <transportConnector name="openwire" uri="tcp://localhost:61616"  
  4.             discoveryUri="multicast://default"/>  
  5.         <transportConnector name="ssl" uri="ssl://localhost:61617"/>  
  6.         <transportConnector name="stomp" uri="stomp://localhost:61613"/>  
  7.         <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>  
  8.     </transportConnectors>  


可以看到在<transportConnectors>中包含了多个<transportConnector>对象,每一个对象都定义了监听的地址、端口以及使用的协议。不同的<transportConnector>的name和uri属性值必须不同。以上的配置定义了四个不同的<transportConnector>,那在启动ActiveMQ时,就可以看到如下输出:
    
[plain]  view plain copy
  1. INFO TransportServerThreadSupport - Listening for connections at:  
  2.     tcp://localhost:61616  
  3.     INFO TransportConnector - Connector openwire Started  
  4.     INFO TransportServerThreadSupport - Listening for connections at:  
  5.     ssl://localhost:61617  
  6.     INFO TransportConnector - Connector ssl Started  
  7.     INFO TransportServerThreadSupport - Listening for connections at:  
  8.     stomp://localhost:61613  
  9.     INFO TransportConnector - Connector stomp Started  
  10.     INFO TransportServerThreadSupport - Listening for connections at:  
  11.     xmpp://localhost:61222  
  12.     INFO TransportConnector - Connector xmpp Started  


    从客户端的角度来看,transportConnector的URI是用于和broker建立连接,以通过该连接来发送和接受消息。例如,以下Java代码通过之前配置文件中定义的”openwire“那个transportConnector来与broker建立连接:
 
[java]  view plain copy
  1. ActiveMQConnectionFactory factory =  
  2.       new ActiveMQConnectionFactory("tcp://localhost:61616");  
  3.   Connection connection = factory.createConnection();  
  4.       connection.start();  
  5.   Session session =  
  6.       connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  


二、Transport Connector的可用协议
    ActiveMQ最常用的场景是作为一个单独的程序运行,而客户端(包括消息生产者和消费者)通过某种网络协议来与ActiveMQ建立连接,并进行消息的收发。ActiveMQ支持多种网络协议,具体如下:
    1. 传输控制协议  TCP
    由于TCP具有可靠传输的特性,它在ActiveMQ中也是最长使用的一种协议。在默认的配置中,TCP连接的端口为61616.TCP Connector的URI的配置语法如下:
    tcp://hostname:port?key=value&key=value
    加粗的部分为必须部分,剩余的key/value部分为可选部分,不同的key/value用"&"符号分开。具体的可选部分详细介绍可以在http://activemq.apache.org/tcp-transport-reference.html这个网址中找到。可选部分用于定义broker的一些额外的行为,如假设我们进行如下配置:
    <transportConnector name="tcp"uri="tcp://localhost:61616?trace=true"/>
    则broker会在日志中记录经过这个connector所发送的每一条消息,这对于调试会有很大的帮助。
    2. New I/O API协议(NIO)
     NIO是在Java SE 1.4开始引进的,用于提供一种网络编程和访问现代操作系统的底层I/O.NIO中使用最多的两种特性是selector和non-blocking I/O,它们使得开发人员可以使用相同的资源来处理更多的网络连接(如果不使用NIO技术,系统将无法承受这么多的网络连接)。
    从客户端的角度来看,NIO transport connector与TCP connector是相同的,这是因为NIO connector实际上采用TCP来传输数据。唯一不同的是,NIO transport connector是利用NIO API实现的。这使得NIO在以下几种情况下更为适合:
  • 你有大量的客户端需要连接broker。通常,与broker之间的连接数是受操作系统的线程数限制的,由于相比TCP connector而言,NIO connector会占用更少的线程。所以,当TCP connector无法满足要求时,可以考虑使用NIO进行替代。
  • 你到broker之间存在严重的网路阻塞。NIO connector会比TCP connector拥有更好的性能,因为它会使用更少的资源。
    NIO的配置语法与TCP的配置相似,只需将tcp替换成nio即可:
    nio://hostname:port?key=value
    NIO的默认监听端口是61618,它也有trace这个可以,用于决定是否记录所有传输的消息。
3. 用户数据包协议(UDP)
    根据UDP的特性,它一般用于要求传出速率快,且能够忍受丢包发生的情况。你可以使用UDP协议来连接ActiveMQ的UDP connector。它的URI语法与TCP及NIO基本一致:
    udp://hostname:port?key=value
    完整的参考内容可以在http://activemq.apache.org/udp-transport-reference.html中找到,通常以下两种情况可以考虑使用UDP:
  • broker有防火墙的保护,只能通过UDP端口来访问;
  • 消息传送对实时性要求非常高,可以通过UDP来尽可能的消除网络延迟;
    由于UDP的不可靠特性,所以在使用时,必须考虑丢包时的处理。
4. SSL协议(Secure Sockets Layer Protocol)
当broker暴露于不安全的网络环境,而你的数据需要保密时,可以使用SSL。它是用于通过TCP传输加密数据的一种协议,它通过一对钥匙(公钥和私钥)来保证一条安全通道。ActiveMQ提供SSL connector,它的语法如下:
ssl://hostname:port?key=value
    由于ssl采用TCP进行传输,它的选项跟TCP是一致的,当然如果你需要更加详细的说明,可以参考:http://activemq.apache.org/ssl-transport-reference.html,另外需要说明的是ssl connector默认监听616167端口。
    与之前介绍的3中协议不同,ssl connector还需要ssl证书来保证其正确运行。JSSE提供了两类文件分别用于存储key和certification,用于存储key的文件称为keystores,存储certification的称为truststores.
5.HTTP/HTTPS协议
    有些服务器的防火墙设置了只能提供HTTP访问,这时便是HTTP/HTTPS connector的地盘了。ActiveMQ实现的HTTP/HTTPS协议用于传输XML数据,它们的配置语法分别如下:
    http://hostname:port?key=value
    https://hostname:port?key=value
6. 虚拟机协议(virtual machine protocol, VM)
    除了以上介绍的5中协议外,ActiveMQ还可以嵌入Java应用程序中,这样Java程序与broker之间的连接不会经过网络,而是在同一个JVM中进行,从而可以减少网络传输,大幅提升性能。这种方式成为虚拟机协议。
    使用VM协议的broker拥有与其它协议相同的功能,VM connector的配置语法如下:
    vm://brokerName?key=value
    关于VM connector具体可以参见http://activemq.apache.org/vm-transport-reference.html。

这篇关于配置ActiveMQ的Transport Connectors的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/928176

相关文章

Zookeeper安装和配置说明

一、Zookeeper的搭建方式 Zookeeper安装方式有三种,单机模式和集群模式以及伪集群模式。 ■ 单机模式:Zookeeper只运行在一台服务器上,适合测试环境; ■ 伪集群模式:就是在一台物理机上运行多个Zookeeper 实例; ■ 集群模式:Zookeeper运行于一个集群上,适合生产环境,这个计算机集群被称为一个“集合体”(ensemble) Zookeeper通过复制来实现

CentOS7安装配置mysql5.7 tar免安装版

一、CentOS7.4系统自带mariadb # 查看系统自带的Mariadb[root@localhost~]# rpm -qa|grep mariadbmariadb-libs-5.5.44-2.el7.centos.x86_64# 卸载系统自带的Mariadb[root@localhost ~]# rpm -e --nodeps mariadb-libs-5.5.44-2.el7

hadoop开启回收站配置

开启回收站功能,可以将删除的文件在不超时的情况下,恢复原数据,起到防止误删除、备份等作用。 开启回收站功能参数说明 (1)默认值fs.trash.interval = 0,0表示禁用回收站;其他值表示设置文件的存活时间。 (2)默认值fs.trash.checkpoint.interval = 0,检查回收站的间隔时间。如果该值为0,则该值设置和fs.trash.interval的参数值相等。

NameNode内存生产配置

Hadoop2.x 系列,配置 NameNode 内存 NameNode 内存默认 2000m ,如果服务器内存 4G , NameNode 内存可以配置 3g 。在 hadoop-env.sh 文件中配置如下。 HADOOP_NAMENODE_OPTS=-Xmx3072m Hadoop3.x 系列,配置 Nam

每天认识几个maven依赖(ActiveMQ+activemq-jaxb+activesoap+activespace+adarwin)

八、ActiveMQ 1、是什么? ActiveMQ 是一个开源的消息中间件(Message Broker),由 Apache 软件基金会开发和维护。它实现了 Java 消息服务(Java Message Service, JMS)规范,并支持多种消息传递协议,包括 AMQP、MQTT 和 OpenWire 等。 2、有什么用? 可靠性:ActiveMQ 提供了消息持久性和事务支持,确保消

wolfSSL参数设置或配置项解释

1. wolfCrypt Only 解释:wolfCrypt是一个开源的、轻量级的、可移植的加密库,支持多种加密算法和协议。选择“wolfCrypt Only”意味着系统或应用将仅使用wolfCrypt库进行加密操作,而不依赖其他加密库。 2. DTLS Support 解释:DTLS(Datagram Transport Layer Security)是一种基于UDP的安全协议,提供类似于

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如,在当前目录下创建一个名为 myenv 的虚拟环境: python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行: source myenv/bin/activate 3.与notebook连接 在虚拟环境中,使用 pip 安装 Jupyter 和 ipykernel: pip instal

沁恒CH32在MounRiver Studio上环境配置以及使用详细教程

目录 1.  RISC-V简介 2.  CPU架构现状 3.  MounRiver Studio软件下载 4.  MounRiver Studio软件安装 5.  MounRiver Studio软件介绍 6.  创建工程 7.  编译代码 1.  RISC-V简介         RISC就是精简指令集计算机(Reduced Instruction SetCom

log4j2相关配置说明以及${sys:catalina.home}应用

${sys:catalina.home} 等价于 System.getProperty("catalina.home") 就是Tomcat的根目录:  C:\apache-tomcat-7.0.77 <PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} [%t] %-5p %c{1}:%L - %msg%n" /> 2017-08-10

DM8数据库安装后配置

1 前言 在上篇文章中,我们已经成功将库装好。在安装完成后,为了能够更好地满足应用需求和保障系统的安全稳定运行,通常需要进行一些基本的配置。下面是一些常见的配置项: 数据库服务注册:默认包含14个功能模块,将这些模块注册成服务后,可以更好的启动和管理这些功能;基本的实例参数配置:契合应用场景和发挥系统的最大性能;备份:有备无患;… 2 注册实例服务 注册了实例服务后,可以使用系统服务管理,