org.springframework.boot
spring-boot-starter-amqp
mysql
mysql-connector-java
runtime
org.projectlombok
lombok
true
org.springframework.boot
spring-boot-starter-jdbc
com.alibaba
fastjson
1.2.17
3.2.1.2配置文件內(nèi)容：
server:
port:?8080
spring:
datasource:
driver-class-name:?com.mysql.cj.jdbc.Driver
url:?jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8&allowMultiQueries=true
username:?root
password:?root123
rabbitmq:
host:?localhost
port:?5672
username:?admin
password:?admin123
virtual-host:?/
#必須配置這個，生產(chǎn)者才會確認回調(diào)
publisher-confirm-type:?correlated
publisher-returns:?true
#重要，手動開啟消費者ACK，控制消息在MQ中的刪除、重發(fā)
listener:
simple:
acknowledge-mode:?MANUAL
3.2.2 訂單中心代碼
import?com.alibaba.fastjson.JSONObject;
import?lombok.extern.slf4j.Slf4j;
import?org.springframework.amqp.rabbit.connection.CorrelationData;
import?org.springframework.amqp.rabbit.core.RabbitTemplate;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.jdbc.core.JdbcTemplate;
import?org.springframework.stereotype.Service;
import?javax.annotation.PostConstruct;
import?java.beans.Transient;
/**
*?@Author?Lee
*?@Description?訂單中心
*?@Date?2020/1/30?16:57
*?@Version?1.0
*/
@Slf4j
@Service
public?class?OrderService?{
@Autowired
private?JdbcTemplate?jdbcTemplate;
@Autowired
private?RabbitTemplate?rabbitTemplate;
@PostConstruct
public?void?setup(){
//消息發(fā)送完成后，則回調(diào)此方法，ack代表此方法是否發(fā)送成功
rabbitTemplate.setConfirmCallback(new?RabbitTemplate.ConfirmCallback(){
@Override
public?void?confirm(CorrelationData?correlationData,?boolean?ack,?String?cause)?{
//ack為true,代表MQ已經(jīng)準確收到消息
if(!ack){
return;
}
try{
String?sql?=?“update?tb_msgstatus?set?status?=?1?where?msgid?=??”;
int?count?=?jdbcTemplate.update(sql,correlationData.getId());
if(count?!=?1){
log.warn(“本地消息表狀態(tài)修改失敗”);
}
}catch?(Exception?e){
log.warn(“本息消息表狀態(tài)修改異?！?e);
}
}
});
}
/**
*?創(chuàng)建訂單信息
*?@param?order?訂單信息
*?@throws?Exception
*/
public?void?createOrder(JSONObject?order)?throws?Exception?{
//保存訂單信息
saveOrder(order);
//發(fā)送MQ消息，直接發(fā)送時不可靠，可能會失?。òl(fā)送后根據(jù)回執(zhí)修改狀態(tài)表，定時任務(wù)掃表讀取失敗數(shù)據(jù)重新發(fā)送）
sendMsg(order);
}
/**
*?發(fā)送訂單信息至MQ
*?@param?order?訂單信息
*/
private?void?sendMsg(JSONObject?order)?{
//發(fā)送消息到MQ，CorrelationData作用：當收到消息回執(zhí)時會帶上這個參數(shù)
rabbitTemplate.convertAndSend(“orderExchange”,“”,order.toJSONString(),new?CorrelationData((String)?order.get(“orderid”)));
}
/**
*?保存訂單信息
*?@param?order?訂單信息
*?@throws?Exception
*/
@Transient
private?void?saveOrder(JSONObject?order)?throws?Exception?{
String?sql?=?“insert?into?tb_order?(orderid,userid,goodsid,ordertime)?values?(??,???,???,?now())”;
//保存訂單信息
int?count?=?jdbcTemplate.update(sql,order.get(“orderid”),order.get(“userid”),order.get(“goodsid”));
if(count?!=?1){
throw?new?Exception(“訂單創(chuàng)建失敗”);
}
//保存消息發(fā)送狀態(tài)
saveLocalMsg(order);
}
/**
*?記錄消息發(fā)送狀態(tài)
*?@param?order?訂單信息
*?@throws?Exception
*/
private?void?saveLocalMsg(JSONObject?order)?throws?Exception?{
String?sql?=?“insert?into?tb_msgstatus?(msgid,msg,status,sendtime)?values?(??,???,?0?,?now())”;
//記錄消息發(fā)送狀態(tài)
int?count?=?jdbcTemplate.update(sql,order.get(“orderid”),order.toJSONString());
if(count?!=?1){
throw?new?Exception(“記錄消息發(fā)送狀態(tài)失敗”);
}
}
}
3.3 訂單中心測試
3.3.1 測試代碼
@Autowired
private?OrderService?orderService;
@Test
public?void?orderServiceTest()?throws?Exception?{
//生成訂單信息
JSONObject?orderinfo?=?new?JSONObject();
orderinfo.put(“orderid”,UUID.randomUUID().toString());
orderinfo.put(“userid”,UUID.randomUUID().toString());
orderinfo.put(“goodsid”,UUID.randomUUID().toString());
orderService.createOrder(orderinfo);
}
3.3.2 測試驗證結(jié)果
orderQueue消息隊列中已經(jīng)接收到數(shù)據(jù)
訂單表里的數(shù)據(jù)
狀態(tài)表數(shù)據(jù)：
4、運單中心
4.1 運單中心分析
消費者收到消息進行處理，處理成功則發(fā)送ACK消息通知MQ清除該條記錄，否則通知MQ重發(fā)或者等待MQ自動重發(fā)。本地維護一個處理次數(shù)，如果多次處理仍然失敗，則將該消息丟棄或者加入到死信隊列（DLQ）中。死信隊列中的數(shù)據(jù)可以人工干預(yù)。推薦Java精選公眾號，回復(fù)Java面試，獲取面試資料。
4.2 編寫代碼
import?com.alibaba.fastjson.JSONObject;
import?com.rabbitmq.client.Channel;
import?lombok.extern.slf4j.Slf4j;
import?org.springframework.amqp.rabbit.annotation.RabbitListener;
import?org.springframework.amqp.support.AmqpHeaders;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.jdbc.core.JdbcTemplate;
import?org.springframework.messaging.handler.annotation.Header;
import?org.springframework.stereotype.Service;
import?java.beans.Transient;
import?java.io.IOException;
/**
*?@Author?Lee
*?@Description?運單系統(tǒng)
*?@Date?2020/1/30?21:58
*?@Version?1.0
*/
@Slf4j
@Service
public?class?DispatchService?{
自我介紹一下，小編13年上海交大畢業(yè)，曾經(jīng)在小公司待過，也去過華為、OPPO等大廠，18年進入阿里一直到現(xiàn)在。
深知大多數(shù)Java工程師，想要提升技能，往往是自己摸索成長或者是報班學(xué)習(xí)，但對于培訓(xùn)機構(gòu)動則幾千的學(xué)費，著實壓力不小。自己不成體系的自學(xué)效果低效又漫長，而且極易碰到天花板技術(shù)停滯不前！
因此收集整理了一份《2024年Java開發(fā)全套學(xué)習(xí)資料》，初衷也很簡單，就是希望能夠幫助到想自學(xué)提升又不知道該從何學(xué)起的朋友，同時減輕大家的負擔。
既有適合小白學(xué)習(xí)的零基礎(chǔ)資料，也有適合3年以上經(jīng)驗的小伙伴深入學(xué)習(xí)提升的進階課程，基本涵蓋了95%以上Java開發(fā)知識點，真正體系化！
由于文件比較大，這里只是將部分目錄截圖出來，每個節(jié)點里面都包含大廠面經(jīng)、學(xué)習(xí)筆記、源碼講義、實戰(zhàn)項目、講解視頻，并且會持續(xù)更新！
如果你覺得這些內(nèi)容對你有幫助，可以掃碼獲?。。。▊渥ava獲取）
最后
一次偶然，從朋友那里得到一份“java高分面試指南”，里面涵蓋了25個分類的面試題以及詳細的解析：JavaOOP、Java集合/泛型、Java中的IO與NIO、Java反射、Java序列化、Java注解、多線程&并發(fā)、JVM、Mysql、Redis、Memcached、MongoDB、Spring、Spring Boot、Spring Cloud、RabbitMQ、Dubbo 、MyBatis 、ZooKeeper 、數(shù)據(jù)結(jié)構(gòu)、算法、Elasticsearch 、Kafka 、微服務(wù)、Linux。
這不，馬上就要到招聘季了，很多朋友又開始準備“金三銀四”的春招啦，那我想這份“java高分面試指南”應(yīng)該起到不小的作用，所以今天想給大家分享一下。
請注意：關(guān)于這份“java高分面試指南”，每一個方向?qū)ｎ}（25個）的題目這里幾乎都會列舉，在不看答案的情況下，大家可以自行測試一下水平 且由于篇幅原因，這邊無法展示所有完整的答案解析
《互聯(lián)網(wǎng)大廠面試真題解析、進階開發(fā)核心學(xué)習(xí)筆記、全套講解視頻、實戰(zhàn)項目源碼講義》點擊傳送門即可獲取！
va反射、Java序列化、Java注解、多線程&并發(fā)、JVM、Mysql、Redis、Memcached、MongoDB、Spring、Spring Boot、Spring Cloud、RabbitMQ、Dubbo 、MyBatis 、ZooKeeper 、數(shù)據(jù)結(jié)構(gòu)、算法、Elasticsearch 、Kafka 、微服務(wù)、Linux。
這不，馬上就要到招聘季了，很多朋友又開始準備“金三銀四”的春招啦，那我想這份“java高分面試指南”應(yīng)該起到不小的作用，所以今天想給大家分享一下。
[外鏈圖片轉(zhuǎn)存中…(img-yNUCgxDi-1712701157677)]文章來源：http://www.zghlxwxcb.cn/news/detail-850924.html
請注意：關(guān)于這份“java高分面試指南”，每一個方向?qū)ｎ}（25個）的題目這里幾乎都會列舉，在不看答案的情況下，大家可以自行測試一下水平 且由于篇幅原因，這邊無法展示所有完整的答案解析
《互聯(lián)網(wǎng)大廠面試真題解析、進階開發(fā)核心學(xué)習(xí)筆記、全套講解視頻、實戰(zhàn)項目源碼講義》點擊傳送門即可獲?。?/strong>文章來源地址http://www.zghlxwxcb.cn/news/detail-850924.html
到了這里，關(guān)于【103期】RabbitMQ 實現(xiàn)多系統(tǒng)間的分布式事務(wù)，保證數(shù)據(jù)一致性的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
