p2psender.java

jms队列方式发送端代码

package temp;

import java.util.Properties;

import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;

import javax.naming.InitialContext;

import java.util.Hashtable;

/**
 * This class demonstrates a simple sender in a point-to-point
 * JMS application.
 * @author dwhuang
 */
public class p2pSender
{
	public static void main(String args[])
	{
		try
		{
			System.out.println("p2pSender started");

	 		//手工配置JNDI
	 		Properties props = new Properties();
			props.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
			props.put("java.naming.provider.url", "localhost:1099");
			props.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
			InitialContext ic = new InitialContext(props);

			//queue/testQueue必须在$JBOSS_HOME/server/default/deploy/\jbossmq-destinations-service.xml文件中定义
			String queueName = "queue/testQueue";
			//查找连接工厂
			QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)ic.lookup("ConnectionFactory");
			//查找目的地
			Queue queue = (Queue)ic.lookup(queueName);
			
			//建立连接
			QueueConnection queueConnection = queueConnectionFactory.createQueueConnection();
			//建立会话
			QueueSession queueSession = queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);//不需要事务,自动接收消息的收条
			//建立消息发送者
			QueueSender queueSender = queueSession.createSender(queue);
			
			//开启连接
			queueConnection.start();
			System.out.println("about to send message");
			
			//发送消息
			TextMessage message = queueSession.createTextMessage();
			message.setText("This is the 1st message for p2pSender the demo ");
			queueSender.send(message);
		
			message = queueSession.createTextMessage();
			message.setText("This is the 2nd message for p2pSender the demo ");
			queueSender.send(message);
			
			queueSender.send(queueSession.createMessage());
			//关闭连接
			queueConnection.close();
		}
	    catch(Exception e)
		{
			e.printStackTrace();
		}
   }
}