通过EJB容器调用JMS处理信息所遇到的问题？

0 0

通过EJB容器调用JMS处理信息所遇到的问题？10

EJB接口实现jms队列发送，然后同步方法receive（）接收消息。在通过客户端远程调用的时候，发现服务器线程阻塞在receive（）处直到超时异常抛出，观察发现 send（）方法执行后，并没有立即把消息发出。而通过普通的java类直接实现jms消息收发，则正常发送和接收。

MessageSendAndReceiveForSync.java类的sendAndReceive（String reqMessage）方法实现发送和接收。 Company.java类是提供的远程EJB调用接口方法。CompanyBean.java是远程接口实现。TestCompany.java是远程客户端调用

package com.jms;

import java.util.Hashtable;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class MessageSendAndReceiveForSync {
	
	public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";	
	public final static String PROVIDER_URL = "t3://localhost:7001";	
	public final static String JMS_FACTORY = "jndiConnectionFactory";
	public final static String QUEUE = "jndiQueue";
	public final static String RSPQUEUE = "GSRspQueue";
    
    public String sendAndReceive (String reqMessage)throws Exception  {
    	InitialContext ctx = getInitialContext();
    	QueueConnectionFactory factory = (QueueConnectionFactory)ctx.lookup(JMS_FACTORY);  
        QueueConnection qconn = factory.createQueueConnection();  
        qconn.start();
        //=========================消息发送================================
        Queue queue = (Queue)ctx.lookup(QUEUE);       
        final QueueSession session = qconn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
        Message message = session.createTextMessage(reqMessage);
//        message.setJMSMessageID(System.currentTimeMillis());
        QueueSender qs = session.createSender(queue);
        qs.send(message);
        System.out.println(System.currentTimeMillis()+"=======Send Message Completed!");

        //=========================同步消息接收================================
        Queue rspQ = (Queue)ctx.lookup(RSPQUEUE);
        QueueReceiver qr = session.createReceiver(rspQ);
        System.out.println(System.currentTimeMillis()+"=======receive()方法开始被调用---");
        Message recvMessage = qr.receive(180000L);
        System.out.println(System.currentTimeMillis()+"=======receive()方法已执行完成---");
        TextMessage tm = (TextMessage)recvMessage;
        
        String rspMessage = tm.getText();
        qr.close();
        qs.close();
        qconn.close();
        
        return rspMessage;
    }
    public  InitialContext getInitialContext() throws NamingException {
		Hashtable env = new Hashtable();
		env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
		env.put(Context.PROVIDER_URL, PROVIDER_URL);
		return new InitialContext(env);
	}
    
    public static void main(String[] args) {
    	MessageSendAndReceiveForSync msar = new MessageSendAndReceiveForSync();
    	try {
			String sendAndReceive = msar.sendAndReceive("htjs");
			System.out.println(System.currentTimeMillis()+"=======客户端收到返回消息："+sendAndReceive);
		} catch (Exception e) {
			
			e.printStackTrace();
		}
	}
    
 

}

package com.ejb;


import javax.ejb.Stateless;

import com.jms.MessageSendAndReceive;
import com.jms.MessageSendAndReceiveForSync;

@Stateless(mappedName = "Company")
public class CompanyBean implements Company {

	
	public String getNameForSync(String name) {
		
		String rspMessage ="系统错误";
		 try {
			 
			 MessageSendAndReceiveForSync qs = new MessageSendAndReceiveForSync();
		     rspMessage = qs.sendAndReceive(name);
		
		} catch (Exception e) {			
			e.printStackTrace();
		} 		
		
		return rspMessage;
	}

}

package com.ejb;

import javax.ejb.Remote;
@Remote
public interface Company
{
  
    public String getNameForSync(String name);
    
}

客户端代码

写道

package com.ejb;
import java.util.Properties;
import javax.naming.Context;
import javax.naming.InitialContext;

import com.ejb.Company;

public class TestCompany
{
public static void main(String[] args) throws Exception
{
Properties props = new Properties();
props.setProperty(Context.INITIAL_CONTEXT_FACTORY,
"weblogic.jndi.WLInitialContextFactory");
props.setProperty(Context.PROVIDER_URL, "t3://localhost:7001");

InitialContext ctx = new InitialContext(props);
Company companyRemote = (Company) ctx.lookup("Company#com.ejb.Company");
String name = companyRemote.getNameForSync("htjs");
System.out.println(name);

}
}

问题补充：EJB应用相当于一个中间转发的作用，和客户端通讯采用提供的EJB接口，和远程服务器通信采用JMS。负责把客户端的EJB请求，转化为JMS的消息，然后发送给专门处理的服务器。