~~~ import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TextProductor { public void sendTextMessage(String datas){ //連接工廠 ConnectionFactory factory = null; //連接 Connection connection = null; //目的地 Destination destination = null; //會話 Session session = null; //消息發送者 MessageProducer producer = null; //消息對象 Message message = null; try { //創建連接工廠，連接activeMQ服務的連接工廠 factory = new ActiveMQConnectionFactory("guest", "guest", "tcp://114.116.69.58:61616"); //創建連接對象 connection = factory.createConnection(); //啟動連接，消息的發送者不是必須啟動連接，消息的消費者必須啟動連接 connection.start(); /** * 創建會話對象 * 兩個參數： * 1. 是否支持事務 * true 支持事務，true時第二個參數無效 * false 不支持事務，第二個參數必須傳遞 * 2. 如何確認消息 * AUTO_ACKNOWLEDGE 自動確認消息 * CLIENT_ACKNOWLEDGE 客戶端手動確認 * DUPS_OK_ACKNOWLEDGE 有副本的客戶端手動確認 * 一個消息可以多次處理，可以降低Session的消耗，在可以容忍重復消息時使用（不推薦使用） */ session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = session.createTopic("first-tp"); //創建消息發送者 producer = session.createProducer(destination); message = session.createTextMessage(datas); //發送消息 producer.send(message); System.out.println("消息已發送"); }catch (Exception e){ e.printStackTrace(); }finally { if (producer != null){ try { producer.close(); } catch (JMSException e) { e.printStackTrace(); } } if (session != null){ try { session.close(); } catch (JMSException e) { e.printStackTrace(); } } if (connection != null){ try { connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } } public static void main(String[] args) { TextProductor textProductor = new TextProductor(); textProductor.sendTextMessage("hello activemq"); } } ~~~