牛仔裤的夏天

JAVA是蓝色的- online
  BlogJava :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理 ::
  30 随笔 :: 5 文章 :: 15 评论 :: 0 Trackbacks
Weblogic JMS 的配置和MDB的应用(听课笔记)
  • 在JMS的Connection Factories 中新建一个连接工厂
  • 在Stores中新建一个存储空间，可以为jdbc或者file类型
  • 在Servers中新建一个Server
  • 展开刚才创建的DemoJMSServer，新建一个Destinations，其中有2种类型，queue：点对点方式，topic：广播方式给所有的MDB
  • 在jb中新建一个MDB，transaction type:bean ，Destination type:javax.jms.Queue，在Destination name中输入刚才在weblogic的jms里面建立的目标名称，Pool properties的Maximum pool size:10
  • 在onMessage方法中加入代码
    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     = new InitialContext();

          Object ref     = context.lookup("Sess");  //session bean的本地接口

          SessHome sessHome     = (SessHome) PortableRemoteObject.narrow(ref, SessHome.class);

          sessHome.create().insTableAa11(a1, b1);

              //这是通过Session Bean的insTableAa11调用EntityBean的ejbHomeEjbInsertAa11

              //功能其是很简单，插入Aa11表一条记录(a1,a1)

        }

            catch (Exception ex) {

          ex.printStackTrace();

        }
    }
  • deploy这个消息驱动Bean
  • new一个MDBTestClient class
    package bmpsessmdb;
    import java.util.*;

    import javax.jms.*;

    import javax.naming.*;


    public class MDBTestClient {
            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("songtx3");

        System.out.println(    "Sending a message to queue");

        qSend.send(txtMsg);

            //---------------------------------------------------------//

        txtMsg     = qSess.createTextMessage("songtx4");

        System.out.println(    "Sending a message to queue");

        qSend.send(txtMsg);

            //---------------------------------------------------------//

        qConn.close();

        System.exit(    0);

      }

    }
  • 运行测试，over
posted on 2006-03-23 14:51 luckyrobbie 阅读(1550) 评论(0)  编辑  收藏 所属分类: Tomcat & Weblogic

只有注册用户登录后才能发表评论。
网站导航: