ActiveMQ在linux上的安装以及客户端测验点对点和广播两种测试

安装环境：

需要jdk
安装Linux系统。生产环境都是Linux系统。

安装步骤

第一步：把ActiveMQ 的压缩包上传到Linux系统。

第二步：解压缩。

第三步：启动。

使用bin目录下的activemq命令启动：

[[email protected] bin]# ./activemq start

关闭：

[[email protected] bin]# ./activemq stop

查看状态：

[[email protected] bin]# ./activemq status

注意：如果ActiveMQ整合spring使用不要使用activemq-all-5.12.0.jar包。建议使用5.11.2

进入管理后台：

http://192.168.25.168:8161/admin

用户名：admin

密码：admin

ActiveMQ在linux上的安装以及客户端测验点对点和广播两种测试

安装完成

测试：先导包

ActiveMQ在linux上的安装以及客户端测验点对点和广播两种测试

package com.baidu.test;
import java.io.IOException;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;

import org.apache.activemq.ActiveMQConnectionFactory;

import org.junit.Test;

public class ActiveMq {

   //点对点提供者
   @Test
   public void test1() throws JMSException {

//       第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。

       ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.3.140:61616");
//       第二步：使用ConnectionFactory对象创建一个Connection对象。
       Connection connection = connectionFactory.createConnection();
//       第三步：开启连接，调用Connection对象的start方法。
       connection.start();
//       第四步：使用Connection对象创建一个Session对象。
       //第一个参数是是否开启事务，第二个参数是当地第一个参数为false的情况下，1、自动应答 2、手动应答一般用默认的自动应答
       Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//       第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。
       Queue createQueue = session.createQueue("lili");
//       第六步：使用Session对象创建一个Producer对象。
       MessageProducer producer = session.createProducer(createQueue);
//       第七步：创建一个Message对象，创建一个TextMessage对象。
       TextMessage message = session.createTextMessage("nihao");
//       第八步：使用Producer对象发送消息。
       producer.send(message);
//       第九步：关闭资源。
       producer.close();
       session.close();
       connection.close();
   }

   //点对点消费者
   @Test
   public void test2() throws JMSException, IOException {
//       消费者：接收消息。
//       第一步：创建一个ConnectionFactory对象。
       ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.3.140:61616");
//       第二步：从ConnectionFactory对象中获得一个Connection对象。
       Connection connection = connectionFactory.createConnection();
//       第三步：开启连接。调用Connection对象的start方法。
       connection.start();
//       第四步：使用Connection对象创建一个Session对象。
       Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//       第五步：使用Session对象创建一个Destination对象。和发送端保持一致queue，并且队列的名称一致。
       Queue queue = session.createQueue("lili");
//       第六步：使用Session对象创建一个Consumer对象。
       MessageConsumer consumer = session.createConsumer(queue);
//       第七步：接收消息。
       consumer.setMessageListener(new MessageListener() {

           @Override
           public void onMessage(Message message) {
               try {
                   TextMessage textMessage = (TextMessage) message;
                   String text = null;
                   //取消息的内容
                   text = textMessage.getText();
                   // 第八步：打印消息。
                   System.out.println(text);
               } catch (JMSException e) {
                   e.printStackTrace();
               }
           }

       });
          //等待键盘输入

        System.in.read();
//       第九步：关闭资源

       consumer.close();
       session.close();
       connection.close();
   }

   public void onMessage(javax.jms.Message arg0) {
       // TODO Auto-generated method stub

   }

   @Test

public void testTopicProducer() throws Exception {

// 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。

// brokerURL服务器的ip及端口号

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.3.140:61616");

// 第二步：使用ConnectionFactory对象创建一个Connection对象。

Connection connection = connectionFactory.createConnection();

// 第三步：开启连接，调用Connection对象的start方法。

connection.start();

// 第四步：使用Connection对象创建一个Session对象。

// 第一个参数：是否开启事务。true：开启事务，第二个参数忽略。

// 第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个topic对象。

// 参数：话题的名称。

Topic topic = session.createTopic("zzytopic");

// 第六步：使用Session对象创建一个Producer对象。

MessageProducer producer = session.createProducer(topic);

// 第七步：创建一个Message对象，创建一个TextMessage对象。

* TextMessage message = new ActiveMQTextMessage(); message.setText(

* "hello activeMq,this is my first test.");

TextMessage textMessage = session.createTextMessage("hello activeMq,this is my topic test11111111111111");

// 第八步：使用Producer对象发送消息。

producer.send(textMessage);

// 第九步：关闭资源。

producer.close();

session.close();

connection.close();

    }

   @Test
    public void testTopicConsumer() throws Exception {

// 第一步：创建一个ConnectionFactory对象。

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.3.140:61616");

// 第二步：从ConnectionFactory对象中获得一个Connection对象。

Connection connection = connectionFactory.createConnection();

// 第三步：开启连接。调用Connection对象的start方法。

connection.start();

// 第四步：使用Connection对象创建一个Session对象。

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 第五步：使用Session对象创建一个Destination对象。和发送端保持一致topic，并且话题的名称一致。

Topic topic = session.createTopic("zzytopic");

// 第六步：使用Session对象创建一个Consumer对象。

MessageConsumer consumer = session.createConsumer(topic);

// 第七步：接收消息。

consumer.setMessageListener(new MessageListener() {

@Override

public void onMessage(Message message) {

try {

TextMessage textMessage = (TextMessage) message;

String text = null;

// 取消息的内容

text = textMessage.getText();

// 第八步：打印消息。

System.out.println(text);

} catch (JMSException e) {

e.printStackTrace();

}

});

System.out.println("topic的消费端01。。。。。");

// 等待键盘输入

System.in.read();

// 第九步：关闭资源

consumer.close();

session.close();

connection.close();

    }



   /////////////////////
   @Test
    public void testTopicConsumer1() throws Exception {

// 第一步：创建一个ConnectionFactory对象。

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.3.140:61616");

// 第二步：从ConnectionFactory对象中获得一个Connection对象。

Connection connection = connectionFactory.createConnection();

// 第三步：开启连接。调用Connection对象的start方法。

connection.start();

// 第四步：使用Connection对象创建一个Session对象。

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 第五步：使用Session对象创建一个Destination对象。和发送端保持一致topic，并且话题的名称一致。

Topic topic = session.createTopic("zzytopic");

// 第六步：使用Session对象创建一个Consumer对象。

MessageConsumer consumer = session.createConsumer(topic);

// 第七步：接收消息。

consumer.setMessageListener(new MessageListener() {

@Override

public void onMessage(Message message) {

try {

TextMessage textMessage = (TextMessage) message;

String text = null;

// 取消息的内容

text = textMessage.getText();

// 第八步：打印消息。

System.out.println(text);

} catch (JMSException e) {

e.printStackTrace();

}

});

System.out.println("topic的消费端03。。。。。");

// 等待键盘输入

System.in.read();

// 第九步：关闭资源

consumer.close();

session.close();

connection.close();

}

}

ActiveMQ在linux上的安装以及客户端测验 点对点和广播两种测试

安装环境：

安装步骤

相关推荐

ActiveMQ在linux上的安装以及客户端测验点对点和广播两种测试