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;");
}
}

推荐阅读

include
深入解析Android 4.4中的Fence机制及其应用

在Android 4.4中，Fence机制是处理缓冲区交换和同步问题的关键技术。该机制广泛应用于生产者-消费者模式中，确保了不同组件之间高效、安全的数据传输。通过深入解析Fence机制的工作原理和应用场景，本文探讨了其在系统性能优化和资源管理中的重要作用。 ... [详细]

蜡笔小新 2024-11-09 19:30:27
get
Java项目中两个文件互相调用时出现函数错误，请求专业解决方案

在Java项目中，当两个文件进行互相调用时出现了函数错误。具体问题出现在 `MainFrame.java` 文件中，该文件位于 `cn.javass.bookmgr` 包下，并且导入了 `java.awt.BorderLayout` 和 `java.awt.Event` 等相关类。为了确保项目的正常运行，请求提供专业的解决方案，以解决函数调用中的错误。建议从类路径、依赖关系和方法签名等方面入手，进行全面排查和调试。 ... [详细]

蜡笔小新 2024-11-08 17:04:11
include
CentOS 7 中配置开机自动挂载 NFS 的解决方案

本文详细介绍了在 CentOS 7 系统中配置 fstab 文件以实现开机自动挂载 NFS 共享目录的方法，并解决了常见的配置失败问题。 ... [详细]

蜡笔小新 2024-11-13 12:05:24
get
Java 编程错误：对象无法转换为 long 类型

本文介绍了在 Java 编程中遇到的一个常见错误：对象无法转换为 long 类型，并提供了详细的解决方案。 ... [详细]

蜡笔小新 2024-11-13 10:57:24
include
com.sun.javadoc.PackageDoc.exceptions()方法的使用及代码示例

com.sun.javadoc.PackageDoc.exceptions()方法的使用及代码示例 ... [详细]

蜡笔小新 2024-11-13 10:47:33
get
Spring详解（六）AOP

原文网址：https:www.cnblogs.comysoceanp7476379.html目录1、AOP什么？2、需求3、解决办法1:使用静态代理4 ... [详细]

蜡笔小新 2024-11-12 14:40:40
get
Java高并发与多线程（二）：线程的实现方式详解

本文将深入探讨Java中线程的三种主要实现方式，包括继承Thread类、实现Runnable接口和实现Callable接口，并分析它们之间的异同及其应用场景。 ... [详细]

蜡笔小新 2024-11-12 14:31:23
get
实验九：使用SharedPreferences存储简单数据

本实验旨在帮助学生理解和掌握使用SharedPreferences存储和读取简单数据的方法，包括程序参数和用户选项。 ... [详细]

蜡笔小新 2024-11-12 14:21:47
get
开发中遇到的一些常见问题及解决方案

本文总结了一些开发中常见的问题及其解决方案，包括特性过滤器的使用、NuGet程序集版本冲突、线程存储、溢出检查、ThreadPool的最大线程数设置、Redis使用中的问题以及Task.Result和Task.GetAwaiter().GetResult()的区别。 ... [详细]

蜡笔小新 2024-11-12 08:20:05
list
深入解析 Synchronized 锁的升级机制及其在并发编程中的应用

深入解析 Synchronized 锁的升级机制及其在并发编程中的应用 ... [详细]

蜡笔小新 2024-11-11 13:09:38
get
基于Net Core 3.0与Web API的前后端分离开发：Vue.js在前端的应用

本文介绍了如何使用Net Core 3.0和Web API进行前后端分离开发，并重点探讨了Vue.js在前端的应用。后端采用MySQL数据库和EF Core框架进行数据操作，开发环境为Windows 10和Visual Studio 2019，MySQL服务器版本为8.0.16。文章详细描述了API项目的创建过程、启动步骤以及必要的插件安装，为开发者提供了一套完整的开发指南。 ... [详细]

蜡笔小新 2024-11-11 10:58:21
get
如何利用Java 5 Executor框架高效构建和管理线程池

Java 5 引入了 Executor 框架，为开发人员提供了一种高效管理和构建线程池的方法。该框架通过将任务提交与任务执行分离，简化了多线程编程的复杂性。利用 Executor 框架，开发人员可以更灵活地控制线程的创建、分配和管理，从而提高服务器端应用的性能和响应能力。此外，该框架还提供了多种线程池实现，如固定线程池、缓存线程池和单线程池，以适应不同的应用场景和需求。 ... [详细]

蜡笔小新 2024-11-07 17:05:32
get
如何在Java中使用DButils类

这期内容当中小编将会给大家带来有关如何在Java中使用DButils类，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。D ... [详细]

蜡笔小新 2024-11-12 13:46:11
list
如何在Linux服务器上配置MySQL和Tomcat的开机自动启动

在Linux服务器上部署Web项目时，通常需要确保MySQL和Tomcat服务能够随系统启动而自动运行。本文将详细介绍如何在Linux环境中配置MySQL和Tomcat的开机自启动，以确保服务的稳定性和可靠性。通过合理的配置，可以有效避免因服务未启动而导致的项目故障。 ... [详细]

蜡笔小新 2024-11-11 19:41:03
get
大类|电阻器_使用Requests、Etree、BeautifulSoup、Pandas和Path库进行数据抓取与处理 | 将指定区域内容保存为HTML和Excel格式

大类|电阻器_使用Requests、Etree、BeautifulSoup、Pandas和Path库进行数据抓取与处理 | 将指定区域内容保存为HTML和Excel格式 ... [详细]

蜡笔小新 2024-11-11 19:05:59

花长好月常圆人长久

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

Tags | 热门标签

RankList | 热门文章