Urus niaga yang diedarkan: skim ketekalan akhirnya mesej yang boleh dipercayai

Apakah masalah dengan kaedah ini?

Penyelesaian ini dilaksanakan melalui perisian tengah mesej Pemula transaksi (pengeluar mesej) menghantar mesej kepada perisian tengah mesej, dan peserta urus niaga menerima mesej daripada perisian tengah mesej Disebabkan oleh ketidakpastian komunikasi rangkaian, pengedaran akan berlaku Taip masalah transaksi, seperti yang ditunjukkan di bawah:

1. Transaksi tempatan dan masalah atomicity mesej

Seperti yang ditunjukkan dalam gambar di atas dalam kotak bertitik, terdapat situasi berikut:

2) Urus niaga tempatan berjaya, penghantaran mesej gagal, dan transaksi tempatan ditarik balik.

3) Mesej tempatan berjaya, mesej tamat masa, transaksi tempatan digulung semula dan akhirnya mesej gagal.
4) Mesej tempatan berjaya, mesej tamat tempoh, transaksi tempatan digulung semula dan akhirnya mesej berjaya.

Ringkasnya, terdapat Situasi keempat mengakibatkan transaksi tempatan yang tidak konsisten dengan transaksi peserta mesej.

第四种情况，造成本地事务，与消息参与方的事务不一致。

2. 事务参与方接收消息的可靠性。
   

消息中间件与事务参与方要确保能够成功消费到消息。

3. 消息重复消费
   

注意事务参与方的接口幂等性Kebolehpercayaan mesej yang diterima oleh peserta transaksi.

🎜🎜🎜🎜Mesej middleware dengan Peserta transaksi mesti memastikan bahawa Berjaya menggunakan mesej itu. 🎜
🎜🎜Penggunaan mesej berulang🎜🎜🎜🎜🎜Perhatikan Idepot antara muka masalah. Peserta mesej mungkin telah berjaya menggunakannya. Disebabkan masalah rangkaian, middleware mesej percaya bahawa mesej belum digunakan dan masalah itu berlaku selepas memulakan percubaan semula. 🎜

Solution

1. Local Message Table
   

Kunci ke Jadual Mesej Tempatan ialah terdapat jadual rekod tempatan yang menyimpan log mesej. rekod log untuk memastikan Mesej boleh dihantar. Proses khusus adalah seperti berikut:



Proses dalam gambar di atas:


1) Transaksi tempatan pemula transaksi berjaya dilaksanakan dan log mesej direkodkan dalam jadual mesej tempatan.
2) Mulakan tugas berjadual dan imbas jadual mesej setempat secara kitaran.
3) Apabila tugas yang dijadualkan mengimbas mesej, ia menghantar mesej ke perisian tengah mesej.
4) Perisian tengah mesej menerima mesej dan berjaya mengembalikan mesej untuk menghantar pemberitahuan yang berjaya kepada pemula transaksi.
5) Pemula transaksi memadamkan mesej log selepas menerima mesej dan menghantarnya dengan jayanya.
6) Peserta transaksi melanggan mesej dan menggunakan mesej.
7) Peserta transaksi mengendalikan hal ehwal tempatan.
8) Transaksi tempatan berjaya diproses dan ack yang berjaya dihantar ke middleware mesej.


Perhatian:
Peserta transaksi menjamin mati pucuk antara muka. 事务参与方保证接口幂等性。

2. RocketMq事务消息方案
   

Apache RocketMQ 4.3之后的版本正式支持事务消息，为分布式事务实现提供了便利性支持。在RocketMQ 4.3后实现了完整的事务消息，实际上其实是对本地消息表的一个封装，将本地消息表移动到了MQ内部，解决 Producer 端的消息发送与本地事务执行的原子性

Penyelesaian mesej transaksi RocketMq

🎜🎜🎜Apache RocketMQ Versi selepas 4.3 secara rasmi menyokong Mesej transaksi menyediakan sokongan mudah untuk pelaksanaan transaksi yang diedarkan. Mesej transaksi lengkap dilaksanakan selepas RocketMQ 4.3, yang sebenarnya Enkapsulasi jadual mesej setempat, mengalihkan jadual mesej setempat ke MQ internal, menyelesaikan masalah penghantaran mesej dan pelaksanaan transaksi setempat di sebelah ProducerAtomicityisu. 🎜🎜🎜🎜

Proses pelaksanaan:


1) Pemula transaksi menghantar SeparuhMesej transaksiHalf事务消息
2）RocketMq回复Half发送成功
3）事务发起方执行本地事务
4）事务发起方执行本地事务成功，发送commit到RocketMq，mq投递消息到事务参与方；事务发起方执行本地事务失败，发送rollback到RocketMq，mq删除消息。
5）当RocketMq一定时间内未收到来自事务发起方的确认信息，会对事务发起方进行事务回查。
6）事务发起方查询本地事务状态。
7）事务发起方根据查询到的事务状态发送commint/rollback到RocketMq。
8）当RocketMq发起commit后，收到失败或一定时间未收到成功ack，则会发起重试。

优点：

消息数据独立存储，降低业务系统与消息系统之间的耦合。
吞吐量优于本地消息表方案。

缺点2) Balas RocketMqSeparuh berjaya dihantar

3) Pemula transaksi melaksanakan transaksi tempatan

4) Pemula transaksi melaksanakan transaksi tempatan dengan jayanya dan menghantar komit kepada RocketMq , penghantaran mq Mesej dihantar kepada peserta transaksi; pemula transaksi gagal melaksanakan transaksi setempat dan menghantar rollback ke RocketMq, mq memadamkan mesej.
5) Apabila RocketMq tidak menerima maklumat pengesahan daripada pemula transaksi dalam tempoh masa tertentu, ia akan melaksanakan Semakan transaksi.

6) Pemula transaksi menanyakan status transaksi setempat.

7) Pemula transaksi menghantar commin/rollback ke RocketMq.

8) Apabila RocketMq memulakan komit, jika kegagalan diterima atau ack yang berjaya tidak diterima untuk tempoh masa tertentu, percubaan semula akan dimulakan.