请教JAVA高手，关于JMS消息远程消费的问题？

Question

大家好，今天测试EJB3.0的JMS相关内容，测试了一下远程消费，步骤和出现的异常如下：
1、写一个生产者：
package com.foshanshop.ejb3.app;import java.util.Properties;import javax.jms.BytesMessage;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSession;
import javax.jms.StreamMessage;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;import com.foshanshop.ejb3.bean.Man;public class QueueSender {
    public static void main(String[] args) {
        QueueConnection conn = null;
        QueueSession session = null;
        try {
            Properties props = new Properties();
            props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
            props.setProperty(Context.PROVIDER_URL, "10.1.35.126:1099");
            props.setProperty(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
            InitialContext ctx = new InitialContext(props);
            
            QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("QueueConnectionFactory");
            conn = factory.createQueueConnection();
            session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
            Destination destination = (Queue) ctx.lookup("queue/foshanshop");
            MessageProducer producer = session.createProducer(destination);
            
            //发送文本
            TextMessage msg = session.createTextMessage("佛山人您好，这是我的第一个消息驱动Bean");
            producer.send(msg);
            
            
        } catch (Exception e) {
         e.printStackTrace();
        }finally{
            try {
                session.close ();
                conn.close();
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }
}
2、在JMS服务器上布置服务
<?xml version="1.0" encoding="UTF-8"?>
<server>  
  <mbean code="org.jboss.mq.server.jmx.Queue"
         name="jboss.mq.destination:service=Queue,name=foshanshop">
    <attribute name="JNDIName">queue/foshanshop</attribute>   
    <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
  </mbean>  <mbean code="org.jboss.mq.server.jmx.Topic"
 name="jboss.mq.destination:service=Topic,name=chatTopic">
<attribute name="JNDIName">topic/chatTopic</attribute>
    <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
  </mbean>
</server>
3、在另外一台机器上布置消费者(该机器也安装了JBOSS，打算将消费者布置在JBOSS里面)
package cn.tcl.remotefoshandrivebean;import java.io.ByteArrayOutputStream;import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.BytesMessage;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.jms.StreamMessage;
import javax.jms.TextMessage;import cn.tcl.remotefoshandrivebean.bean.Man;
@MessageDriven(activationConfig =
{
        @ActivationConfigProperty(propertyName="destinationType", 
           propertyValue="javax.jms.Queue"), 
        @ActivationConfigProperty(propertyName="destination",
                           propertyValue="queue/foshanshop"), 
        @ActivationConfigProperty(propertyName="providerAdapterJNDI",
                           propertyValue="java:/RemoteJMSProvider") 
}) 
public class FoshanConsumer implements MessageListener {public void onMessage(Message msg) {        try {            
            if (msg instanceof TextMessage) {
                TextMessage tmsg = (TextMessage) msg;
                String content = tmsg.getText();
                System.out.println(content);
            }            
        } catch (Exception e){
            e.printStackTrace();
        }
    
}}
同时在jboss的server\default\deploy目录下放一个配置文件foshanshop-consumer-service.xml文件内容如下：
<mbean code="org.jboss.jms.jndi.JMSProviderLoader"
   name="jboss.mq:service=JMSProviderLoader,name=RemoteJMSProvider,server=remotehost"> 
    <attribute name="ProviderName">RemoteJMSProvider</attribute> 
    <attribute name="ProviderAdapterClass">org.jboss.jms.jndi.JNDIProviderAdapter</attribute> 
    <!-- The connection factory --> 
    <attribute name="FactoryRef">UIL2XAConnectionFactory</attribute> 
    <!-- The queue connection factory --> 
    <attribute name="QueueFactoryRef">UIL2XAConnectionFactory</attribute> 
    <!-- The topic factory --> 
    <attribute name="TopicFactoryRef">UIL2XAConnectionFactory</attribute> 
    <!-- Connect to JNDI on the host "the-remote-host-name" port 1099--> 
    <attribute name="Properties"> 
        java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory 
        java.naming.factory.url.pkgs=org.jnp.interfaces 
        java.naming.provider.url=10.1.35.126:1099 
    </attribute> 
  </mbean> 
以上完成了所有的步骤，启动JMS服务器没有问题，启动消费者的JBOSS时系统报出如下异常：
20:40:57,165 WARN  [ServiceController] Problem starting service jboss.j2ee:jar=M
essageDrivenBean.jar,name=FoshanConsumer,service=EJB3
javax.naming.NoInitialContextException: Cannot instantiate class: org.jnp.interf
aces.NamingContextFactory  [Root exception is java.lang.ClassNotFoundException:
No ClassLoaders found for: org.jnp.interfaces.NamingContextFactory ]
        at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:6
57)
        at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:288
)
        at javax.naming.InitialContext.init(InitialContext.java:223)
        at javax.naming.InitialContext.<init>(InitialContext.java:197)
        at org.jboss.jms.jndi.JNDIProviderAdapter.getInitialContext(JNDIProvider
Adapter.java:44)
        at org.jboss.ejb3.mdb.MessagingContainer.jmsCreate(MessagingContainer.ja
va:374)
        at org.jboss.ejb3.mdb.MessagingContainer.innerStart(MessagingContainer.j
ava:166)
        at org.jboss.ejb3.mdb.MessagingContainer.start(MessagingContainer.java:1
52)
        at org.jboss.ejb3.mdb.MDB.start(MDB.java:126)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)从报出的异常上看Cannot instantiate class: org.jnp.interf
aces.NamingContextFactory  [Root exception is java.lang.ClassNotFoundException:
系统好象是没有找到NamingContextFactory这个类，而自己也查看了一下在jboss\server\default\lib这个目录下有jnpservler.jar这个包中存在，而这个目录下是自动加载，百思不得其解为什么会报出这个异常，希望各位JAVA高手能够指定

Answer 1

真是不可思议，CSDN里面这么多高手，怎么就没有人回答呢？

Answer 2

查看是否将JBOSS_Home下client文件夹中的所有jar包都导入到了项目工程中。或者,在classpath內,加上%JBoss Home%clientjbossall-client.jar

Answer 3

哥们这样有用吗？jboss自动启动时直接会将jnpserver.jar加载，我昨天也试着将jbossall-client.jar加入到server/default/lib下面去，反而会报出其他错误，其实昨天我还怀疑是不是我自己的jdk版本的问题，但是今天早上也将这个怀疑否定了，，真是没有办法，恳请高手指点。。