一个JMS程序的实现步骤

ConnectionFactory connectionFactory;connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.0.214:61616");

Queue queue = new ActiveMQQueue("q");Topic topic = new ActiveMQTopic("t");

Connection connection = connectionFactory.createConnection();connection.start();

Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

//创建消息生产者 MessageProducer producer = session.createProducer(queue);

/** * 创建map消息 */ MapMessage mapMessage = session.createMapMessage(); mapMessage.setString("Name","Daizi"); mapMessage.setDouble("Value",1234); mapMessage.setLong("Time",new Date().getTime());

//开始发送消息 producer.send(mapMessage);

当然这个步骤不是钉死的！