适用于孩子,父母和祖父母的JBoss HornetQ –第1章

现在与HornetQ合作已经快4年了,我认为是时候分享我到目前为止所学知识的一部分了。

这篇文章的主要目的不是重写官方文档 ,而是以简单的方式阐明我们在PaddyPower中最常用的概念。

什么是HornetQ

HornetQ是JMS实现。 JMS是一种面向消息的中间件API,用于以异步方式在生产者和使用者之间交换信息。

HornetQ是实现JMS API的众多框架之一。

组态

我们关心的所有HornetQ配置都在1个文件夹中。 那有多美? 该文件夹为hornetq(或在您使用的jboss版本上浸入hornetq.sar) ,您可以在jboss配置文件的部署文件夹中找到它。

在此文件夹中,我们最多有7个xml配置文件。 我们真的只关心2:

  • hornetq-jms.xmlhornetq-configuration.xml
  • hornetq-jms.xml

在这里,您要为队列,主题和连接工厂定义JNDI名称。

默认情况下,所有Connection工厂,无效字母和到期队列都已配置。

您需要添加的只是您的应用程序需要使用的队列或主题。

例如:

<queue name='phaseQueueFromEngine'><entry name='/queue/phaseQueueFromEngine'/>
</queue>

条目名称是生产者和使用者用来发现队列的JNDI名称。

hornetq-configuration.xml

在这里您要定义接收器,连接器,桥和其他很酷的东西。

了解连接器和接受器

好的,这可能很棘手,所以我将尝试变得简单而必要。

HornetQ在服务器(例如JBoss)中运行或作为独立应用程序运行。

在以上任何一种情况下,HornetQ均通过与自己的服务器HornetQ服务器进行通信来工作。

为了与之通信,我们必须告诉我们如何连接以及我们接受的连接。

  • 接受者定义HornetQ Server接受哪种连接类型。
  • 连接器定义了如何连接到HornetQ服务器。

幸运的是,in-vm和netty仅支持2种连接器和接受器。 当生产者和使用者位于同一虚拟机中时,将使用in-vm

例:

<acceptor name='in-vm'><factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class>
</acceptor>
<connector name='in-vm'><factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class>
</connector>

当生产者和消费者居住在不同的虚拟机中时,将使用netty

例:

同一台机器上的生产者/消费者:

<acceptor name='netty'><factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class><param key='host'  value='${host:localhost}'/><param key='port'  value='${port:5445}'/></acceptor>
<connector name=”netty”>
<factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class>
<param key=”host” value=”${host:localhost}”/>
<param key=”port” value=”${port:5445}”/>
</connector>


不同机器上的生产者/消费者:

消费盒

<acceptor name=”netty-external-acceptor”>
<factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class>
<param key=”host” value=”172.x.x.62″/>
<param key=”port” value=”5445″/>
</acceptor>

生产箱

<connector name='remote-engine-connector'><factory-class> org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class><param key='host' value='172.x.x.62'/><param key='port' value='5445'/></connector>

到目前为止,一切都很好。

配置接收器和连接器时请注意,因为要进行正确的通信,它们必须与相同的主机和端口使用相同的种类。

带netty连接器的netty接受器(相同的主机和端口)

带有in-vm连接器的in-vm接受器

带Netty连接器的in-vm接受器

带Netty连接器5446的Netty接受器端口5445

带有网络连接器172.xx62的网络接受器主机172.xx60

了解桥梁

我广泛使用的另一个功能是桥接。

如果您有一个生产者生活在172.xx60框内,而一个消费者则生活在172.xx62框内,则需要连接它们,并在我们钟爱的配置文件hornetq-configuration.xml中配置网桥。

范例:

<bridge name=”from60to62Bridge”>
<queue-name>jms.queue.phaseQueueToEngine</queue-name>
<forwarding-address>jms.queue.phaseQueueFromInput</forwarding-address>
<reconnect-attempts>-1</reconnect-attempts>
<connector-ref connector-name=”remote-engine-connector”/>
</bridge>

是的,您可以使用连接器指定连接到其他hornetQ服务器的位置。 简单!

我希望这将阐明几个方面,并有助于更好地理解有时可怕的Hornetq配置。

即将推出.. HornetQ为孩子,父母和祖父母–第2章:地址设置的魔力

参考: JBoss HornetQ for Kids,父母和祖父母–来自我们的JCG合作伙伴 Marco Castigliego的第一章 ,位于“ 删除重复并修复不良名称”博客上。

翻译自: https://www.javacodegeeks.com/2012/11/jboss-hornetq-for-kids-parents-and-grandparents-chapter-1.html

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

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

相关文章

riot.js教程【四】Mixins、HTML内嵌表达式

前文回顾riot.js教程【三】访问DOM元素、使用jquery、mount输入参数、riotjs标签的生命周期&#xff1b;riot.js教程【二】组件撰写准则、预处理器、标签样式和装配方法&#xff1b;riot.js教程【一】简介&#xff1b; 共享Mixins 混合开发可以使你很好的复用代码&#xff0c;如…

移动端判断手机横竖屏状态

禁用用户自动缩放功能&#xff1a; <meta name"viewport" content"widthdevice-width, initial-scale1.0, maximum-scale1.0, user-scalable0"> 判断横竖屏状态有两种方法&#xff1a;css判断、js判断 (一)、css判断横屏还是竖屏 1、写在同一个css文…

ubuntu dhcp ping 不通 自己_??2、DHCP安装和配置

DHCP动态主机设置协议&#xff0c;是一个局域网的网络协议&#xff0c;使用UDP协议工作&#xff0c;可以快速分配IP地址&#xff0c;解决内网IP不足、手动配置IP造成IP冲突以及内网机器多手工配置比较麻烦的问题。1.把win2008和win2003设置同一网段&#xff0c;网络适配器—配置…

python秒数变日期_将pandas日期列转换为已用秒数

新答案 将文本转换为Timedeltadf[Origin Time(Local)] pd.to_timedelta(df[Origin Time(Local)]) df[Seconds] df[Origin Time(Local)].dt.total_seconds() 旧答案 考虑数据帧dfdf pd.DataFrame(dict(Datepd.date_range(2017-03-01, 2017-03-02, freq2H))) Date 0 2017-03-0…

mysql用一个表更新另一个表的方法

Solution 1: 修改1列(navicate可行) update student s, city c set s.city_name c.name where s.city_code c.code; Solution 2: 修改多个列 update a, b set a.titleb.title, a.nameb.name where a.idb.id Solution 3: 采用子查询(navicate不可行) update student s set…

选择您的Java EE 6应用服务器

我被问到的第一个问题是&#xff1a;“我们应该使用哪个Java EE应用服务器&#xff1f;”。 随着Java EE 6的日益普及&#xff0c;新的兼容应用程序服务器获得了认证。 当前的官方兼容性和认证矩阵列出了针对完全配置文件&#xff0c;Web配置文件或两者认证的12种不同产品。 如…

串的基本计算

#include<stdio.h> #include<stdlib.h> //typedef int Status; #define Max 20 #define OK 1 #define ERROR 0 #define OVERLOE -2 typedef struct//堆分配表示串 { char *ch; int length; }HString; // int CreatHString(HString &H)//构造字符串 { H.length …

HTML表格属性及简单实例

这里主要总结记录下表格的一些属性和简单的样式&#xff0c;方便以后不时之需。 1、<table> 用来定义HTML的表格&#xff0c;具有本地属性 border 表示边框&#xff0c;border属性的值必须为1或空字符串("")。该属性不会控制边框的样式&#xff0c;而是由CSS来…

怎么查看MySQL 源码编译了什么_Mysql 源码编译教程贴

题外话:这是一篇教程贴,不仅学的是mysql的编译,还是一些编译的知识.我也是一个菜鸟,写一些感悟和心得,有什么问题可以批评指正,谢谢!如果只是为了安装请移到我的另一篇安装贴: Mysql安装贴环境:OS: CentOS 6.6x64 minimysql: mysql-5.6.251. mysql 下载:http://dev.mysql.com/d…

linux mysql启动_MySQL 安装(二)

MySQL 安装所有平台的Mysql下载地址为&#xff1a;MySQL 下载 . 挑选你需要的 MySQL Community Server 版本及对应的平台。Linux/UNIX上安装MySQLLinux平台上推荐使用RPM包来安装MySQL&#xff0c;MySQL AB提供了以下RPM包的下载地址&#xff1a;MySQL - MySQL服务器。你需要该…

0524驼峰命名法,模态对话框

模态对话框 window.showModalDialog("url"&#xff0c;"向目标对话框传的值"&#xff0c;"窗口特征参数") 打开模态对话框 模态对话框必须关掉才能对后端操作。 模块对话框和窗口的区别是永远置顶。 特征参数&#xff1a;用分号隔开&#xff0c;…

谁在偷你的记忆? 应用服务器版

您创建了一个了不起的应用程序。 您将其投入生产。 您会发现您没有足够的可用内存。 即使您的所有测量结果&#xff08;可能是借助我们的小型公用事业公司进行的测量 &#xff09;都表明您应该还不错。 我们计划发布一系列博客文章&#xff0c;研究堆消失的位置&#xff0c;并…

遗忘的html标签

1 <span>x</span><sup>2</sup><span> y10</span> 2 <br> 3 <span>H</span><sub>2</sub><span>O</span> <sup> 标签可定义上标文本。 包含在 <sup> 标签和其结束标签 …

Android四大组件之BroadcastReceiver

什么是BroadcastReceiver? BroadcastReceiver(广播接收器)&#xff0c;顾名思义&#xff0c;是用来接收广播的。Android内部实现了一套广播通信机制&#xff0c;即在某个应用或某个组件注册广播接收器&#xff0c;接收特定类型的广播。当别的应用或组件发送该类型的广播时&…

mysql数据库索引页号为什么从3开始_MySQL数据库快问快答

原标题&#xff1a;MySQL数据库快问快答前言今天楼主给大家列一下关于数据库几个常见问题的要点&#xff0c;如果大家对其中的问题感兴趣&#xff0c;可以自行扩展研究。1. UNION ALL 与 UNION 的区别UNION和UNION ALL关键字都是将两个结果集合并为一个。UNION在进行表链接后会…

通过简单的Spring方面摆脱null参数

什么是世界上最令人讨厌的&#xff0c;同时也是最受欢迎的例外&#xff1f; 我敢打赌这是NullPointerException。 NullPointerException可以表示任何东西&#xff0c;从简单的“ ups&#xff0c;我认为不能为空”到数小时和数天的第三方库调试&#xff08;我敢于尝试使用Doze…

java arraylist排序_最全Java集合笔记

集合概述什么是集合集合框架&#xff1a;用于存储数据的容器。集合框架是为表示和操作集合而规定的一种统一的标准的体系结构。任何集合框架都包含三大块内容&#xff1a;对外的接口、接口的实现和对集合运算的算法。接口&#xff1a;表示集合的抽象数据类型。接口允许我们操作…

【3】JVM-OutOfMemory异常重现

JVM中常见的OOM&#xff0c;那么如何通过自己编写代码产生这些OOM异常呢&#xff1f;通过写代码重现异常&#xff0c;是为了避免在工作中写出有OOM BUG的代码。之前虽然看过相关文章&#xff0c;但是没自己写过这些代码&#xff0c;这次在编写的实际过程中&#xff0c;由于和书…

CachedIntrospectionResults 初始化

转载于:https://www.cnblogs.com/xiluhua/p/7862985.html

为什么有些内联(行内)元素可以设置宽高?

为什么有些内联&#xff08;行内&#xff09;元素如img、input可以设置宽高&#xff1f; 在说明之前我们先来了解一些定义。 块级元素和内联元素&#xff1a; ①块级元素总是独占一行&#xff0c;表现为另起一行开始&#xff0c;而且其后的元素也必须另起一行显示。 宽度(w…