面試官：消息隊(duì)列消息可靠性、重復(fù)消息、消息積壓、利用消息實(shí)現(xiàn)分布式事務(wù)

-? ? ?如何確保消息不丟失? ? -?

1、檢測(cè)消息丟失的方法

如果是在一個(gè)分布式系統(tǒng)中實(shí)現(xiàn)這個(gè)檢測(cè)方法，有幾個(gè)問(wèn)題需要注意：

2、確保消息可靠傳遞

2.1、生產(chǎn)階段

try{
    producer.send(record).get();
System.out.println("消息發(fā)送成功");
} catch(Exception e) {
System.out.println("消息發(fā)送失敗");
System.out.println(e);
}

異步發(fā)送時(shí)，則需要在回調(diào)方法里進(jìn)行檢查：

 producer.send(record, newCallback() {
@Override
publicvoid onCompletion(RecordMetadata metadata, Exception exception) {
if(metadata != null) {
System.out.println("消息發(fā)送成功");
} else{
System.out.println("消息發(fā)送失敗");
System.out.println(exception);
}
}
});
producer.send(record, (metadata, exception) -> {
if(metadata != null) {
System.out.println("消息發(fā)送成功");
} else{
System.out.println("消息發(fā)送失敗");
System.out.println(exception);
}
});

2.2、存儲(chǔ)階段

2.3、消費(fèi)階段

-? ? ?小結(jié)? ? -?

-? ? ?如何處理消費(fèi)過(guò)程中的重復(fù)消息? ? -?

1、消息重復(fù)的情況必然存在

2、用冪等性解決重復(fù)消息問(wèn)題

幾種常用的設(shè)計(jì)冪等操作的方法

-? ? ?如何處理消息積壓？? ? -?

優(yōu)化性能來(lái)避免消息積壓

• 發(fā)送端準(zhǔn)備數(shù)據(jù)、序列化消息、構(gòu)造請(qǐng)求等邏輯的時(shí)間，也就是發(fā)送端在網(wǎng)絡(luò)請(qǐng)求之前的耗時(shí)；

• 發(fā)送消息和返回響應(yīng)在網(wǎng)絡(luò)傳輸中的耗時(shí)；

• Broker處理消息的時(shí)延。

消息積壓了該如何處理？

-? ? ?利用事務(wù)消息實(shí)現(xiàn)分布式事務(wù)? ? -?

什么是分布式事務(wù)？

• 原子性：指一個(gè)事務(wù)操作不可分割，要么成功，要么失敗，不能有一半成功一半失敗的情況。
  

  
  

• 一致性：指這些數(shù)據(jù)在事務(wù)執(zhí)行完成這個(gè)時(shí)間點(diǎn)之前，讀到的一定是更新前的數(shù)據(jù)，之后讀到的一定是更新后的數(shù)據(jù)，不應(yīng)該存在一個(gè)時(shí)刻，讓用戶讀到更新過(guò)程中的數(shù)據(jù)。
  

  
  

• 隔離性：指一個(gè)事務(wù)的執(zhí)行不能被其他事務(wù)干擾。即一個(gè)事務(wù)內(nèi)部的操作及使用的數(shù)據(jù)對(duì)正在進(jìn)行的其他事務(wù)是隔離的，并發(fā)執(zhí)行的各個(gè)事務(wù)之間不能互相干擾。
  

  
  

• 持久性：指一個(gè)事務(wù)一旦完成提交，后續(xù)的其他操作和故障都不會(huì)對(duì)事務(wù)的結(jié)果產(chǎn)生任何影響 事務(wù)消息適用的場(chǎng)景主要是那些需要異步更新數(shù)據(jù)，并且對(duì)數(shù)據(jù)實(shí)時(shí)性要求不太高的場(chǎng)景。比如訂單系統(tǒng)的例子，在創(chuàng)建訂單后，如果出現(xiàn)短暫的幾秒，購(gòu)物車?yán)锏纳唐窙](méi)有及時(shí)情況，也不是完全不可接受的，只要最終購(gòu)物車的數(shù)據(jù)和訂單數(shù)據(jù)保持一致就可以了。

2、消息隊(duì)列是如何實(shí)現(xiàn)分布式事務(wù)的？

3、RocketMQ中的分布式事務(wù)實(shí)現(xiàn)

作者：邋遢的流浪劍客

來(lái)源：

https://blog.csdn.net/qq_40378034/article/details/98790433

程序汪資料鏈接
程序汪接的7個(gè)私活都在這里，經(jīng)驗(yàn)整理
Java項(xiàng)目分享 最新整理全集，找項(xiàng)目不累啦 06版
堪稱神級(jí)的Spring Boot手冊(cè)，從基礎(chǔ)入門(mén)到實(shí)戰(zhàn)進(jìn)階
臥槽！字節(jié)跳動(dòng)《算法中文手冊(cè)》火了，完整版 PDF 開(kāi)放下載！
臥槽！阿里大佬總結(jié)的《圖解Java》火了，完整版PDF開(kāi)放下載！
字節(jié)跳動(dòng)總結(jié)的設(shè)計(jì)模式 PDF 火了，完整版開(kāi)放下載！

歡迎添加程序汪個(gè)人微信 itwang005? 進(jìn)粉絲群或圍觀朋友圈