active mq 点对点模式 和 订阅者模式简单demo

active mq 整合   Spring  ：https://www.cnblogs.com/xiaochangwei/p/5426639.html

 

 

Queue Demo
QueueProducer Demo

//一、建立一个链接工厂对象，须要指定服务的ip及端口。
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.21.80:61616");
//二、使用工厂对象建立一个Connection对象。
Connection connection = connectionFactory.createConnection();
//三、开启链接，调用Connection对象的start方法。
connection.start();
//四、建立一个Session对象。
//第一个参数：是否开启事务。若是true开启事务，第二个参数无心义。通常不开启事务false。
//第二个参数：应答模式。自动应答或者手动应答。通常自动应答。
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//五、使用Session对象建立一个Destination对象。两种形式queue、topic，如今应该使用queue
Queue queue = session.createQueue("test-queue");
//六、使用Session对象建立一个Producer对象。
MessageProducer producer = session.createProducer(queue);
//七、建立一个Message对象，可使用TextMessage。
/*TextMessage textMessage = new ActiveMQTextMessage();
textMessage.setText("hello Activemq");*/
TextMessage textMessage = session.createTextMessage("hello activemq");
//八、发送消息
producer.send(textMessage);
//九、关闭资源
producer.close();
session.close();
connection.close();

 

 

QueueConsumer Demo

//建立一个ConnectionFactory对象链接MQ服务器
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.161:61616");
//建立一个链接对象
Connection connection = connectionFactory.createConnection();
//开启链接
connection.start();
//使用Connection对象建立一个Session对象
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//建立一个Destination对象。queue对象
Queue queue = session.createQueue("test-queue");
//使用Session对象建立一个消费者对象。
MessageConsumer consumer = session.createConsumer(queue);
//接收消息
consumer.setMessageListener(new MessageListener() {
    @Override
    public void onMessage(Message message) {
        //打印结果
        TextMessage textMessage = (TextMessage) message;
        String text;
        try {
            text = textMessage.getText();
            System.out.println(text);
        } catch (JMSException e) {
            e.printStackTrace();
        }

    }
});
//等待接收消息
System.in.read();
//关闭资源
consumer.close();
session.close();
connection.close();

 

 

Topic Demo
TopicProducer Demo

//一、建立一个链接工厂对象，须要指定服务的ip及端口。
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.21.80:61616");
//二、使用工厂对象建立一个Connection对象。
Connection connection = connectionFactory.createConnection();
//三、开启链接，调用Connection对象的start方法。
connection.start();
//四、建立一个Session对象。
//第一个参数：是否开启事务。若是true开启事务，第二个参数无心义。通常不开启事务false。
//第二个参数：应答模式。自动应答或者手动应答。通常自动应答。
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//五、使用Session对象建立一个Destination对象。两种形式queue、topic，如今应该使用topic
Topic topic = session.createTopic("test-topic");
//六、使用Session对象建立一个Producer对象。
MessageProducer producer = session.createProducer(topic);
//七、建立一个Message对象，可使用TextMessage。
/*TextMessage textMessage = new ActiveMQTextMessage();
textMessage.setText("hello Activemq");*/
TextMessage textMessage = session.createTextMessage("topic message");
//八、发送消息
producer.send(textMessage);
//九、关闭资源
producer.close();
session.close();
connection.close();

 

 

TopicConsumer Demo

//建立一个ConnectionFactory对象链接MQ服务器
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.21.80:61616");
//建立一个链接对象
Connection connection = connectionFactory.createConnection();
//开启链接
connection.start();
//使用Connection对象建立一个Session对象
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//建立一个Destination对象。topic对象
Topic topic = session.createTopic("test-topic");
//使用Session对象建立一个消费者对象。
MessageConsumer consumer = session.createConsumer(topic);
//接收消息
consumer.setMessageListener(new MessageListener() {

    @Override
    public void onMessage(Message message) {
        //打印结果
        TextMessage textMessage = (TextMessage) message;
        String text;
        try {
            text = textMessage.getText();
            System.out.println(text);
        } catch (JMSException e) {
            e.printStackTrace();
        }

    }
});
System.out.println("topic消费者3启动。。。。");
//等待接收消息
System.in.read();
//关闭资源
consumer.close();
session.close();
connection.close();

 

pom <dependency>     <groupId>org.apache.activemq</groupId>     <artifactId>activemq-all</artifactId> </dependency> ---------------------  做者：Francis-李鑫超  来源：CSDN  原文：https://blog.csdn.net/Francis123580/article/details/81902682  版权声明：本文为博主原创文章，转载请附上博文连接！