当前页面: 开发资料首页 → J2EE 专题 → Jbuilder8开发J2ee学习笔记(6)
摘要: BMP,SessionBean,JMS,Struts,Oracle,Jbuilder8,Weblogic
Jbuilder8开发J2ee学习笔记(6)<?xml:namespace prefix = o ns = "urn:schemas-microsoft-com:office:office" />
作者:缪青
1.建立JMS
首先建立JMS,由于需要调用SessionBean所以加入一个Field“sessHome”,注意类型一定是SessHome。对于JMS的一些参数都是我们在前面Weblogic6.1配置中所提前配置好的,忘了的话,回去看看。
<?xml:namespace prefix = v ns = "urn:schemas-microsoft-com:vml" />
这样一个简单的点对点的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条记录。