ActiveMQ学习系列（二）生产者客户端（java）

java.naming.factory.initial &＃61; org.apache.activemq.jndi.ActiveMQInitialContextFactory# Use the following property to configure the default connector
java.naming.provider.url &＃61; tcp://192.168.2.140:61616# Use the following property to specify the JNDI name the connection factory
# should appear as.
connectionFactoryNames &＃61; ConnectionFactory, queueConnectionFactory, topicConnectionFactry# Register some queues in JNDI using the form:
# queue.[jndiName] &＃61; [physicalName]
queue.MyQueue &＃61; example.MyQueue# Register some topics in JNDI using the form:
# topic.[jndiName] &＃61; [physicalName]
topic.MyTopic &＃61; example.MyTopic

package com.ckl.activemq;
/*** The SimpleQueueSender class consists only of a main method,* which sends several messages to a queue.** Run this program in conjunction with SimpleQueueReceiver.* Specify a queue name on the command line when you run the* program. By default, the program sends one message. Specify* a number after the queue name to send that number of messages.*/import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;/*** A simple polymorphic JMS producer which can work with Queues or Topics which* uses JNDI to lookup the JMS connection factory and destination.*/
public class SimpleProducer {private static final Logger LOG &＃61; LoggerFactory.getLogger(SimpleProducer.class);private SimpleProducer() {}/*** &＃64;param args the destination name to send to and optionally, the number of* messages to send*/public static void main(String[] args) {Context jndiContext &＃61; null;ConnectionFactory connectionFactory &＃61; null;Connection connection &＃61; null;Session session &＃61; null;Destination destination &＃61; null;MessageProducer producer &＃61; null;String destinationName &＃61; null;final int numMsgs;
　　　　//这边被我手动修改了&＃xff0c;比较不喜欢每次运行时还要修改Run configuration&＃xff0c;麻烦。args &＃61; new String[2];args[0] &＃61; "MyTopic";args[1] &＃61; "3";if ((args.length <1) || (args.length > 2)) {LOG.info("Usage: java SimpleProducer []");System.exit(1);}destinationName &＃61; args[0];LOG.info("Destination name is " &＃43; destinationName);if (args.length &＃61;&＃61; 2) {numMsgs &＃61; (new Integer(args[1])).intValue();}else {numMsgs &＃61; 1;}/** Create a JNDI API InitialContext object*/try {jndiContext &＃61; new InitialContext();}catch (NamingException e) {LOG.info("Could not create JNDI API context: " &＃43; e.toString());System.exit(1);}/** Look up connection factory and destination.*/try {connectionFactory &＃61; (ConnectionFactory)jndiContext.lookup("ConnectionFactory");destination &＃61; (Destination)jndiContext.lookup(destinationName);}catch (NamingException e) {LOG.info("JNDI API lookup failed: " &＃43; e);System.exit(1);}/** Create connection. Create session from connection; false means* session is not transacted. Create sender and text message. Send* messages, varying text slightly. Send end-of-messages message.* Finally, close the connection.*/try {connection &＃61; connectionFactory.createConnection();session &＃61; connection.createSession(false, Session.AUTO_ACKNOWLEDGE);producer &＃61; session.createProducer(destination);TextMessage message &＃61; session.createTextMessage();for (int i &＃61; 0; i ) {message.setText("This is message " &＃43; (i &＃43; 1));LOG.info("Sending message: " &＃43; message.getText());producer.send(message);}/** Send a non-text control message indicating end of messages.*/producer.send(session.createMessage());}catch (JMSException e) {LOG.info("Exception occurred: " &＃43; e);}finally {
　　　　　　　//睡眠是我手动加的&＃xff0c;主要为了观察效果try {Thread.sleep(100000L);} catch (InterruptedException e) {e.printStackTrace();}if (connection !&＃61; null) {try {connection.close();}catch (JMSException ignored) {}}}}
}