`

JMS用公用接口进行客户机编程

    博客分类:
  • java
阅读更多
绍 第 1 页(共11 页)




在这一节中,我们将查看两个进行 JMS 客户机消息接发的程序——Sender.java 和 Receiver.java。

我们将按小节分析代码并描述每小节的作用。可以在附录中看到完整的清单:Sender.java 的代码清单 和 Receiver.java 的代码清单。
Sender:提示输入 JNDI 名 第 2 页(共11 页)




所有示例程序都是命令行程序,它们用 System.in 进行输入,用System.out 进行输出。

Sender 类有两个方法:main(String[]) 和 send()。main(String[]) 方法只是举例说明了 Sender 并调用了它的 send() 方法。

send() 方法的第一部分提示了将用来发送消息的受管理对象的 JNDI 名。



import java.io.*;
import javax.jms.*;
import javax.naming.*;

public class Sender {

    public static void main(String[] args) {

        new Sender().send();
    }

    public void send() {

        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

        try {
            //Prompt for JNDI names
            System.out.println("Enter ConnectionFactory name:");
            String factoryName = reader.readLine();
            System.out.println("Enter Destination name:");
            String destinationName = reader.readLine();
              。。。。。。。。。。。
Sender:查询管理对象 第 3 页(共11 页)




send() 方法的下一部分用前面输入的名字在 JNDI 中查询受管理的对象。

通过举例说明 InitialContext 对象访问了 JNDI,通过调用 lookup(String) 方法并传递要获取的对象的名字来检索受管理的对象。注意, lookup(String) 方法返回 Object,所以必须对返回的对象进行类型强制转换(typecast)。

Sender:创建 JMS 对象 第 4 页(共11 页)




现在,我们创建了发送消息所需要的 JMS 对象。注意,我们不用直接使用 new 举例说明这些对象。所有对象都是通过调用另一个对象的方法创建的。

首先,用 ConnectionFactory 创建一个 Connection。然后我们用这个 Connection 创建一个 Session。

Session 没有被处理(false) 并且它将使用自动确认(Session.AUTO_ACKNOWLEDGE)。

最后,创建 Sender ,向从 JNDI 中检索的 Destination 发送消息。



    . . .
            //Create JMS objects
            Connection connection = factory.createConnection();
            Session session =
                connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageProducer sender = session.createProducer(destination);
            . . .



    . . .
            //Look up administered objects
            InitialContext initContext = new InitialContext();
            ConnectionFactory factory =
                (ConnectionFactory) initContext.lookup(factoryName);
            Destination destination = (Destination) initContext.lookup(destinationName);
            initContext.close();
            . . .

Sender:发送消息 第 5 页(共11 页)




现在我们已经可以发送消息了。在这一部分,我们进入一个循环,它提示了要发送消息的文本。如果用户输入 quit,就可以从循环就退出。

否则要在输入文本中建立一个 TextMessage ,用 MessageProducer 发送消息,然后返回到循环的开始部分。



    . . .
            //Send messages
            String messageText = null;
            while (true) {
                System.out.println("Enter message to send or 'quit':");
                messageText = reader.readLine();
                if ("quit".equals(messageText))
                    break;
                TextMessage message = session.createTextMessage(messageText);
                sender.send(message);
            }
            . . .

Sender:退出 第 6 页(共11 页)




退出循环后,关闭 Connection。关闭Connection 会自动关闭 Session 和 MessageProducer。



    . . .
            //Exit
            System.out.println("Exiting...");
            reader.close();
            connection.close();
            System.out.println("Goodbye!");

        } catch (Exception e) {
            e.printStackTrace();
            System.exit(1);
        }
    }
}

Receiver:提示输入 JNDI 的名称并查找受管理的对象 第 7 页(共11 页)




Receiver 类与 Sender 类非常类似,都有一个 main(String[]) 方法,它只是举例说明了 Receiver 并调用它的主要方法 receive()。

提示输入 JNDI 的名称并查找受管理对象的代码与 Sender 中的代码完全一样。

不过,在这个类中有两处不一样的地方:

boolean stop 实例变量用来指出程序应该退出。


Receiver 实现了 MessageListener 接口,为了异步接收消息。



import java.io.*;
import javax.jms.*;
import javax.naming.*;

public class Receiver implements MessageListener {

    private boolean stop = false;

    public static void main(String[] args) {

        new Receiver().receive();
    }

    public void receive() {

        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

        try {
            //Prompt for JNDI names
            System.out.println("Enter ConnectionFactory name:");
            String factoryName = reader.readLine();
            System.out.println("Enter Destination name:");
            String destinationName = reader.readLine();
            reader.close();

            //Look up administered objects
            InitialContext initContext = new InitialContext();
            ConnectionFactory factory =
                (ConnectionFactory) initContext.lookup(factoryName);
            Destination destination = (Destination) initContext.lookup(destinationName);
            initContext.close();
            . . .

Receiver:创建 JMS 对象 第 8 页(共11 页)




像在 Sender 中那样创建Connection 和 Session,然后创建一个 MessageConsumer。

接着,调用 setMessageListener(),传递 Receiver ——本地实例 this,您会重调用它来实现 MessageListener 接口。

最后,启动 Connection,允许接收消息。



    . . .
            //Create JMS objects
            Connection connection = factory.createConnection();
            Session session =
                connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageConsumer receiver = session.createConsumer(queue);
            receiver.setMessageListener(this);
            connection.start();
            . . .


Receiver:等待 stop 并退出 第 9 页(共11 页)




接着,程序进入一个循环,循环会在 stop 变量变为 true 时退出。在循环中,线程睡眠一秒钟。一旦退出循环, Connection 就会关闭,程序会终止。



    . . .
            //Wait for stop
            while (!stop) {
                Thread.sleep(1000);
            }

            //Exit
            System.out.println("Exiting...");
            connection.close();
            System.out.println("Goodbye!");

        } catch (Exception e) {
            e.printStackTrace();
            System.exit(1);
        }
    }
    . . .


Receiver:onMessage(Message) 方法 第 10 页(共11 页)




需要包含 Receiver 类的 onMessage(Message) 方法,因为 Receiver 可以实现 MessageListener 接口。

收到消息时,就调用这个方法,并将 Message 作为参数传递。

在我们的实现中,我们得到消息的文字内容并将它打印到 System.out。然后检查消息是否等于 stop,如果是,那么就将 stop 变量设置为 true,这会使 receive() 方法中的循环终止。



    . . .
    public void onMessage(Message message) {

        try {
            String msgText = ((TextMessage) message).getText();
            System.out.println(msgText);
            if ("stop".equals(msgText))
                stop = true;
        } catch (JMSException e) {
            e.printStackTrace();
            stop = true;
        }
    }
}


返回程序 第 11 页(共11 页)



http://www6.software.ibm.com/developerworks/cn/education/java/j-jms/tutorial/j-jms-1-1.html
如 开始 中所述,编译 Sender 和 Receiver 程序需要 javax.naming 和 javax.jms 包。

在运行这个程序之前,需要使用 JMS 提供者提供的管理工具创建受管理对象 ConnectionFactory 和 Destination ,并将它们放到 JNDI 名字空间中。

还需要保证提供者的 JMS 实现类存在于 classpath 中。

然后,可以同时运行这两个程序,为 ConnectionFactory 和 Destination 提供同样的 JNDI 名称,并从 Sender 向 Receiver 发送消息。


分享到:
评论

相关推荐

    JMS公用接口

    **JMS 公用接口详解** Java Message Service(JMS)是Java平台中用于企业级应用间异步通信的一种标准接口。它为分布式系统提供了一种可靠的消息传递机制,允许应用程序创建、发送、接收和读取消息。在JMS中,有两个...

    Java网络编程--基于Spring的JMS编程

    文件"基于Spring的JMS编程-1"可能包含了关于如何在Spring环境中配置和使用JMS的详细步骤,包括XML配置、代码示例以及可能的实战项目案例。进一步学习这些内容,你将能够熟练掌握Spring框架下的JMS编程技巧,从而在...

    JMS583编程器固件备份

    JMS583编程器固件备份,用于USB-NVME的固态硬盘桥接方案。nvme USB硬盘盒JMS583方案在市面上占有率很高,出现掉固件的情况可能会有,可以用编程器烧录试试。

    软件接口(JMS及WEB SERVICE)

    API的目的是允许程序员在不了解底层实现细节的情况下,通过预定义的函数、类或方法进行编程。API的使用大大降低了开发的复杂性,提高了代码的可复用性和可维护性。 另一方面,接口也指人与软件之间的交互界面,如...

    jms-1.1接口定义代码

    JMS(Java Message Service)是Java平台中用于企业级应用之间进行异步消息传递的一种标准API。在JMS 1.1版本中,它提供了一套接口和模型,使得开发人员能够创建、发送、接收和读取消息。JMS允许应用程序在不关心彼此...

    javax.jms包,sun的JMS接口规范包

    `javax.jms`包是JMS规范的核心部分,包含了各种与消息传递相关的接口和类,这些接口和类为开发人员提供了一种在分布式环境中进行异步通信的标准方式。 1. **JMS接口**:`javax.jms`包中定义了几个关键接口,包括`...

    用JMS编程

    ### 用JMS编程 #### 一、JMS概述与重要性 Java消息服务(JMS)是一项重要的技术,用于实现分布式系统中的消息传递。它为开发者提供了一套标准的API,使得Java应用能够与消息中间件进行交互,无论后者是由哪家厂商...

    JMS 简单使用指南

    Java消息服务(JMS,Java Message Service)是一种用于在分布式环境中进行异步通信的应用程序接口。JMS允许应用程序创建、发送、接收和读取消息,有效地处理系统间的解耦和消息传递。以下是对JMS的一些关键知识点的...

    jms官方接口

    官方jar,用于JMS queue和topic开发

    JMS 使用 ActiveMQ 传送文件

    2. **JMS 使用 ActiveMQ 传送文件.doc** - 这个文档应该直接涵盖了如何使用ActiveMQ进行文件传输的具体步骤,可能包括了创建消息、设置目的地、发送和接收文件的代码示例,以及如何处理错误和异常的情况。...

    JMS583方案原理图参考手册

    JMS583作为桥接芯片,它的核心功能是将USB 3.1 Gen 2接口的数据信号转换为PCIe Gen3x2接口可识别的形式,实现两个不同协议间的通信,使得外接的USB设备(如存储设备)能够通过M.2接口与主板进行高速数据交换。...

    基于Jboss的jms编程

    为了在Jboss上进行JMS编程,你需要将一系列Spring相关的JAR文件放入服务的lib目录中,包括`spring-aop.jar`, `spring-beans.jar`, `spring-context.jar`, `spring-context-support.jar`, `spring-core.jar`, `spring...

    国产化中间件产品对接,jms的接口参考

    标题中的“国产化中间件产品对接,jms的接口参考”指的是在信息技术领域,特别是中国国内,使用本土化的中间件产品进行系统间的通信,而这里的通信机制是基于Java消息服务(Java Message Service,简称JMS)。JMS是...

    用Java编写客户机_服务器端应用程序.zip

    本资源"用Java编写客户机_服务器端应用程序.zip"包含了一份关于如何使用Java进行此类开发的详细指南,主要文件为"用Java编写客户机_服务器端应用程序.pdf"。 一、Java客户机-服务器架构基础 客户机-服务器(Client-...

    PDS-17001_JMS583_Datasheet_(Rev._1.0)_JMS583_jmicron_jms583开发_

    datasheet通常包含电气特性、引脚定义、操作条件、接口协议、硬件布局指南和软件编程接口等关键信息。 总结来说,JMS583芯片是现代高速存储解决方案的重要组成部分,它利用先进的USB 3.1 Gen 2和PCIe Gen3x2技术,...

    JMS--J2EE培训材料

    4. **管理对象**:这些是预定义的JMS对象,客户使用它们进行消息的发送和接收。 #### 四、JMS的高级接口 JMS定义了一系列高级接口来封装各种消息的概念。这些接口根据PTP和Pub/Sub两个消息域进行了进一步的定义和...

    javax.jms包,sun的JMS接口规范包,版本1.1

    javax.jms包,sun的JMS接口规范包 2018年6月4日17:05:30

    java.jms.jar JMS需要的JAR包

    Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用集成的API,它定义了一种标准的接口,使得应用程序可以与各种消息中间件进行交互,实现异步的消息传递。JMS允许应用程序创建、发送、接收...

    JMS578固件资源支持UASP支持光驱ODD功能

    这对于那些仍然需要使用光盘进行数据交换或安装软件的用户来说至关重要。固件升级可以改善光驱的兼容性、稳定性和读写速度,确保用户能够顺畅地使用各类光盘。 **固件版本** 在提供的资源中,有两个固件版本可供...

Global site tag (gtag.js) - Google Analytics