Jbuilder8开发J2ee学习笔记(6)
作者：缪青
开发JMS
1．建立JMS
首先建立JMS，由于需要调用SessionBean所以加入一个Field“sessHome”，注意类型一定是SessHome。对于JMS的一些参数都是我们在前面Weblogic6.1配置中所提前配置好的，忘了的话，回去看看。
这样一个简单的点对点的JMS接收器就差不多了。
2．书写代码
public void onMessage(Message msg) {
try {
TextMessage TMS = (TextMessage) msg;
String a1 = TMS.getText();
String b1 = a1;
System.out.println("Message getted Is :" + a1 + ">>>>>>>>>>>OK");
Context context = getInitialContext();
Object ref = context.lookup("SessBean");
sessHome = (SessHome) PortableRemoteObject.narrow(ref, SessHome.class);
sessHome.create().insTableAa11(a1, b1);
//这是通过Session的insTableAa11调用EntityBean的ejbHomeEjbInsertAa11
//功能其是很简单，插入Aa11表一条记录(a1,a1)
}
catch (Exception ex) {
ex.printStackTrace();
}
}
代码很简单，几乎和SessionBean的测试端代码差不多，没什么问题吧。
3．发布JMS
和上一节讲的一样，使用ReDelpoy发布EJB上Weblogic6.1
4．开发测试程序
现在要开发JMS的发布端了，这里只要新建一个CLASS就可以了。
代码下面给出：
package userjmssesenbdb;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
public class Client {
public final static String
JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";
public final static String URL = "t3://127.0.0.1:7001";
private static final String QUEUE_CONNECTION_FACTORY =
"DemoJMSConnectionFactory";
private static final String QUEUE = "DemoJMSQueue";
private static InitialContext getInitialContext(String url) throws
NamingException {
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
env.put(Context.PROVIDER_URL, url);
return new InitialContext(env);
}
public static void main(String[] args) throws Exception {
Context ctx = getInitialContext(URL);
QueueConnectionFactory qConnFact =
(QueueConnectionFactory) ctx.lookup(QUEUE_CONNECTION_FACTORY);
QueueConnection qConn = qConnFact.createQueueConnection();
QueueSession qSess = qConn.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
Queue q = (Queue) ctx.lookup(QUEUE);
QueueSender qSend = qSess.createSender(q);
TextMessage txtMsg = qSess.createTextMessage("c");
System.out.println("Sending a message to queue");
qSend.send(txtMsg);
//---------------------------------------------------------//
txtMsg = qSess.createTextMessage("a");
System.out.println("Sending a message to queue");
qSend.send(txtMsg);
//---------------------------------------------------------//
qConn.close();
System.exit(0);
}
}
看懂了么，其实就是发送“c”，“a”到接收端。执行一下，是不是数据表aa11中又多了2条记录。
