~~~ 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://ip: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.createQueue("first-mq"); //创建消息发送者 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"); } } ~~~