spring-kms-test源码

package com.iboray.test.jms; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; /** * Created by jm on 16/9/20. */ public class JmsProducter { public static void main(String[] args) { //连接工厂 ConnectionFactory connectionFactory; //连接 Connection connection = null; //会话 接受或者发送消息的线程 Session session; //消息的目的地 Destination destination; //消息生产者 MessageProducer producer; //实例化连接工厂(默认连接用户名,密码,连接地址) connectionFactory = new ActiveMQConnectionFactory("xiaoshoujia","xiaoshoujia123","tcp://101.200.183.100:61616"); try { //通过连接工厂获取连接 connection = connectionFactory.createConnection(); //启动连接 connection.start(); //创建session session = connection.createSession(true,Session.AUTO_ACKNOWLEDGE); //创建一个名称为HelloWorld的消息队列 destination = session.createQueue("Hello queue"); //创建消息生产者 producer = session.createProducer(destination); //发送消息 send(session,producer); session.commit(); }catch (Exception e){ }finally { if (connection != null){ try { connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } } /** * 发送消息 * @param session * @param producer 消息生产者 * @throws Exception */ static void send(Session session,MessageProducer producer) throws JMSException { for (int i=0;i<10;i++){ //创建一条文本消息 TextMessage message = session.createTextMessage("msgaaa"+i); System.out.println("send msg"+i); //通过消息生产者发出消息 producer.send(message); } } }