我是 JMS 新手，从我的独立客户端连接到远程 JMS 队列时遇到问题。任何有关解决此问题的提示将不胜感激。
现在我有一个在多个客户端上运行的 JavaFX 独立应用程序和一个在远程 Unix 机器上运行的 glassfish 服务器 3.1.2.2。我很难将独立应用程序中的消息推送到驻留在服务器上的队列中。
Client Mc：Windows PC（未安装服务器） Remote Mc：Unix（已安装 GlassFish 3.1.2.2）
服务器上的 JMS 资源：
JMS 目标资源
JNDI 名称：jms/ReferralQueue
物理目的地名称：ReferralQueue
资源类型：javax.jms.Queue
JMS 连接工厂
池名称：jms/ReferralConnectionFactory
JNDI 名称：jms/ReferralConnectionFactory
资源类型：javax.jms.QueueConnectionFactory
JMS 服务类型：嵌入式
JMS 消息存储类型：文件
连接服务器的客户端代码：
jms.properties：
org.omg.CORBA.ORBInitialHost= UNIX MC URL
org.omg.CORBA.ORBInitialPort= 7676
服务定位器设计实现资源缓存
public class JMSServiceLocator {
private static JMSServiceLocator singletonService = null;
private static QueueConnectionFactory qFactory;
private static Queue queue;
private InitialContext context;
private static Properties properties = new Properties();
private Map cache;
static {
try {
singletonService = new JMSServiceLocator();
} catch (Exception e) {
//error handling
}
}
private JMSServiceLocator() {
try {
loadProperties();
context = new InitialContext(properties);
cache = Collections.synchronizedMap(new HashMap());
} catch (Exception e) {
//error handling
}
}
public static JMSServiceLocator getInstance() {
return singletonService;
}
public QueueConnectionFactory getQueueConnectionFactory() {
String qConnFactoryName = "jms/ReferralConnectionFactory";
qFactory = null;
try {
System.out.println("/********************Comment after Testing*****************************/");
Hashtable env = context.getEnvironment();
System.out.println("**env.size::" + env.size());
Enumeration names = env.keys();
while (names.hasMoreElements()) {
String str = (String) names.nextElement();
System.out.println("**" + str + "=" + env.get(str));
}
System.out.println("/**********************************************************************/");
if (cache.containsKey(qConnFactoryName)) {
qFactory = (QueueConnectionFactory) cache.get(qConnFactoryName);
} else {
qFactory = (QueueConnectionFactory) context.lookup(qConnFactoryName);
cache.put(qConnFactoryName, qFactory);
}
} catch (Exception e) {
//error handling
}
return qFactory;
}
public Queue getQueue() {
String queueName = "jms/ReferralQueue";
queue = null;
try {
if (cache.containsKey(queueName)) {
queue = (Queue) cache.get(queueName);
} else {
queue = (Queue) context.lookup(queueName);
cache.put(queueName, queue);
}
} catch (Exception e) {
//error handling
}
return queue;
}
private static void loadProperties() {
//Load jms properties
}
}
最终向服务器发送消息：
JMSServiceLocator jmsLocator = JMSServiceLocator.getInstance();
QueueConnectionFactory qConnFactory = jmsLocator.getQueueConnectionFactory();
qConnection = qConnFactory.createQueueConnection();
session = qConnection.createSession(false, ession.AUTO_ACKNOWLEDGE);
queue = jmsLocator.getQueue();
// Push and publish the message
messageProducer = session.createProducer(queue);
textMessage = session.createTextMessage();
textMessage.setText(message);
messageProducer.send(textMessage);
嗯......现在我观察到一个奇怪的行为......
我在客户端机器上创建了一个新的 GlassFish 3.1.2.2 服务器实例，没有 jndi、没有连接工厂，也没有 jms 队列。
我已经启动了这个服务器实例并执行了独立的客户端应用程序。奇怪的是，一切正常，消息直接被推送到远程队列。
有没有人遇到过这种问题？我怀疑只有在启动服务器实例（可能是任何随机实例，完全不相关）时，应用程序才可能在类路径中加载依赖的 GlassFish jar。
我的独立应用程序类路径中有以下 jar：
*C:\Program Files\glassfish-3.1.2.2\glassfish\lib\gf-client.jar *C:\Program Files\glassfish-3.1.2.2\glassfish\lib\appserv-rt.jar *C:\Program Files \glassfish-3.1.2.2\glassfish\lib\install\applications\jmsra\imqbroker.jar *C:\Program Files\glassfish-3.1.2.2\glassfish\lib\install\applications\jmsra\imqjmsra.jar
我还在Oracle JMS和GlassFish论坛上发布了这个，但没有找到解决方案。对此问题的任何帮助将不胜感激。
谢谢。