美文网首页
ActiveMQ的安装部署以及Java代码通讯

ActiveMQ的安装部署以及Java代码通讯

作者: WithWind | 来源:发表于2020-04-28 16:45 被阅读0次

    ActiveMQ是一款开源免费的消息队列。现在主要介绍如何安装和使用ActiveMQ。

    1.安装和启动

    ActiveMQ是apache的一款产品,所以推荐去apache的官网去下载,这里是下载地址:http://activemq.apache.org/components/classic/download/,根据自己的操作系统下载对应的版本。笔者这里下载的是windows版本;

    下载地址

    下载完成后,无论是windows还是Linux版本,第一步都是解压。windows下解压完成的基本目录如下。这里进入到bin目录下,有一个win32和win64目录,根据自己操作系统是32位还是63位分别进入不同目录,双击activemq.bat,启动脚本;

    启动正常后,会出现一个命令窗口,表示程序正在运行。

    打开浏览器,输入http://localhost:8161,进入到MQ后台的首页。

    点击Manage ActiveMQ broker,进入到消息查看和管理页面,此时需要输入账户和密码,默认的账户和密码都是admin。

    点击菜单栏queue,可以查看所有消息队列的名称,默认没有消息队列。

    2.创建和接收消息

    ActiveMQ安装成功后,消息队列中是没有消息的,此时我们可以创建两个微服务项目来实现消息的发送和接收。使用springboot的主要原因是创建过程比较简单,代码比较简约。这里说明以下,创建两个微服务,一个作为消息发送方,一个作为消息的接收方。两个微服务配置基本相同,就是代码略有不同。

    首先我们需要在pom.xml文件中引入对activemq的依赖。

    然后在项目的配置文件中配置下mq的连接,mq通讯的端口为61616端口,如果你的服务和mq安装在不同的机器上,还需要去开放端口;

    Java代码部分,需要引入jmstemplate

    发送方的部分代码
    接收方的代码

    运行消息发送服务,发送消息,此时我们可以管理页面看到我们定义几个消息的名称:

    消息队列

    此时运行消息接收服务,日志会看到接收到的消息内容

    相关文章

      网友评论

          本文标题:ActiveMQ的安装部署以及Java代码通讯

          本文链接:https://www.haomeiwen.com/subject/qgavwhtx.html