ActiveMQ安装及HelloWorld(二)

朴灿烈づ我的快乐病毒、 2021-09-27 01:16 363阅读 0赞

**  ActiveMQ安装（windows）**

ActiveMQ（5.15.4）下载地址：https://pan.baidu.com/s/1Zgkd-PsvC\_m4fJYgySEZ6A

下载好的zip后，解压到你自己想要放它的目录后，点开文件如下图。

![70][]

bin文件夹是启动脚本   32位还是64位的启动脚本

![70 1][]

conf中都是配置文件

![70 2][]

一般来讲  你想要配置集群等等配置文件都在这里。比较核心的两个是activeMQ.xml和jetty.xml。jetty是控制台，发布信息到jetty里。activeMQ中也是内驱了一个小的web容器。发布者发布信息到mq，然后可以关机什么的操作都可以，然后消费者从mq中拿发布者发布的消息就行。

**ActiveMQ的Hello World**

注：在此之前你需打开你下载好的activeMQ中bin文件下的看你的操作系统是多少位的，然后启动（activemq.bat）activeMQ才能hello world.然后用的jar包是你下好的activeMQ文件lib文件夹下的一个activemq-all-5.11.1.jar。

我们先写一个hello world,让大家感受一下ActiveMQ，我们需要实现接收者和发送者两部分代码的编写。

Sender/Receiver：

第一步 建立ConnectionFactory工厂对象，需要填入用户名，密码，以及要连接的地址，均使用默认即可，端口默认为：“tcp://localhost:61616”

第二步 通过ConnectionFactory工厂对象创建一个Connection连接，并且调用Connection的start方法开启连接，Connection默认关闭的。

第三步 通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1为是否启用事务，参数配置2位签收模式，一般我们设置自动签收。

第四步 通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象，在PTP模式中，Destination被称作Queue即队列；在Pub/Sub模式，Destination被称作Topic即主题。在程序中可以使用多个Queue和Topic。

第五步 我们可以使用Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer和MessageConsumer。

第六步 我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性（deliveryMode），我们稍后详细介绍。

第七步 最后我们使用JMS规范的TextMessage形式创建数据（通过Session对象），并用MessageProducer的send方法发送数据。同理客户端使用receive方法进行接收数据。最后不要忘记关闭Connection连接。

**Coding：**

**Sender.java**

package com;
    
    import javax.jms.Connection;
    import javax.jms.ConnectionFactory;
    import javax.jms.DeliveryMode;
    import javax.jms.Destination;
    import javax.jms.JMSException;
    import javax.jms.MessageProducer;
    import javax.jms.Session;
    import javax.jms.TextMessage;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    
    public class Sender {
    
    	public static void main(String[] args) throws JMSException {
    		//第一步 建立ConnectionFactory工厂对象，需要填入用户名和密码以及要链接的地址，
    		//均使用默认即可，默认端口为"tcp://localhost:61616"
    		
    		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://localhost:61616");
    		//第二步 通过ConnerctionFactory工厂对象我们创建一个Connection链接，并且调用
    		//Connection的start方法开启链接，Connection默认是关闭的。
    		Connection connection = connectionFactory.createConnection();
    		connection.start();
    		//第三步 通过Connection对象创建Session会话（上下文环境对象），用于接受消息，参数配置1为
    		//是否启动事务，参数配置2位签收模式，一般我们设置自动签收。
    		Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
    		//第四步 、通过Session创建Destionation对象，指的是一个客户端用来指定生产消息目标和消费消息来源
    		//的对象，在PTP模式中，Destination被称作Queue即队列；在Pub/Sub模式，Destination被称作Topic即主题。
    		//在程序中可以使用多个Queue和Topic.
    		Destination destination = session.createQueue("queue1");
    		//第五步 我们需要通过Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer/MessageConsumer.
    		MessageProducer messageProducer = session.createProducer(destination);
    		//第六步 我们可以使用MessageProducer的serDeliveryMode方法为其设置持久化特性和非持久化特性
    		//(DeliveryMode)。
    		messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
    		//第七步 最后我们使用JMS规范TextMessage形式创建数据（通过Session对象），并用MessageProducer的send方法发送数据。同理客户端使用receive方法进行接收数据。
    		//最后不要忘记关闭Connection.
    		//发布五条信息到mq中
    		for (int i = 1; i <= 5; i++) {
    			TextMessage textMessage = session.createTextMessage();
    			textMessage.setText("我是消息内容"+i);
    			messageProducer.send(textMessage);
    		}
    		if(connection !=null){
    			connection.close();
    		}
    	}
    }

**Receiver.java**

package com;
    
    import javax.jms.Connection;
    import javax.jms.ConnectionFactory;
    import javax.jms.DeliveryMode;
    import javax.jms.Destination;
    import javax.jms.JMSException;
    import javax.jms.MessageConsumer;
    import javax.jms.MessageProducer;
    import javax.jms.Session;
    import javax.jms.TextMessage;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    
    public class Receiver {
    
    	
    	public static void main(String[] args) throws JMSException {
    		//第一步 建立ConnectionFactory工厂对象，需要填入用户名和密码以及要链接的地址，
    				//均使用默认即可，默认端口为"tcp://localhost:61616"
    				
    				ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://localhost:61616");
    				//第二步 通过ConnerctionFactory工厂对象我们创建一个Connection链接，并且调用
    				//Connection的start方法开启链接，Connection默认是关闭的。
    				Connection connection = connectionFactory.createConnection();
    				connection.start();
    				//第三步 通过Connection对象创建Session会话（上下文环境对象），用于接受消息，参数配置1为
    				//是否启动事务，参数配置2位签收模式，一般我们设置自动签收。
    				Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
    				//第四步 、通过Session创建Destionation对象，指的是一个客户端用来指定生产消息目标和消费消息来源
    				//的对象，在PTP模式中，Destination被称作Queue即队列；在Pub/Sub模式，Destination被称作Topic即主题。
    				//在程序中可以使用多个Queue和Topic.
    				Destination destination = session.createQueue("queue1");
    				//第五步 我们需要通过Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer/MessageConsumer.
    				MessageConsumer messageConsumer = session.createConsumer(destination);
    				
    				while(true){
    					TextMessage textMessage =  (TextMessage) messageConsumer.receive();
    					if(textMessage==null){
    						break;
    					}
    					System.out.println("收到的内容： "+textMessage.getText() );
    					
    				}
    				if(connection !=null){
    					connection.close();
    				}
    				
    	}
    }

其中 Destination destination = session.createQueue("queue1");这个queue1就和html中的form表单中的name值一样 前段中的name就得和后台的获取的参数值的一样 后台才能接受到这个值。这个不是瞎定义的  因为发布者定义好这个名字后 消费者根据这个名字去找队列中的小心 。其中消费者的MessageConsumer对象的receive方法

![70 3][]

其中 第一个receive()阻塞状态，直到生产者有消息，才进行运行，第二个是写等待多长时间，比如你写五秒，那就五秒去查询有没有这个队列消息，第三个是不等待，如果有 那就接收，没有就算。

运行sender.java

之后打开网址输入：http://127.0.0.1:8161/admin/queues.jsp，会弹出一个对话框让你输入账号和密码。此时你如果想知道账号和密码就要打开ActiveMQ文件的jetty-realm.properties文件。

![70 4][]

这里面有两个账号和密码，我是用的是admin的。之后就是activeMQ的网页。

![70 5][]

里面有五条消息，我们也可以点击那个queue1查看详情。

![70 6][]

然后我们运行Receiver.java

![70 7][]

看到控制台已经输出被消费的消息。

此时我们再打开activeMQ那个网页刷新一下看到以下结果

![70 8][]

一共有一个消费者消费，他一共消费了五条数据，有0条未被消费的消息。

**ActiveMQ安全机制**

activeMQ的web管理界面：[http://127.0.0.1:8161/admin][http_127.0.0.1_8161_admin]

activeMQ管控台使用jetty部署，所以需要修改密码则需要到相应的配置文件。

你解压后的activeMQ文件下conf文件下jetty-realm.properties

activeMQ应该设置有安全机制，只有符合认证的用户才能进行发送和获取信息，所以我们也可以在activemq.xml里添加安全验证配置。

你解压后的activeMQ文件下conf文件下activeMQ.xml。

![70 9][]

然后代码中需要修改这个地方：

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("xxx","xxx", "tcp://localhost:61616");

之前是使用的是默认的账号和密码

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://localhost:61616");

[70]: /images/20210923/3e4c1b9253794323a067cddeeb73e7e9.png
[70 1]: /images/20210923/aa3fb81e727444e5a249b5b02d7fd43d.png
[70 2]: /images/20210923/40a00b8d6654416eae83a59fee7c207e.png
[70 3]: /images/20210923/37cd8deb7f4f466aa7e130d99fd4945b.png
[70 4]: /images/20210923/12043334a6554def9b47ad77cd3e581d.png
[70 5]: /images/20210923/9d3b4df32fdc49168c9e5bc8766c882c.png
[70 6]: /images/20210923/9612d4b4d4e842499c17eff887cf681f.png
[70 7]: /images/20210923/90e0a0d08e2b4754b8b17e5c4bd111b1.png
[70 8]: /images/20210923/acbd9b30de5a46128454f7a85a66702e.png
[http_127.0.0.1_8161_admin]: http://127.0.0.1:8161/admin
[70 9]: /images/20210923/db021c12c4b24d17bf13f30a5c9ee059.png