本篇文章給大家分享的是有關ActiveMQ要入門什么，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

創(chuàng)新互聯(lián)公司成立以來不斷整合自身及行業(yè)資源、不斷突破觀念以使企業(yè)策略得到完善和成熟，建立了一套“以技術為基點，以客戶需求中心、市場為導向”的快速反應體系。對公司的主營項目，如中高端企業(yè)網站企劃 / 設計、行業(yè) / 企業(yè)門戶設計推廣、行業(yè)門戶平臺運營、重慶APP開發(fā)公司、手機網站開發(fā)、微信網站制作、軟件開發(fā)、成都服務器托管等實行標準化操作，讓客戶可以直觀的預知到從創(chuàng)新互聯(lián)公司可以獲得的服務效果。

1. 發(fā)布消息

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

public class BookProducer implements Runnable{
    public static final String BROKER_URL = "tcp://localhost:61616";
    @Override
    public void run() {
        try {
            //1.創(chuàng)建連接工廠，指定ip和端口
            ConnectionFactory factory = new ActiveMQConnectionFactory(BROKER_URL);
            //2.使用連接工廠創(chuàng)建一個連接對象
            Connection connection = factory.createConnection();
            //3.開啟連接（JMS會話）
            connection.start();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //使用會話創(chuàng)建目的地
            /**
             * ① 點對點（Point-to-Point）。在點對點的消息系統(tǒng)中，消息分發(fā)給一個單獨的使用者。點對點消息往往與隊列（javax.jms.Queue）相關聯(lián)。
             * ② 發(fā)布/訂閱（Publish/Subscribe）。發(fā)布/訂閱消息系統(tǒng)支持一個事件驅動模型，消息生產者和消費者都參與消息的傳遞。生產者發(fā)布事件，
                  而使用者訂閱感興趣的事件，并使用事件。該類型消息一般與特定的主題（javax.jms.Topic）關聯(lián)。
             */
            Destination destination = session.createQueue("book-broker")
            //創(chuàng)建生產者/消費者
            MessageProducer producer = session.createProducer(destination);
            // MessageConsumer consumer = session.createConsumer(destination);
            //consumer.receive();
            /**
             * 創(chuàng)建消息，支持的消息類型：
             *  TextMessage
             *  MapMessage
             *  ObjectMessage：對象需要實現(xiàn)序列化接口
             *  BytesMessage
             *  StreamMessage
             */
            Message message = session.createTextMessage("我是一個香蕉.......");
            //發(fā)送消息
            producer.send(message);
            //釋放資源
            producer.close();
            session.close();
            connection.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

2. 接收消息

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;

public class BookConsumer implements Runnable {
    @Override
    public void run() {
        try {
            var connection = new ActiveMQConnectionFactory(BookProducer.BROKER_URL).createConnection();
            connection.start();
            /**
             * connection.createSession(boolean transacted, int acknowledgeMode);
             * transacted:是否使用事務
             * acknowledgeMode：應答模式
             *     AUTO_ACKNOWLEDGE:自動應答
             *          對于同步消費者,receive方法調用返回,且沒有異常發(fā)生時,將自動對收到的消息予以確認.
             *          對于異步消息,當onMessage方法返回,且沒有異常發(fā)生時,即對收到的消息自動確認.
             *     CLIENT_ACKNOWLEDGE:客戶端手動應答
             *          這種方式要求客戶端使用javax.jms.Message.acknowledge()方法完成確認.
             *     DUPS_OK_ACKNOWLEDGE:延時//批量通知
             *          這種確認方式允許JMS不必急于確認收到的消息,允許在收到多個消息之后一次完成確認,
                       與Auto_AcKnowledge相比,這種確認方式在某些情況下可能更有效,
                       因為沒有確認,當系統(tǒng)崩潰或者網絡出現(xiàn)故障的時候,消息可以被重新傳遞.
             *     使用事務消息確認模式：
             *     SESSION_TRANSACTED
             */
            var session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            var consumer = session.createConsumer(session.createQueue("tmall-queue"));
            var message = ((TextMessage)consumer.receive()).getText();
            System.out.println(message);
            session.close();
            connection.close();
    }
}

      或者設置監(jiān)聽器接收(消費者不用一直在線，監(jiān)聽到消息自動接收)

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;

public class BookConsumer implements Runnable {
    @Override
    public void run() {
        try {
            var connection = new ActiveMQConnectionFactory(BookProducer.BROKER_URL).createConnection();
            connection.start();
            var session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            var consumer = session.createConsumer(session.createQueue("tmall-queue"));
            consumer.setMessageListener(message -> {
                try {
                    System.out.println(((TextMessage) message).getText());
                }catch (JMSException e){
                    e.printStackTrace();
                }
            });
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

3. java內嵌ActiveMQ，自動啟動一個ActiveMQ，不需要Linux啟動

import org.apache.activemq.broker.BrokerService;

public class Broker {
    //導入依賴compile group: 'com.fasterxml.jackson.core', name: 'jackson-core', version: '2.9.9'
    public void producter(){
        BrokerService brokerService = new BrokerService();
        brokerService.setUseJmx(true);//設置Broker的服務是否應該公開給JMX
        try {
            brokerService.addConnector("tcp://localhost:61616");
            brokerService.start(); 
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

以上就是ActiveMQ要入門什么，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

當前文章：ActiveMQ要入門什么
文章URL：http://aaarwkj.com/article42/gpjphc.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供面包屑導航、企業(yè)網站制作、、App開發(fā)、網頁設計公司、關鍵詞優(yōu)化

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)