开发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条记录。