ActiveMQ之简单测试代码

àì夳堔傛蜴生んèń 2022-06-04 05:52 208阅读 0赞

1.  编写消息发送者类

public class Sender {  
        private static final int SEND_NUMBER = 5;  
    
        public static void main(String[] args) {  
            // ConnectionFactory ：连接工厂，JMS 用它创建连接 
            ConnectionFactory connectionFactory; // Connection ：JMS 客户端到JMS 
            // Provider 的连接 
            Connection connection = null; // Session： 一个发送或接收消息的线程 
            Session session; // Destination ：消息的目的地;消息发送给谁. 
            Destination destination; // MessageProducer：消息发送者 
            MessageProducer producer; // TextMessage message; 
            // 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar 
            connectionFactory = new ActiveMQConnectionFactory(  
                    ActiveMQConnection.DEFAULT_USER,  
                    ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");  
            try { // 构造从工厂得到连接对象 
                connection = connectionFactory.createConnection();  
                // 启动 
                connection.start();  
                // 获取操作连接 
                session = connection.createSession(Boolean.TRUE,  
                        Session.AUTO_ACKNOWLEDGE);  
                // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置 
                destination = session.createQueue("firstqueue");  
                // 得到消息生成者【发送者】 
                producer = session.createProducer(destination);  
                // 设置不持久化，此处学习，实际根据项目决定 
                producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  
                // 构造消息，此处写死，项目就是参数，或者方法获取 
                sendMessage(session, producer);  
                session.commit();  
            } catch (Exception e) {  
                e.printStackTrace();  
            } finally {  
                try {  
                    if (null != connection)  
                        connection.close();  
                } catch (Throwable ignore) {  
                }  
            }  
        }  
    
        public static void sendMessage(Session session, MessageProducer producer)  
                throws Exception {  
            for (int i = 1; i <= SEND_NUMBER; i++) {  
                TextMessage message = session.createTextMessage("ActiveMq 发送的消息"  
                        + i);  
                // 发送消息到目的地方 
    
                System.out.println("发送消息：" + "ActiveMq 发送的消息" + i);  
                producer.send(message);  
            }  
        }  
    }

2.编写消息接收者类

public class Receiver {  
        public static void main(String[] args) {  
            // ConnectionFactory ：连接工厂，JMS 用它创建连接 
            ConnectionFactory connectionFactory;  
            // Connection ：JMS 客户端到JMS Provider 的连接 
            Connection connection = null;  
            // Session： 一个发送或接收消息的线程 
            Session session;  
            // Destination ：消息的目的地;消息发送给谁. 
            Destination destination;  
            // 消费者，消息接收者 
            MessageConsumer consumer;  
            connectionFactory = new ActiveMQConnectionFactory(  
                    ActiveMQConnection.DEFAULT_USER,  
                    ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");  
            try {  
                // 构造从工厂得到连接对象 
                connection = connectionFactory.createConnection();  
                // 启动 
                connection.start();  
                // 获取操作连接 
                session = connection.createSession(Boolean.FALSE,  
                        Session.AUTO_ACKNOWLEDGE);  
                // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置 
                destination = session.createQueue("firstqueue");  
                consumer = session.createConsumer(destination);  
                while (true) {  
                    // 设置接收者接收消息的时间，为了便于测试，这里设定为100s 
                    TextMessage message = (TextMessage) consumer.receive(100000);  
                    if (null != message) {  
                        System.out.println("收到消息" + message.getText());  
                    } else {  
                        break;  
                    }  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
            } finally {  
                try {  
                    if (null != connection)  
                        connection.close();  
                } catch (Throwable ignore) {  
                }  
            }  
        }  
    }

3.测试

运行sender,控制台输出：  
发送消息：ActiveMq 发送的消息1  
发送消息：ActiveMq 发送的消息2  
发送消息：ActiveMq 发送的消息3  
发送消息：ActiveMq 发送的消息4  
发送消息：ActiveMq 发送的消息5  
![这里写图片描述][SouthEast]

运行reciver，控制台输出：  
收到消息ActiveMq 发送的消息1  
收到消息ActiveMq 发送的消息2  
收到消息ActiveMq 发送的消息3  
收到消息ActiveMq 发送的消息4  
收到消息ActiveMq 发送的消息5

![这里写图片描述][SouthEast 1]

[SouthEast]: /images/20220604/1d2b527509aa4590af9da5778810945e.png
[SouthEast 1]: /images/20220604/8f9f9122dcaf4591aa47fc5bd0bab968.png