eclipse+JBoss5+EJB3开发指南（14）：消息驱动Bean

作者：花长好月常圆人长久 | 来源：互联网 | 2023-10-10 06:58

本文为原创，如需转载，请注明作者和出处，谢谢！在前面的文章中给出的SessionBean的例子都是同步调用SessionBe

本文为原创&＃xff0c;如需转载&＃xff0c;请注明作者和出处&＃xff0c;谢谢&＃xff01;

在前面的文章中给出的SessionBean的例子都是同步调用SessionBean方法的&＃xff0c;也就是说&＃xff0c;只有当方法中的代码都执行完&＃xff0c;才能返回到客户端。但在某些情况下&＃xff0c;由于SessionBean方法的执行时间比较长&＃xff0c;这就需要异步地调用该方法&＃xff0c;否则客户端就需要等待比较长的时间。要实现异步调用&＃xff0c; 就需要使用本要讲的消息驱动Bean。消息驱动Bean的基本原理是客户端向消息服务器发送一条消息后&＃xff0c;消息服务器会将该消息保存在消息队列中。在这时消息服务器中的某个消费者&＃xff08;读取并处理消息的对象&＃xff09;会读取该消息&＃xff0c;并进行处理。发送消息的客户端被称为消息生产者。
本文给出的消息驱动Bean的例子的基本功能是客户端向消息服务器发送一条消息&＃xff08;该消息实际上是一个实体Bean的对象实例&＃xff09;&＃xff0c;然后消息消费者读取这条消息后&＃xff0c;将消息中的实体Bean持久化。实现消息驱动Bean的步骤如下&＃xff1a;

一、实现实体Bean

Code:

package entity;
import java.io.Serializable;
import java.util.Date;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;
&＃64;Entity
&＃64;Table(name&＃61;"t_date")
public class DateBean implements Serializable
{
private int id;
private Date myDate;
&＃64;Id
&＃64;GeneratedValue(strategy&＃61;GenerationType.IDENTITY)
public int getId()
{
return id;
}
public void setId(int id)
{
this.id &＃61; id;
}
&＃64;Column(name&＃61;"mydate")
public Date getMyDate()
{
return myDate;
}
public void setMyDate(Date myDate)
{
this.myDate &＃61; myDate;
}
}

二、编写消息驱动Bean

消息驱动Bean必须实现MessageListener接口&＃xff0c;当该消息驱动Bean接收到一个消息后&＃xff0c;EJB容器就会调用MessageListener接口的onMessage方法来理该消息。消息驱动Bean的代码如下&＃xff1a;

Code:

package service;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.EJBException;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import entity.DateBean;
&＃64;MessageDriven( activationConfig &＃61; {
&＃64;ActivationConfigProperty(propertyName &＃61; "destinationType", propertyValue &＃61; "javax.jms.Queue"),
&＃64;ActivationConfigProperty(propertyName &＃61; "destination", propertyValue &＃61; "queue/MDBQueue")
})
public class DateMessageBean implements MessageListener
{
&＃64;PersistenceContext(unitName &＃61; "myentity1")
private EntityManager em;
&＃64;Override
public void onMessage(Message message)
{
try
{
if(message instanceof ObjectMessage)
{
ObjectMessage objmsg &＃61; (ObjectMessage) message;
DateBean dateBean &＃61; (DateBean) objmsg.getObject();
em.persist(dateBean);
System.out.println("成功持久化DateBean对象!");
}
else
{
System.out.println("消息类型错误&＃xff01;");
}
}
catch (Exception e)
{
throw new EJBException(e);
}
}
}

消息驱动Bean需要使用

&＃64;MessageDriven进行注释。要注意的是destination属性的值是queue/MDBQueue。 JBoss不会自已建立一个Queue对象&＃xff0c;因此&＃xff0c;需要手工来配置Queue对象。读者可以/server/ default/deploy目录中建立一个xxx-service.xml文件&＃xff0c;其中xxx可以任意取值&＃xff0c;但必须跟“-service”后缀&＃xff0c;例如&＃xff0c; abc-service.xml。该文件可以放在deploy或其子目录&＃xff08;可以是多层子目录&＃xff09;中。该文件的内容如下&＃xff1a;

Code:

xml version&＃61;"1.0" encoding&＃61;"UTF-8"?>
<server>
<mbean code&＃61;"org.jboss.mq.server.jmx.Queue" name&＃61;"jboss.mq.destination:service&＃61;Queue,name&＃61;MDBQueue">
<depends optional-attribute-name&＃61;"DestinationManager">jboss.mq:service&＃61;DestinationManagerdepends>
mbean>
server>

要注意的是&＃xff0c;元素的name属性值中的name必须是MDBQueue&＃xff0c;要与queue/MDBQueue中的/后面的部分一致。如果不进行上面的配置&＃xff0c;在启动JBOSS时就会抛出如下的异常&＃xff1a;

javax.naming.NameNotFoundException: MDBQueue not bound

也可以将元素放在deploy目录中的其他以-service.xml结尾的文件中。
如果不设置destination属性的值&＃xff0c;在启动JBoss是会抛出如下的异常&＃xff1a;

org.jboss.deployers.spi.DeploymentException: Required config property RequiredConfigPropertyMetaData&＃64;174098f[name&＃61;destination descriptions&＃61;[DescriptionMetaData&＃64;4ca30b[language&＃61;zh]]] for messagingType &＃39;javax.jms.MessageListener&＃39; not found in activation config [ActivationConfigProperty(destinationType&＃61;javax.jms.Queue), ActivationConfigProperty(connectionFactoryJndiName&＃61;MyQueueConnectionFactory), ActivationConfigProperty(destinationName&＃61;MyRequestQueue)] ra&＃61;jboss.jca:service&＃61;RARDeployment,name&＃61;&＃39;jms-ra.rar&＃39;
... ...

三、编写调用消息驱动Bean的SessionBean

Code:

package service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import javax.annotation.Resource;
import javax.ejb.Stateless;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.Session;
import javax.persistence.EntityManager;
import entity.DateBean;
import entity.Greeting;

&＃64;Stateless
public class GreeterBean implements Greeter
{
    &＃64;Resource(mappedName &＃61; "ConnectionFactory")
    private ConnectionFactory cf;
    &＃64;Resource(mappedName &＃61; "queue/MDBQueue")
    private Queue queue;

    &＃64;Override
    public String greet(String message)
    {
        try
        {
            DateBean db &＃61; new DateBean();
            db.setMyDate(new Date());
            Connection connection &＃61; cf.createConnection();
            Session session &＃61; connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageProducer messageProducer &＃61; session.createProducer(queue);
            ObjectMessage objectMessage &＃61; session.createObjectMessage();
            objectMessage.setObject(db);
            messageProducer.send(objectMessage);
            connection.close();
            System.out.println("成功发送消息&＃xff01;");
        }
        catch (Exception e)
        {
            System.out.println("发送消息失败&＃xff01;");
        }

        return "方法成功返回";

    }
}

在上面的代码中使用ObjectMessage对象来包装要向消息服务器发送的实体Bean的对象实例。

除了可以在SessionBean中访问消息驱动Bean外&＃xff0c;还可以在不同的机器上通过jndi来查找并调用消息驱动Bean&＃xff0c;代码如下:&＃xff1a;

Code:

package test;
import java.util.Date;
import javax.ejb.EJB;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import entity.DateBean;
import service.Greeter;
public class Client
{
public static void main(String[] args) throws Exception
{
InitialContext ctx &＃61; new InitialContext();
QueueConnection connection &＃61; null;
QueueSession session &＃61; null;
QueueConnectionFactory factory &＃61; (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
connection &＃61; factory.createQueueConnection();
session &＃61; connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
Destination destination &＃61; (Queue) ctx.lookup("queue/MDBQueue");
MessageProducer messageProducer &＃61; session.createProducer(destination);
ObjectMessage objectMessage &＃61; session.createObjectMessage();
DateBean db &＃61; new DateBean();
db.setMyDate(new Date());
objectMessage.setObject(db);
messageProducer.send(objectMessage);
connection.close();
System.out.println("成功发送消息&＃xff01;");
}
}

推荐阅读

string
通过Go SDK（Amazon S3）从Bucket生成Torrent - Generate Torrent from Bucket via Go SDK (Amazon S3)

Imtryingtofigureoutawaytogeneratetorrentfilesfromabucket,usingtheAWSSDKforGo.我正 ... [详细]

蜡笔小新 2023-12-12 14:13:01
string
C#制作Java+Mysql+Tomcat环境安装程序，一键式安装教程

本文介绍了如何使用C#制作Java+Mysql+Tomcat环境安装程序，实现一键式安装。通过将JDK、Mysql、Tomcat三者制作成一个安装包，解决了客户在安装软件时的复杂配置和繁琐问题，便于管理软件版本和系统集成。具体步骤包括配置JDK环境变量和安装Mysql服务，其中使用了MySQL Server 5.5社区版和my.ini文件。安装方法为通过命令行将目录转到mysql的bin目录下，执行mysqld --install MySQL5命令。 ... [详细]

蜡笔小新 2023-12-12 19:29:55
string
Hibernate延迟加载深入分析-集合属性的延迟加载策略

本文深入分析了Hibernate延迟加载的机制，特别是集合属性的延迟加载策略。通过延迟加载，可以降低系统的内存开销，提高Hibernate的运行性能。对于集合属性，推荐使用延迟加载策略，即在系统需要使用集合属性时才从数据库装载关联的数据，避免一次加载所有集合属性导致性能下降。 ... [详细]

蜡笔小新 2023-12-10 14:26:13
string
在类中定义数组时出错 - Error on defining arrays in class

Iamtryingtomakeaclassthatwillreadatextfileofnamesintoanarray,thenreturnthatarra ... [详细]

蜡笔小新 2023-12-14 17:38:12
uri
Java序列化对象传给PHP的方法及原理解析

本文介绍了Java序列化对象传给PHP的方法及原理，包括Java对象传递的方式、序列化的方式、PHP中的序列化用法介绍、Java是否能反序列化PHP的数据、Java序列化的原理以及解决Java序列化中的问题。同时还解释了序列化的概念和作用，以及代码执行序列化所需要的权限。最后指出，序列化会将对象实例的所有字段都进行序列化，使得数据能够被表示为实例的序列化数据，但只有能够解释该格式的代码才能够确定数据的内容。 ... [详细]

蜡笔小新 2023-12-14 15:25:15
utf-8
开发笔记:加密&json&StringIO模块&BytesIO模块

篇首语：本文由编程笔记#小编为大家整理，主要介绍了加密&json&StringIO模块&BytesIO模块相关的知识，希望对你有一定的参考价值。一、加密加密 ... [详细]

蜡笔小新 2023-12-14 15:18:35
io
实现下拉列表，点击其他位置自动隐藏效果的三种方式比较

目录实现效果：实现环境实现方法一：基本思路主要代码JavaScript代码总结方法二主要代码总结方法三基本思路主要代码JavaScriptHTML总结实 ... [详细]

蜡笔小新 2023-12-14 15:03:14
search
如何使用Java获取服务器硬件信息和磁盘负载率

本文介绍了使用Java编程语言获取服务器硬件信息和磁盘负载率的方法。首先在远程服务器上搭建一个支持服务端语言的HTTP服务，并获取服务器的磁盘信息，并将结果输出。然后在本地使用JS编写一个AJAX脚本，远程请求服务端的程序，得到结果并展示给用户。其中还介绍了如何提取硬盘序列号的方法。 ... [详细]

蜡笔小新 2023-12-14 13:56:20
string
Java容器中的compareto方法排序原理解析

本文从源码解析Java容器中的compareto方法的排序原理，讲解了在使用数组存储数据时的限制以及存储效率的问题。同时提到了Redis的五大数据结构和list、set等知识点，回忆了作者大学时代的Java学习经历。文章以作者做的思维导图作为目录，展示了整个讲解过程。 ... [详细]

蜡笔小新 2023-12-14 13:53:31
io
LeetCode笔记：剑指Offer 41. 数据流中的中位数（Java、堆、优先队列、知识点）

本文介绍了LeetCode剑指Offer 41题的解题思路和代码实现，主要涉及了Java中的优先队列和堆排序的知识点。优先队列是Queue接口的实现，可以对其中的元素进行排序，采用小顶堆的方式进行排序。本文还介绍了Java中queue的offer、poll、add、remove、element、peek等方法的区别和用法。 ... [详细]

蜡笔小新 2023-12-14 13:34:58
import
OC学习笔记之@property和@synthesize

本文介绍了OC学习笔记中的@property和@synthesize，包括属性的定义和合成的使用方法。通过示例代码详细讲解了@property和@synthesize的作用和用法。 ... [详细]

蜡笔小新 2023-12-14 12:05:06
case
的错误消息：

ZSI.generate.Wsdl2PythonError: unsupported local simpleType restriction ... [详细]

蜡笔小新 2023-12-13 20:28:08
string
Android Material Design风格的日期时间选择器TimeSelector

本文介绍了一款名为TimeSelector的Android日期时间选择器，采用了Material Design风格，可以在Android Studio中通过gradle添加依赖来使用，也可以在Eclipse中下载源码使用。文章详细介绍了TimeSelector的构造方法和参数说明，以及如何使用回调函数来处理选取时间后的操作。同时还提供了示例代码和可选的起始时间和结束时间设置。 ... [详细]

蜡笔小新 2023-12-11 13:07:46
string
GreenDAO快速入门

前言之前在自己做项目的时候，用到了GreenDAO数据库，其实对于数据库辅助工具库从OrmLite，到litePal再到GreenDAO，总是在不停的切换，但是没有真正去了解他们的 ... [详细]

蜡笔小新 2023-12-11 12:31:00
io
Servlet多用户登录时HttpSession会话信息覆盖问题的解决方案

本文讨论了在Servlet多用户登录时可能出现的HttpSession会话信息覆盖问题，并提供了解决方案。通过分析JSESSIONID的作用机制和编码方式，我们可以得出每个HttpSession对象都是通过客户端发送的唯一JSESSIONID来识别的，因此无需担心会话信息被覆盖的问题。需要注意的是，本文讨论的是多个客户端级别上的多用户登录，而非同一个浏览器级别上的多用户登录。 ... [详细]

蜡笔小新 2023-12-10 12:00:40

花长好月常圆人长久

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章