- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我需要每天处理大量用户的列表,以便根据某些场景向他们发送电子邮件和短信通知。我为此使用 Java EE 批处理模型。我的工作xml如下:
<step id="sendNotification">
<chunk item-count="10" retry-limit="3">
<reader ref="myItemReader"></reader>
<processor ref="myItemProcessor"></processor>
<writer ref="myItemWriter"></writer>
<retryable-exception-classes>
<include class="java.lang.IllegalArgumentException"/>
</retryable-exception-classes>
</chunk>
</step>
MyItemReader 的 onOpen 方法从数据库读取所有用户,而 readItem() 使用列表迭代器一次读取一个用户。在 myItemProcessor 中,实际的电子邮件通知被发送给用户,然后用户将保留在该 block 的 myItemWriter 类的数据库中。
@Named
public class MyItemReader extends AbstractItemReader {
private Iterator<User> iterator = null;
private User lastUser;
@Inject
private MyService service;
@Override
public void open(Serializable checkpoint) throws Exception {
super.open(checkpoint);
List<User> users = service.getUsers();
iterator = users.iterator();
if(checkpoint != null) {
User checkpointUser = (User) checkpoint;
System.out.println("Checkpoint Found: " + checkpointUser.getUserId());
while(iterator.hasNext() && !iterator.next().getUserId().equals(checkpointUser.getUserId())) {
System.out.println("skipping already read users ... ");
}
}
}
@Override
public Object readItem() throws Exception {
User user=null;
if(iterator.hasNext()) {
user = iterator.next();
lastUser = user;
}
return user;
}
@Override
public Serializable checkpointInfo() throws Exception {
return lastUser;
}
}
我的问题是检查点存储了前一个 block 中执行的最后一条记录。如果我有一个包含接下来 10 个用户的 block ,并且第 5 个用户的 myItemProcessor 中抛出异常,则在重试时将执行整个 block ,并且将再次处理所有 10 个用户。我不希望再次向已处理的用户发送通知。
有办法解决这个问题吗?应该如何有效地完成这项工作?
任何帮助将不胜感激。谢谢。
最佳答案
我将基于@ Cheng 的评论。我在这里向他表示感谢,希望我的回答能够为有效组织和呈现选项提供额外的值(value)。
正如@heng所指出的,失败意味着整个事务被回滚,并且检查点不会前进。
那么如何处理您的 block 已向某些用户而不是全部用户发送电子邮件的事实? (你可能会说它回滚了,但有“副作用”。)
因此,我们可以将您的问题重申为:如何从批量 block 步骤发送电子邮件?
好吧,假设您有办法通过事务 API 发送电子邮件(实现 XAResource 等),您可以使用该 API。
假设您不这样做,我会向 JMS 队列进行事务写入,然后使用单独的 MDB 发送电子邮件(正如 @ Cheng 在他的评论之一中建议的那样)。
通过这种方法,您仍然可以通过对数据库进行批量处理和更新来提高效率(无论如何,您一次只发送一封电子邮件),并且您可以从简单的检查点和重新启动中受益,而无需编写复杂的错误处理.
这也可能作为跨批处理作业和批处理之外的模式重复使用。
其他一些我认为不太好的想法,列出来供讨论:
您可以使用 ItemProcessListener 方法构建自己的成功/失败电子邮件列表:afterProcess和 onProcessError .
重新启动后,您可以知道当前 block 中哪些用户已收到电子邮件,由于整个 block 回滚,我们重新定位到当前 block ,即使某些电子邮件已经发送。
这肯定会使您的批处理逻辑变得复杂,并且您还必须以某种方式保留此成功或失败列表。另外,这种方法可能是专门针对该作业的(而不是排队等待 MDB 进行处理)。
但它更简单,因为您有一个批处理作业,而不需要消息传递提供程序和单独的应用程序组件。
如果您选择这种方式,您可能需要结合使用可跳过的异常和“不可回滚”的可重试异常。
如果您使用 item-count="1" 定义 block ,则可以避免复杂的检查点和错误处理代码。不过,您会牺牲效率,因此只有当批处理的其他方面非常引人注目时,这才有意义:例如通过通用接口(interface)调度和管理作业,能够在作业中的失败步骤处重新启动
如果您要走这条路,您可能需要考虑将套接字和超时异常定义为“无回滚”异常(使用),因为回滚没有任何好处,并且您可能需要重试网络超时问题。
既然您特别提到了效率,我猜这不适合您。
这也许可行,但批处理 API 并没有让这一切变得特别容易,而且您仍然可能会遇到 block 完成但一封或多封电子邮件发送失败的情况。
关于java - 如何从 Java EE 批处理作业发送电子邮件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47557094/
我想了解为什么一些 Jakarta EE 规范是空的。 例如 Jakarta Annotations规范由免责声明和快速描述(3 行)组成,但是有 Javadoc . 当 JCP 负责 J2EE 规范
我们将在我们的开发中使用 WebSphere 8.0 应用服务器。 我们的网络应用程序使用 Amazon aws java sdk,而后者又使用 Apache http-client 4.1。 但是
Java EE Web Profile 认证服务器(如 JOnAS)和 Java EE Full Platform 认证服务器(如 JBoss AS)有什么区别? 最佳答案 这是一张很好的图片来解释它
Java EE 5 和 Java EE 6 的主要区别是什么? 最佳答案 Oracle 有一篇由三部分组成的文章详细介绍了这些更改:Introducing the Java EE 6 Platform
自从我将 web.xml 从 Java-EE-5 迁移到 Java-EE-6 后,我的应用程序出现问题。这是我部署应用程序时得到的堆栈跟踪: 24 août 2011 14:10:45 org.apa
我想让我的 Java EE 应用程序可插入。主应用程序将部署在一个ear 中,但它在EJB 中的代码将包含插件的入口点。插件可以部署在它们自己的 jar 文件中。有什么好的框架可以做到这一点吗?我正在
就目前而言,这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持,但这个问题可能会引起辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开,visit the he
我有一个关于 EE 容器如何控制事务的问题。这是为我的问题提供一些上下文的伪代码。这不是我编码的方式,所以请留在问题上,不要将主题演变成其他内容。 考虑以下两个服务和相关 Controller 。这两
如果在应用程序初始化期间发生异常,是否有任何方法可以防止 Java EE 应用程序启动?在从 JSR-77 抛出未处理的异常之后,我基本上是在寻找一种方法来使应用程序进入“j2ee.state.fai
我们正在开发几个独立的应用程序/模块,我们将它们部署到 Glassfish 3.1.1 应用程序服务器上。在某些情况下,这些应用程序需要通过远程接口(interface)调用彼此的方法。打包这些远程接
我对 Java 有所了解,但对 Enterprise Java 完全陌生。我正在尝试使用 NetBeans 6.1 和 GlassFish Application Server。 请指导我一些资源,这
这个问题在这里已经有了答案: Java / Jakarta EE web development, where do I start and what skills do I need? [close
我有现有的Java EE Web应用程序。我还有一个新的Grails 1.3.7应用程序。 要求是将此Grails应用程序嵌入现有Java EE应用程序中,并将其部署在一个war文件中。请让我知道是否
我熟悉 LAMP 堆栈,多年来已经成功部署了一些基于它的网络站点。我使用过从 Apache + modPerl 到 PHP、Ruby 和 Rails 的一切。通过充分利用缓存,我的 Rails 站点可
这个问题已经有答案了: What exactly is Java EE? (6 个回答) 已关闭 8 年前。 我意识到它的字面意思是Java Enterprise Edition。但我要问的是,这到底
我当前在服务器上有一个 Java EE 应用程序。它使用struts2和Hibernate。我需要访问客户端计算机并搜索客户端计算机检测到的所有蓝牙外设的MAC地址。 那么问题是:如何访问客户端计算机
我们在 StatelessSessionBean 中有一个性能不佳的业务方法。为了提高性能,我们希望将此业务方法拆分为多个异步方法调用。 问题是这些异步方法必须在同一个事务中运行(它们必须使用同一个
希望使用 JSTL 和 Apache Torque 以及某种模板引擎来扩展当前的 Java EE 项目,以便我们可以轻松修改 View 。 有什么建议? 最佳答案 我想 Freemarker是领先的
我有一个在 tomcat 上运行的非常大的 Java EE 应用程序。不幸的是,最近我遇到了堆空间和内存泄漏错误。 所以我想知道是否有一个工具可以帮助我监控我的应用程序并给我一个每个对象的可视化展示,
这个问题在这里已经有了答案: What exactly is Java EE? (6 个答案) 关闭 4 年前。 我知道这个问题已经被问了一百万次,我也做了功课,但最后一件事我不完全理解的是,是否有
我是一名优秀的程序员,十分优秀!