JMS——使用ActiveMQ打造点对点聊天器

素颜马尾好姑娘i 2022-07-14 04:52 171阅读 0赞

这里使用了acticveMQ的点对点，使用Spring配置，实现了简单的点对点聊天功能

所需依赖

<dependency>
                <groupId>org.apache.activemq</groupId>
                <artifactId>activemq-core</artifactId>
                <version>5.5.1</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jms</artifactId>
                <version>3.2.4.RELEASE</version>
            </dependency>

消息监听器

package jms;
    
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.MessageListener;
    import javax.jms.TextMessage;
    
    /**
     * Created by yuyufeng on 2016/11/28.
     */
    public class ActiveMQListener implements MessageListener{
        public void onMessage(Message message) {
            //这里我们知道生产者发送的就是一个纯文本消息，所以这里可以直接进行强制转换，或者直接把onMessage方法的参数改成Message的子类TextMessage
            if (message instanceof TextMessage) {
                TextMessage textMsg = (TextMessage) message;
                try {
                    System.out.println("消息来源是："+textMsg.getJMSDestination()+"消息内容是：" + textMsg.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }else{
                System.out.println("ActiveMQ 消息类型不符合+"+message);
            }
        }
    }

Spring配置文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        
        <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
            
            <property name="connectionFactory" ref="connectionFactory"/>
        </bean>
        
        <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
            <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
        </bean>
        
        <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
            <property name="brokerURL" value="tcp://127.0.0.1:61616"/>
            
            
        </bean>
        
        <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
            <constructor-arg value="test.queue1"/>
        </bean>
    
        
        <bean id="queueDestinationReceive" class="org.apache.activemq.command.ActiveMQQueue">
            <constructor-arg value="test.queue2"/>
        </bean>
    
        
        <bean id="activeMQListener" class="jms.ActiveMQListener"/>
        
        <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="connectionFactory"/>
            <property name="destination" ref="queueDestinationReceive"/>
            <property name="messageListener" ref="activeMQListener"/>
        </bean>
        
    
    </beans>

入口类Main.java

package jms.test;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import org.springframework.jms.core.JmsTemplate;
    import org.springframework.jms.core.MessageCreator;
    
    import javax.jms.*;
    import java.io.IOException;
    import java.util.Scanner;
    
    /**
     * Created by yuyufeng on 2016/11/28.
     */
    public class Main {
        public static void main(String[] args) throws IOException {
            ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("jms/application.xml");
            ac.start();
            JmsTemplate jms = (JmsTemplate) ac.getBean("jmsTemplate");
            Destination destination = (Destination) ac.getBean("queueDestination");
            MessageCreator messageCreator;
            while(true){
                Scanner scanner = new Scanner(System.in);
                final String str = scanner.nextLine();
                messageCreator =  new MessageCreator() {
                    public Message createMessage(Session session) throws JMSException {
                        return session.createTextMessage(str);
                    }
                };
                jms.send(destination,messageCreator);
            }
    
        }
    }

这里注意，因为是聊天器，所以我在这里启动了两个Main方法。每次启动Main方法之前记得修改配置文件中的Destination中的发送和接受名称，比如 一个queueDestination为test1,queueDestinationReceive为test2  另一个：queueDestination为test2,queueDestinationReceive为test1

这样就能互相发送消息了。

测试结果如下

\->main1

你好  
消息来源是：queue://test2消息内容是：嗯 好的

\->main2

消息来源是：queue://test1消息内容是：你好  
嗯 好的