作者LCHENAN (~!!)
看板java
标题Re: [J2EE] 问题,想请问 JMS的Queue的问题
时间Sun Aug 9 11:12:02 2009
各位前辈好
先前的问题，应该是我程式有地方出错
因此，才会产生这样的事情
在经简单的程式测试之後
以下的程式码是可正常运行的
给有需要的人参考
当然，我对程式还不是很熟，因此如果有错
请不吝指教 谢谢
在Queue的发送端:
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.jms.*;
import javax.naming.*;
import javax.xml.soap.*;
/**
*OK
* @author Frederic
*/
public class SendQueue implements MessageListener
{
private QueueConnection qConnection = null;
private QueueSession qSession = null;
private QueueSender qSender = null;
private Queue receiveQueue = null;
private Queue sendQueue = null;
public static void main(String args[]) throws NamingException, JMSException, UnknownHostException
{
String hostName = args[0];
SendQueue sendQueue = new SendQueue(hostName);
sendQueue.sendMessage();
System.exit(1);
}
public SendQueue(String hostName) throws NamingException, JMSException
{
QueueConnectionFactory qFactory = null;
InitialContext jndi = null;
Properties env = new Properties();
//指定要传送讯息的主机名称
env.put("org.omg.CORBA.ORBInitialHost", hostName);
//指定要传送讯息的Port
env.put("org.omg.CORBA.ORBInitialPort", "3700");
jndi = new InitialContext(env);
qFactory = (QueueConnectionFactory) jndi.lookup("jms/QueueConnectionFactory");
qConnection = qFactory.createQueueConnection("guest", "guest");
qSession = qConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
sendQueue = (Queue) jndi.lookup("jms/Queue_RCS");
}
public void onMessage(Message message)
{
System.out.println("这边不关我的事情!!");
}
public void sendMessage() throws UnknownHostException, JMSException
{
TextMessage myMessage = this.qSession.createTextMessage();
myMessage.setText("Hello!!!");
//利用QueueSender和QueueSession来建立讯息的发送
qSender = qSession.createSender(sendQueue);
//送出讯息
qSender.send(
myMessage,
DeliveryMode.PERSISTENT,
Message.DEFAULT_PRIORITY,
1800000);
//传送完之後,就将连线关掉
this.qConnection.close();
}
}
//=================================================================
在Queue的接收端
import java.io.IOException;
import javax.xml.soap.SOAPException;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.jms.*;
import javax.naming.*;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPMessage;
/**
*
* @author Frederic
*/
public class ReceiveQueue implements MessageListener
{
private String broker;
private static QueueConnection qConnection = null;
private QueueSession qSession = null;
private QueueSender qSender = null;
private Queue receiveQueue = null;
private Queue sendQueue = null;
public static void main(String args[]) throws NamingException, JMSException, UnknownHostException
{
System.out.println("准备要开始监听!!");
ReceiveQueue receiveQueue = new ReceiveQueue();
}
public ReceiveQueue() throws NamingException, JMSException, UnknownHostException
{
QueueConnectionFactory qFactory = null;
InitialContext jndi = null;
Properties env = new Properties();
//指定要订阅讯息的主机名称
//抓取本机名称
InetAddress addr = InetAddress.getLocalHost();
String localHostName=addr.getHostName();
env.put("org.omg.CORBA.ORBInitialHost", localHostName);
//指定要传送讯息的Port
env.put("org.omg.CORBA.ORBInitialPort", "3700");
jndi = new InitialContext(env);
qFactory = (QueueConnectionFactory) jndi.lookup("jms/QueueConnectionFactory");
qConnection = qFactory.createQueueConnection("guest", "guest");
qSession = qConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
receiveQueue = (Queue) jndi.lookup("jms/Queue_RCS");
QueueReceiver qReceiver = qSession.createReceiver(receiveQueue);
qReceiver.setMessageListener(this);
qConnection.start();
}
public void onMessage(Message message)
{
try {
TextMessage myMessage = (TextMessage) message;
System.out.println(myMessage.getText());
} catch (JMSException ex) {
Logger.getLogger(ReceiveQueue.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
--
※ 发信站: 批踢踢实业坊(ptt.cc)
◆ From: 218.172.79.138