`
liyuandong
  • 浏览: 331733 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

JMS简明学习教程(二)

    博客分类：
  • JMS
JMSJBossSecurityJVMBlog 
阅读更多

 实战篇

本文来自CSDN博客，转载请标明出处：http://blog.csdn.net/Linyufa/archive/2009/07/24/4375670.aspx

 

 前面对JMS概念的作了一个基本介绍，下面我们看一个具体的例子程序

 

Pub/sub方式的消息传递的例子:

l    HelloPublisher.java

 

package com.jms.test;

 

import java.util.Hashtable;

 

import javax.jms.JMSException;

import javax.jms.Session;

import javax.jms.TextMessage;

import javax.jms.Topic;

import javax.jms.TopicConnection;

import javax.jms.TopicConnectionFactory;

import javax.jms.TopicPublisher;

import javax.jms.TopicSession;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

 

/**

 * pub/sub方式的消息发送程序

 */

public class HelloPublisher {

   

    TopicConnection topicConnection;// JMS连接，属于Pub/Sub方式的连接

    TopicSession topicSession; //JMS会话，属于Pub/Sub方式的会话

    TopicPublisher topicPublisher; //消息发布者

    Topic topic; //主题

   

    public HelloPublisher(String factoryJNDI, String topicJNDI)

           throws JMSException, NamingException {

       Hashtable<String, String> env = new Hashtable<String, String>();

       //设置好连接JMS容器的属性，不同的容器需要的属性可能不同，需要查阅相关文档

       env.put(Context.INITIAL_CONTEXT_FACTORY,

              "org.jnp.interfaces.NamingContextFactory");

       env.put(Context.PROVIDER_URL, "localhost:1099");

       env.put("java.naming.rmi.security.manager", "yes");

       env.put(Context.URL_PKG_PREFIXES, "org.jboss.naming");

 

       //创建连接JMS容器的上下文(context)

       Context context = new InitialContext(env);

 

       //通过连接工厂的JNDI名查找ConnectionFactory

       TopicConnectionFactory topicFactory =

           (TopicConnectionFactory) context.lookup(factoryJNDI);

 

       //用连接工厂创建一个JMS连接

       topicConnection = topicFactory.createTopicConnection();

 

       //通过JMS连接创建一个Session

       topicSession = topicConnection.createTopicSession(false,

              Session.AUTO_ACKNOWLEDGE);

 

       //通过上下文查找到一个主题(topic)

       topic = (Topic) context.lookup(topicJNDI);

 

       //用session来创建一个特定主题的消息发送者

       topicPublisher = topicSession.createPublisher(topic);

    }

   

 

    /**

     * 发布一条文本消息

     * @param msg 待发布的消息

     * @throws JMSException

     */

    public void publish(String msg) throws JMSException {

       //用session来创建一个文本类型的消息

       TextMessage message = topicSession.createTextMessage();

       message.setText(msg);//设置消息内容

       topicPublisher.publish(topic, message);//消息发送，发送到特定主题

    }

 

    public void close() throws JMSException {

       topicSession.close();//关闭session

       topicConnection.close();//关闭连接

    }

 

    public static void main(String[] args)

       throws JMSException, NamingException {

       HelloPublisher publisher =

           new HelloPublisher("ConnectionFactory", "topic/testTopic");

       try {

           for (int i = 1; i < 11; i++) {

              String msg = "Hello World no. " + i;

              System.out.println("Publishing message: " + msg);

              publisher.publish(msg);

           }

           publisher.close();//session和connection用完之后一定记得关闭

       } catch (Exception ex) {

           ex.printStackTrace();

       }

    }

}

程序在控制台输出：

Publishing message: Hello World no. 1

Publishing message: Hello World no. 2

Publishing message: Hello World no. 3

Publishing message: Hello World no. 4

Publishing message: Hello World no. 5

Publishing message: Hello World no. 6

Publishing message: Hello World no. 7

Publishing message: Hello World no. 8

Publishing message: Hello World no. 9

Publishing message: Hello World no. 10

 

 

l        HelloSubscriber.java

 

package com.jms.test;

 

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.Session;

import javax.jms.TextMessage;

import javax.jms.Topic;

import javax.jms.TopicConnection;

import javax.jms.TopicConnectionFactory;

import javax.jms.TopicSession;

import javax.jms.TopicSubscriber;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

 

/**

 * pub/sub方式下的消息接收器。注意，这个消息接收器可以与上面的消息发送器可以工作

* 在不同的JVM中，只要保证它们各自能够连通JMS容器(JMS Provider)

 *

 */

public class HelloSubscriber implements MessageListener {

    TopicConnection topicConnection;

    TopicSession topicSession;

    TopicSubscriber topicSubscriber;

    Topic topic;

 

    public HelloSubscriber(String factoryJNDI, String topicJNDI)

           throws JMSException, NamingException {

Hashtable<String, String> env = new Hashtable<String, String>();

       //设置好连接JMS容器的属性，不同的容器需要的属性可能不同，需要查阅相关文档

       env.put(Context.INITIAL_CONTEXT_FACTORY,

              "org.jnp.interfaces.NamingContextFactory");

       env.put(Context.PROVIDER_URL, "localhost:1099");

       env.put("java.naming.rmi.security.manager", "yes");

       env.put(Context.URL_PKG_PREFIXES, "org.jboss.naming");

       Context context = new InitialContext();

 

       TopicConnectionFactory topicFactory =

           (TopicConnectionFactory) context.lookup(factoryJNDI);

       //创建连接

       topicConnection = topicFactory.createTopicConnection();

       topicSession = topicConnection.createTopicSession(false,

              Session.AUTO_ACKNOWLEDGE);//创建session

       topic = (Topic) context.lookup(topicJNDI);//查找到主题

       //用session创建一个特定queue的消息接收者

       topicSubscriber = topicSession.createSubscriber(topic);

       //注册监听，这里设置的监听是自己，因为本类已经实现了MessageListener接口，

       //一旦queueReceiver接收到了消息，就会调用本类的onMessage方法

       topicSubscriber.setMessageListener(this);

       System.out.println("HelloSubscriber subscribed to topic: "

              + topicJNDI);

       topicConnection.start();//启动连接，这时监听器才真正生效

    }

 

    public void onMessage(Message msg) {

       try {

           if (msg instanceof TextMessage) {

              //把Message 转型成 TextMessage 并提取消息内容

              String msgTxt = ((TextMessage) msg).getText();

              System.out.println("HelloSubscriber got message: " +

                  msgTxt);

           }

       } catch (JMSException ex) {

           System.err.println("Could not get text message: " + ex);

           ex.printStackTrace();

       }

    }

 

    public void close() throws JMSException {

       topicSession.close();

       topicConnection.close();

    }

 

    public static void main(String[] args) {

       try {

           new HelloSubscriber("TopicConnectionFactory",

              "topic/testTopic");

       } catch (Exception ex) {

           ex.printStackTrace();

       }

    }

}

程序在控制台输出：

HelloSubscriber subscribed to topic: topic/testTopic

HelloSubscriber got message: Hello World no. 1

HelloSubscriber got message: Hello World no. 2

HelloSubscriber got message: Hello World no. 3

HelloSubscriber got message: Hello World no. 4

HelloSubscriber got message: Hello World no. 5

HelloSubscriber got message: Hello World no. 6

HelloSubscriber got message: Hello World no. 7

HelloSubscriber got message: Hello World no. 8

HelloSubscriber got message: Hello World no. 9

HelloSubscriber got message: Hello World no. 10

 

 

 

P2P方式下的消息传递

l         HelloQueue.java

 

package com.jms.test;

 

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.jms.QueueConnectionFactory;

import javax.jms.QueueConnection;

import javax.jms.QueueSession;

import javax.jms.QueueSender;

import javax.jms.Queue;

import javax.jms.TextMessage;

import javax.jms.Session;

import javax.jms.JMSException;

 

import java.util.Hashtable;

 

public class HelloQueue {

    QueueConnection queueConnection; //queue方式的JMS连接

    QueueSession queueSession; //queue会话

    QueueSender queueSender; //queue消息发送者

    Queue queue; //消息队列

 

    public HelloQueue(String factoryJNDI, String topicJNDI)

            throws JMSException, NamingException {

        //连接JMS Provider的环境参数

        Hashtable<String, String> props = new Hashtable<String, String>();

        props.put(Context.INITIAL_CONTEXT_FACTORY,

                "org.jnp.interfaces.NamingContextFactory");

        //JMS provider的主机和端口

        props.put(Context.PROVIDER_URL, "localhost:1099");

        props.put("java.naming.rmi.security.manager", "yes");

        props.put(Context.URL_PKG_PREFIXES, "org.jboss.naming");

        Context context = new InitialContext(props);

       

        //lookup到连接工厂

        QueueConnectionFactory queueFactory =

            (QueueConnectionFactory) context.lookup(factoryJNDI);

        queueConnection = queueFactory.createQueueConnection();//创建连接

        queueSession = queueConnection.createQueueSession(false,

                Session.AUTO_ACKNOWLEDGE);//创建会话

 

        queue = (Queue) context.lookup(topicJNDI);//lookup到特定的消息队列

 

        queueSender = queueSession.createSender(queue);//创建队列消息的发送者

 

    }

 

    public void send(String msg) throws JMSException {

        TextMessage message = queueSession.createTextMessage();

        message.setText(msg);

        queueSender.send(queue, message);

    }

 

    public void close() throws JMSException {

        queueSession.close();

        queueConnection.close();

    }

 

    public static void main(String[] args) {

        try {

            HelloQueue queue = new HelloQueue("ConnectionFactory",

                    "queue/testQueue");

            for (int i = 11; i < 21; i++) {

                String msg = "Hello World no. " + i;

                System.out.println("Hello Queue Publishing message: " + msg);

                queue.send(msg);

            }

            queue.close();

        } catch (Exception ex) {

            System.err.println("An exception occurred " +

"while testing HelloPublisher25: " + ex);

            ex.printStackTrace();

        }

    }

}

 

程序在控制台输出：

 

Hello Queue Publishing message: " Hello World no. 11

Hello Queue Publishing message: " Hello World no. 12

Hello Queue Publishing message: " Hello World no. 13

Hello Queue Publishing message: " Hello World no. 14

Hello Queue Publishing message: " Hello World no. 15

Hello Queue Publishing message: " Hello World no. 16

Hello Queue Publishing message: " Hello World no. 17

Hello Queue Publishing message: " Hello World no. 18

Hello Queue Publishing message: " Hello World no. 19

Hello Queue Publishing message: " Hello World no. 20

 

 

 

l        HelloRecvQueue.java

 

package com.jms.test;

 

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.Session;

import javax.jms.TextMessage;

import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueConnectionFactory;

import javax.jms.QueueSession;

import javax.jms.QueueReceiver;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

 

public class HelloRecvQueue implements MessageListener {

    QueueConnection queueConnection;

    QueueSession queueSession;

    QueueReceiver queueReceiver;

    Queue queue;

 

    public HelloRecvQueue(String factoryJNDI, String topicJNDI)

            throws JMSException, NamingException {

        Context context = new InitialContext();

        QueueConnectionFactory queueFactory =

            (QueueConnectionFactory) context.lookup(factoryJNDI);

        queueConnection = queueFactory.createQueueConnection();

        queueSession = queueConnection.createQueueSession(false,

                Session.AUTO_ACKNOWLEDGE);

        queue = (Queue) context.lookup(topicJNDI);

 

        queueReceiver = queueSession.createReceiver(queue);

        queueReceiver.setMessageListener(this);

        System.out.println("HelloReceQueue receiver to queue: " + topicJNDI);

        queueConnection.start();

    }

 

    public void onMessage(Message m) {

        try {

            String msg = ((TextMessage) m).getText();

            System.out.println("HelloReceQueue got message: " + msg);

        } catch (JMSException ex) {

            System.err.println("Could not get text message: " + ex);

            ex.printStackTrace();

        }

    }

 

    public void close() throws JMSException {

        queueSession.close();

        queueConnection.close();

    }

 

    Public ovid main(String[] args) {

    new HelloRecvQueue();

}

}

 

 

 

程序在控制台输出：

 

HelloReceQueue got message: Hello World no. 11

HelloReceQueue got message: Hello World no. 12

HelloReceQueue got message: Hello World no. 13

HelloReceQueue got message: Hello World no. 14

HelloReceQueue got message: Hello World no. 15

HelloReceQueue got message: Hello World no. 16

HelloReceQueue got message: Hello World no. 17

HelloReceQueue got message: Hello World no. 18

HelloReceQueue got message: Hello World no. 19

HelloReceQueue got message: Hello World no. 20

 

分享到：
| JMS简明学习教程(一)
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    JMS 开发简明教程

    Java消息服务（Java Message ..."JMS简明教程.pdf"这份文档应该详细介绍了这些概念，并可能包括实例代码和最佳实践，可以帮助初学者快速入门JMS。学习JMS不仅可以提升你的专业技能，也有助于解决复杂的企业级问题。

    JMS简明教程－－简体中文

    Java消息服务（Java Message Service，简称JMS）是Java平台中用于企业级应用集成的API...通过阅读"JMS简明教程.pdf"，你可以进一步深化对JMS的理解，同时"中国java下载站.url"可能是获取更多Java资源和学习资料的链接。

    一个很好的jms教程

    **JMS（Java Message Service）教程** Java Message Service（JMS）是Java平台中用于创建、发送、接收和读取消息的应用程序接口。...本JMS简明教程将帮助初学者理解其核心概念，并逐步掌握如何在实际项目中运用。

    由浅入深学习、掌握JMS

    **《JMS消息简明教程》** 提供了一个快速入门的指南，简化了JMS的基础知识，适合初学者快速了解JMS的基本概念和操作。它可能包括创建连接工厂、创建和发送消息的示例代码，以及如何测试和调试JMS应用程序的方法。 ...

    JMS.rar_jms

    在学习JMS时，可以参考《JMS简明教程.pdf》这样的文档，它通常会涵盖以上概念，并提供实例代码来帮助理解如何在Java应用程序中使用JMS API创建、发送和接收消息。通过深入学习，开发者可以掌握如何利用JMS构建高可用...

    activemq系列笔记

    4. **JMS简明教程** 这份教程可能提供了JMS基础概念的快速入门，包括消息类型（如TextMessage、ObjectMessage等）、消息模式、生产者和消费者的角色、事务处理以及JMS API的使用方法。 5. **JMS规范教程** JMS...

    最新Java电子书.pdf

    这些电子书资源都是世界级程序设计大师作品，包括 Thinking in Java、Java 数据库高级编程宝典、Java distribute computing、JMS 简明教程等。 Java 基础知识 * Thinking in Java 第三版+第四版（中文版+习题答案...

    Java EE 5 Tutorial (PDF文件)

    通过学习《Java EE 5 Tutorial》，开发者不仅可以掌握这些核心技术，还能了解到如何在实际项目中整合和优化这些组件，提升开发效率和应用性能。这份教程对于想要进入Java企业级开发领域的初学者或是希望更新技能的...

    EJB总结

    《JMS简明教程.pptx》则会帮助你理解JMS的基本概念和使用方式，以及它在企业级应用中的作用。 总之，EJB是Java EE中的重要组成部分，提供了构建企业级应用的强大工具。通过学习和掌握EJB，开发者可以构建出高度模块...

    最新Java电子书.docx

    11. **分布式计算和消息队列**：《Java distribute computing》和《JMS 简明教程》探讨了Java在分布式环境和消息传递中的应用。 12. **游戏编程**：《J2ME Game Programming》介绍了在Java平台上开发移动游戏的技术...

    J2EE中文教材

    J2EE中文教材以简明易懂的语言，结合实际案例，为学习者提供了全面、系统的J2EE学习资源。 **J2EE核心组件** 1. **Java Servlets**: 是J2EE中的核心部分，用于处理HTTP请求并生成响应。Servlets可以扩展服务器功能...

    j2ee程序员必读书.txt

    - **《UML精粹：标准建模语言简明教程》** - 内容：教授UML语言的基本概念和使用方法，有助于软件设计和团队沟通。 - **《重构：改善既有代码的设计》** - 作者：Martin Fowler - 内容：介绍了重构技术，帮助...

Magicbox
Global site tag (gtag.js) - Google Analytics