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配置文件内容：
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: /
#必须配置这个，生产者才会确认回调
publisher-confirm-type: correlated
publisher-returns: true
#重要，手动开启消费者ACK，控制消息在MQ中的删除、重发
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(){
//消息发送完成后，则回调此方法，ack代表此方法是否发送成功
rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback(){
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
//ack为true,代表MQ已经准确收到消息
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(“本地消息表状态修改失败”);
}
}catch (Exception e){
log.warn(“本息消息表状态修改异常”,e);
}
}
});
}
/**
* 创建订单信息
* @param order 订单信息
* @throws Exception
*/
public void createOrder(JSONObject order) throws Exception {
//保存订单信息
saveOrder(order);
//发送MQ消息，直接发送时不可靠，可能会失败（发送后根据回执修改状态表，定时任务扫表读取失败数据重新发送）
sendMsg(order);
}
/**
* 发送订单信息至MQ
* @param order 订单信息
*/
private void sendMsg(JSONObject order) {
//发送消息到MQ，CorrelationData作用：当收到消息回执时会带上这个参数
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(“订单创建失败”);
}
//保存消息发送状态
saveLocalMsg(order);
}
/**
* 记录消息发送状态
* @param order 订单信息
* @throws Exception
*/
private void saveLocalMsg(JSONObject order) throws Exception {
String sql = “insert into tb_msgstatus (msgid,msg,status,sendtime) values (? , ? , 0 , now())”;
//记录消息发送状态
int count = jdbcTemplate.update(sql,order.get(“orderid”),order.toJSONString());
if(count != 1){
throw new Exception(“记录消息发送状态失败”);
}
}
}
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 测试验证结果
orderQueue消息队列中已经接收到数据
订单表里的数据
状态表数据：
4、运单中心
4.1 运单中心分析
消费者收到消息进行处理，处理成功则发送ACK消息通知MQ清除该条记录，否则通知MQ重发或者等待MQ自动重发。本地维护一个处理次数，如果多次处理仍然失败，则将该消息丢弃或者加入到死信队列（DLQ）中。死信队列中的数据可以人工干预。推荐Java精选公众号，回复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 运单系统
* @Date 2020/1/30 21:58
* @Version 1.0
*/
@Slf4j
@Service
public class DispatchService {
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数Java工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！
如果你觉得这些内容对你有帮助，可以扫码获取！！（备注Java获取）
最后
一次偶然，从朋友那里得到一份“java高分面试指南”，里面涵盖了25个分类的面试题以及详细的解析：JavaOOP、Java集合/泛型、Java中的IO与NIO、Java反射、Java序列化、Java注解、多线程&并发、JVM、Mysql、Redis、Memcached、MongoDB、Spring、Spring Boot、Spring Cloud、RabbitMQ、Dubbo 、MyBatis 、ZooKeeper 、数据结构、算法、Elasticsearch 、Kafka 、微服务、Linux。
这不，马上就要到招聘季了，很多朋友又开始准备“金三银四”的春招啦，那我想这份“java高分面试指南”应该起到不小的作用，所以今天想给大家分享一下。
请注意：关于这份“java高分面试指南”，每一个方向专题（25个）的题目这里几乎都会列举，在不看答案的情况下，大家可以自行测试一下水平 且由于篇幅原因，这边无法展示所有完整的答案解析
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
va反射、Java序列化、Java注解、多线程&并发、JVM、Mysql、Redis、Memcached、MongoDB、Spring、Spring Boot、Spring Cloud、RabbitMQ、Dubbo 、MyBatis 、ZooKeeper 、数据结构、算法、Elasticsearch 、Kafka 、微服务、Linux。
这不，马上就要到招聘季了，很多朋友又开始准备“金三银四”的春招啦，那我想这份“java高分面试指南”应该起到不小的作用，所以今天想给大家分享一下。
[外链图片转存中…(img-yNUCgxDi-1712701157677)]文章来源：https://www.toymoban.com/news/detail-850924.html
请注意：关于这份“java高分面试指南”，每一个方向专题（25个）的题目这里几乎都会列举，在不看答案的情况下，大家可以自行测试一下水平 且由于篇幅原因，这边无法展示所有完整的答案解析
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！文章来源地址https://www.toymoban.com/news/detail-850924.html
到了这里，关于【103期】RabbitMQ 实现多系统间的分布式事务，保证数据一致性的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
