上一个–消息传递映射器|索引|下一个–轮询消费者
本周,我们将研究一种称为事务客户端的模式。
事务客户端用于确保系统的状态一致。例如,事务性客户机只有在成功处理消息后才会将消息出列。这意味着,微信返利机器人可靠吗,如果消息的使用者崩溃,自助免费建站,或者在崩溃之前没有提交与消息相关的更改,则消息不会退出队列。因此,当消费者重新上网时,信息可以简单地被消费。
在CPI中,这是信息消费者的默认行为。我将演示如何使用JMS发送者适配器。
与消息端点类别中的其他模式不同,这个模式可以在CPI中演示。我创建了两个集成流。一个集成流只是将消息放入队列中。而另一个集成流消耗消息,但在成功完成消息处理之前休眠60秒。
集成流–排队消息
排队消息
此集成流在部署时立即使用计时器启动事件启动,使用内容修饰符设置消息,使用JMS接收方适配器将消息排队。
创建消息内容修饰符将主体设置为:
JMS接收方适配器的配置如下:
集成流–事务客户端
事务客户端
此集成流充当事务客户端。在消息处理成功之前,即消息到达结束步骤,消息将不会出列。
JMS发送方适配器配置如下:
暂停Groovy脚本只是休眠,然后返回消息原样:
执行
为了演示,我将首先部署排队消息集成流。一旦部署了集成流,就可以在队列中看到消息。
排队消息
现在,我将部署事务客户端。事务客户端消耗消息并休眠60秒
监控显示事务客户端正在处理消息:
正在处理消息
在处理消息的过程中,消息仍然存在于队列中
消息尚未出列
,一旦消息处理成功完成,网络云服务器,消息就退出队列。
已完成消息
空队列
只有在事务客户端通知消息已成功处理后,消息才退出队列。非事务性客户机会将消息从队列中取出,返利app开发,如果消息处理失败,则消息是不可恢复的。
事务性客户机通过确保在提交事务之前消息不会退出队列来确保相关系统的一致性。在CPI中,JMS发送方适配器演示了事务性客户机的行为。
企业集成模式中的事务性客户机模式如何在集成流中配置事务处理消费物价指数构成JMS发送方适配器计时器启动事件内容修改器内容修改器JMS接收器适配器
希望对您有所帮助,Bala
上一个–消息映射器|索引|下一个–轮询消费者
,怎么选购云服务器