c++activemq教程，activemq 教程

如何配置apache-activemq

1、环境：

Windows XP

apache-activemq-5.2.0-bin.zip

2、安装

解压缩到apache-activemq-5.2.0-bin.zip到一个目录，比如C:\apache-activemq-5.2.0

3、配置

配置就在C:\apache-activemq-5.2.0\conf目录下三个文件

activemq.xml

credentials.properties

log4j.properties

4、启动ActiveMQ

运行C:\apache-activemq-5.2.0\bin\activemq.bat

5、测试

ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否成功启动 netstat -an|find "61616"

C:\Documents and Settings\Administratornetstat -an|find "61616"

TCP 0.0.0.0:61616 0.0.0.0:0 LISTENING

6、监控

ActiveMQ5.0版本默认启动时，启动了内置的jetty服务器，提供一个demo应用和用于监控ActiveMQ的admin应用。

在windows7环境中activemq-5.1需要配置环境变量吗

方法/步骤

1、首先，右击“此电脑”，选择“属性”

2、选择“高级系统设置”

3、选择“环境变量”

4、选择“新建”

5、点击新建后，就会出现这个，变量名为“JAVA_HOME”(复制我引号内的内容就可以了，不含引号，下同)，变量值，必须是自己装jdk时的路径，比如我的安装路径是E:java\jdk\,路径问题也需要注意

6、接下来找到“CLASSPATH”,没有的话就“新建”

7、变量名为“CLASSPATH”变量值“.;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar;”

8、找到Path，对其进行编辑，在其原有变量值前加上“;%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;”，加的方法就是这样的C:变量值

9、记得完成后要点两个确定

10、最后，就是测试自己配置是否成功了，同时按 R+ WIN(那个windows标志的键)，输入cmd

11、进入命令提示符，输入JAVA，点击“Enter”，出来这些中文，就行了

12、再输入JAVAC,点击“Enter”，出来这些中文就行了。

分布式事务处理解决方案中,ActiveMQ应该怎么使用_activemq消息队列原理

ActiveMQ工作原理：

首先来看本地通讯的情况，应用程序A和应用程序B运行于同一系统A，它们之间可以借助消息队列技术进行彼此的通讯：应用程序A向队列1发送一条信息，而当应用程序B需要时就可以得到该信息。

其次是远程通讯的情况，如果信息传输的目标改为在系统B上的应用程序C，这种变化不会对应用程序A产生影响，应用程序A向队列2发送一条信息，系统A的MQ发现Q2所指向的目的队列实际上位于系统B，它将信息放到本地的一个特殊队列－传输队列(Queue)。我们建立一条从系统A到系统B的消息通道，消息通道代理将从传输队列中读取消息，并传递这条信息到系统B，然后等待确认。只有MQ接到系统B成功收到信息的确认之后，它才从传输队列中真正将该信息删除。如果通讯线路不通，或系统B不在运行，信息会留在传输队列中，直到被成功地传送到目的地。这是MQ最基本而最重要的技术--确保信息传输，并且是一次且仅一次(once-and-only-once)的传递。

MQ提供了用于应用集成的松耦合的连接方法，因为共享信息的应用不需要知道彼此物理位置（网络地址）；不需要知道彼此间怎样建立通信；不需要同时处于运行状态；不需要在同样的操作系统或网络环境下运行。

ActiveMQ基础教程（一）JMS概述

    JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。可以简单的理解为：两个应用程序之间需要进行通信，我们使用一个JMS服务，进行中间的转发，通过JMS 的使用，我们可以解除两个程序之间的耦合。

    点对点模型用于消息生产者和消息消费者之间点到点的通信。消息生产者将消息发送到由某个特定名字标示的消息队列（Queue）中，消息消费者从这个特定队列中获取对应消息。在消息传送给消费者之前它被存储在这个队列中。队列可以是持久的，以保证在消息服务出现故障时仍然能够传递消息。

    在点对点消息传送模型中，应用程序由消息队列（Queue），发送者（Sender），接收者（Receiver）组成。每一个消息发送给一个特殊的消息队列，该队列保存了所有发送给它的消息(除了被接收者消费掉的和过期的消息)。

    在发布/订阅消息模型中，发布者发布一个消息，该消息通过主题（Topic）传递给所有的客户端。在这种模型中，发布者和订阅者彼此不知道对方，是匿名的且可以动态发布和订阅主题（Topic）。主题（Topic）主要用于保存和传递消息，且会一直保存消息直到消息被传递给客户端。

    在发布与订阅消息传送模型中，应用程序由主题（Topic），发布者（Publisher），订阅者（Subscriber）组成。客户端将消息发送到主题。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。

    在JMS中，消息的产生和消息是异步的。对于消费来说，JMS的消息者可以通过两种方式来消费消息。

    JMS API是在javax.jms包中定义的。

    要使用JMS API 需要创建一个提供连接对象的连接工厂。连接对象提供与消息服务器的链接。链接被用来创建会话，会话被用来创建消息，消息通过消息的生产者发送到目标(队列或主题)，然后消息传递到消息消费者。

    整理文章主要为了自己日后复习用，文章中可能会引用到别的博主的文章，如涉及到博主的版权问题，请博主联系我。

activemq 一台服务器如何配置多个broker

步骤如下：

1、把整个conf文件夹复制一份，比如叫conf2

2、修改里面的activemq.xml文件

①brokerName不能和原来的重复

②数据存放的文件名称不能重复，比如kahaDB directory = "${activemq.data}/kahadb2"/

③所有涉及的transportConnector的端口，都要和原来的不一样。注意不要超出端口的范围(0-65535)

3、修改jetty.xml，把里面的默认端口号8161改成别的，不如9161

4、到bin下面，复制一个activemq，比如叫activemq2

①修改程序的id，不能和原来的重复，ACTIVEMQ_PIDFILE="$ACTIVEMQ_DATA/activemq2.pid"

②修改配置文件路径ACTIVEMQ_CONF="$ACTIVEMQ_BASE/conf2"

③修改端口，tcp://localhost:61616把61616改成和activemq.xml里面的tcp端口一致。请注意，在activemq5.9.0版本中是这么修改。但我使用的是最新的5.12.1版本，在activemq中找不到该tcp端口的配置，折腾了半天才发现该版本把这个配置挪到了env文件。所以就需要拷贝一份env，比如就叫env2吧，然后再env2里面把61616改成和activemq.xml里面的tcp端口一致。最后别忘了把activemq2里面对env的引用改成env2。ACTIVEMQ_CONFIGS="/etc/default/activemq $HOME/.activemqrc $ACTIVEMQ_HOME/bin/env2"

现在你可以到activemq的bin目录下分别执行./activemq start 和 ./activemq2 start 了。这两个broker服务应该能正常启动了。

apache-activemq-5.8.0怎么连接数据库

安装环境：linux rhe

activemq版本：5.8.0

1.从地址下载apache-activemq-5.8.0-bin.tar.gz包

2.解压缩到指定的目录

Shell代码

tar zxvf apache-activemq-5.8.0-bin.tar.gz -C /usr/local

解压缩后会在/usr/local下生成apache-activemq-5.8.0目录，其中bin目录下就是activeMQ的执行脚本存在的位置了。

3.如果启动脚本无法执行，我们需要修改一下权限

Shell代码

cd /usr/local/apache-activemq-5.8.0/bin

chmod 775 activemq

4.设置activeMQ配置环境.activemqrc

Shell代码

bin/activemq setup ~/.activemqrc

5.启动activeMQ

在activemq主目录键入如下命令：

Shell代码

bin/activemq start

然后会看到控制台日志输出如下：

Shell代码

INFO: Loading '/home/chenzhou/.activemqrc'

INFO: Using java '/usr/java/jdk1.6.0_03/bin/java'

INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details

INFO: pidfile created : '/usr/local/apache-activemq-5.8.0/data/activemq-localhost.localdomain.pid' (pid '18567')

我们也可以把日志输出到指定的日志文件中

Shell代码

bin/activemq start /tmp/smlog 21

然后日志就输出到/tmp/smlog文件中了

注意：官方文档中标明了如果按上述的方式启动后，如果我们把linux终端窗口关闭的话，则服务也会停止

关于c++activemq教程和activemq 教程的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。