diff --git a/01-placeorder/pom.xml b/01-placeorder/pom.xml
index a8e301c..9a6cada 100644
--- a/01-placeorder/pom.xml
+++ b/01-placeorder/pom.xml
@@ -30,6 +30,20 @@
org.springframework.boot
spring-boot-starter-amqp
+
+ org.projectlombok
+ lombok
+
+
+ mysql
+ mysql-connector-java
+ 5.1.47
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ 2.2.2
+
\ No newline at end of file
diff --git a/01-placeorder/src/main/java/com/mashibing/PlaceOrderStarterApp.java b/01-placeorder/src/main/java/com/mashibing/PlaceOrderStarterApp.java
index e319faf..d480f1d 100644
--- a/01-placeorder/src/main/java/com/mashibing/PlaceOrderStarterApp.java
+++ b/01-placeorder/src/main/java/com/mashibing/PlaceOrderStarterApp.java
@@ -1,5 +1,6 @@
package com.mashibing;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@@ -12,6 +13,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
+@MapperScan(basePackages = "com.mashibing.mapper")
public class PlaceOrderStarterApp {
public static void main(String[] args) {
diff --git a/01-placeorder/src/main/java/com/mashibing/config/RabbitTemplateConfig.java b/01-placeorder/src/main/java/com/mashibing/config/RabbitTemplateConfig.java
new file mode 100644
index 0000000..3a3a211
--- /dev/null
+++ b/01-placeorder/src/main/java/com/mashibing/config/RabbitTemplateConfig.java
@@ -0,0 +1,76 @@
+package com.mashibing.config;
+
+import com.mashibing.mapper.ResendMapper;
+import com.mashibing.util.GlobalCache;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.connection.CorrelationData;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.annotation.Resource;
+import java.util.Map;
+
+/**
+ * @author zjw
+ * @description
+ */
+@Configuration
+@Slf4j
+public class RabbitTemplateConfig {
+
+ @Resource
+ private ResendMapper resendMapper;
+
+ @Bean
+ public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
+ //1、new出RabbitTemplate对象
+ RabbitTemplate rabbitTemplate = new RabbitTemplate();
+ //2、将connectionFactory设置到RabbitTemplate对象中
+ rabbitTemplate.setConnectionFactory(connectionFactory);
+ //3、设置confirm回调
+ rabbitTemplate.setConfirmCallback(confirmCallback());
+ //4、设置return回调
+ rabbitTemplate.setReturnCallback(returnCallback());
+ //5、设置mandatory为true
+ rabbitTemplate.setMandatory(true);
+ //6、返回RabbitTemplate对象即可
+ return rabbitTemplate;
+ }
+
+ public RabbitTemplate.ConfirmCallback confirmCallback(){
+ return new RabbitTemplate.ConfirmCallback(){
+ @Override
+ public void confirm(CorrelationData correlationData, boolean ack, String cause) {
+ if (correlationData == null) return;
+ String msgId = correlationData.getId();
+ if(ack){
+ log.info("消息发送到Exchange成功!!");
+ GlobalCache.remove(msgId);
+ }else{
+ log.error("消息发送失败！");
+ Map value = (Map) GlobalCache.get(msgId);
+ // 推荐自己玩的时候，用service做增删改操作，控制事务~
+ resendMapper.save(value);
+ }
+ }
+ };
+ }
+
+ public RabbitTemplate.ReturnCallback returnCallback(){
+ return new RabbitTemplate.ReturnCallback(){
+ @Override
+ public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
+ // 做到这，你可以基于confirm中的操作，实现将当前消息也保存到数据库。
+ log.error("消息未路由到队列");
+ log.error("return：消息为：" + new String(message.getBody()));
+ log.error("return：交换机为：" + exchange);
+ log.error("return：路由为：" + routingKey);
+ }
+ };
+ }
+
+}
diff --git a/01-placeorder/src/main/java/com/mashibing/controller/PlaceOrderController.java b/01-placeorder/src/main/java/com/mashibing/controller/PlaceOrderController.java
index dd3d786..0b6728c 100644
--- a/01-placeorder/src/main/java/com/mashibing/controller/PlaceOrderController.java
+++ b/01-placeorder/src/main/java/com/mashibing/controller/PlaceOrderController.java
@@ -2,11 +2,19 @@ package com.mashibing.controller;
import com.mashibing.client.*;
import com.mashibing.config.RabbitMQConfig;
+import com.mashibing.util.GlobalCache;
+import org.springframework.amqp.core.Correlation;
+import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+
/**
* @author zjw
* @description
@@ -19,16 +27,6 @@ public class PlaceOrderController {
@Autowired
private OrderManageClient orderManageClient;
- /*
- @Autowired
- private CouponClient couponClient;
- @Autowired
- private UserPointsClient userPointsClient;
- @Autowired
- private BusinessClient businessClient;
-
-*/
-
@Autowired
private RabbitTemplate rabbitTemplate;
/**
@@ -44,17 +42,21 @@ public class PlaceOrderController {
orderManageClient.create();
// 将之前的同步方式注释
- /*
- //3、调用优惠券服务，预扣除使用的优惠券
- couponClient.coupon();
- //4、调用用户积分服务，预扣除用户使用的积分
- userPointsClient.up();
- //5、调用商家服务，通知商家用户已下单
- businessClient.notifyBusiness();
-*/
String userAndOrderInfo = "用户信息&订单信息&优惠券信息等等…………";
+ // 声明当前消息的id标识
+ String id = UUID.randomUUID().toString();
+ // 封装消息的全部信息
+ Map map = new HashMap<>();
+ map.put("id",id);
+ map.put("message",userAndOrderInfo);
+ map.put("exchange",RabbitMQConfig.PLACE_ORDER_EXCHANGE);
+ map.put("routingKey","");
+ map.put("sendTime",new Date());
+ // 将id标识和消息存储到全局缓存中
+ GlobalCache.set(id,map);
// 将同步方式修改为基于RabbitMQ的异步方式
- rabbitTemplate.convertAndSend(RabbitMQConfig.PLACE_ORDER_EXCHANGE,"",userAndOrderInfo);
+ rabbitTemplate.convertAndSend(RabbitMQConfig.PLACE_ORDER_EXCHANGE,"",userAndOrderInfo,new CorrelationData(id));
+
long end = System.currentTimeMillis();
System.out.println(end - start);
diff --git a/01-placeorder/src/main/java/com/mashibing/mapper/ResendMapper.java b/01-placeorder/src/main/java/com/mashibing/mapper/ResendMapper.java
new file mode 100644
index 0000000..dc7d411
--- /dev/null
+++ b/01-placeorder/src/main/java/com/mashibing/mapper/ResendMapper.java
@@ -0,0 +1,16 @@
+package com.mashibing.mapper;
+
+import org.apache.ibatis.annotations.Insert;
+
+import java.util.Map;
+
+/**
+ * @author zjw
+ * @description
+ */
+public interface ResendMapper {
+
+ @Insert("insert into resend (id,message,exchange,routing_key,send_time) values (#{id},#{message},#{exchange},#{routingKey},#{sendTime})")
+ void save(Map map);
+
+}
diff --git a/01-placeorder/src/main/java/com/mashibing/util/GlobalCache.java b/01-placeorder/src/main/java/com/mashibing/util/GlobalCache.java
new file mode 100644
index 0000000..0330fe0
--- /dev/null
+++ b/01-placeorder/src/main/java/com/mashibing/util/GlobalCache.java
@@ -0,0 +1,27 @@
+package com.mashibing.util;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author zjw
+ * @description
+ */
+public class GlobalCache {
+
+ private static Map map = new HashMap();
+
+ public static void set(String key,Object value){
+ map.put(key,value);
+ }
+
+ public static Object get(String key){
+ Object value = map.get(key);
+ return value;
+ }
+
+ public static void remove(String key){
+ map.remove(key);
+ }
+
+}
diff --git a/01-placeorder/src/main/resources/application.yml b/01-placeorder/src/main/resources/application.yml
index 5ffa4c0..5d5b49c 100644
--- a/01-placeorder/src/main/resources/application.yml
+++ b/01-placeorder/src/main/resources/application.yml
@@ -13,4 +13,11 @@ spring:
port: 5672
username: rabbitmq
password: rabbitmq
- virtual-host: rabbitmq
\ No newline at end of file
+ virtual-host: rabbitmq
+ publisher-confirm-type: correlated
+ publisher-returns: true
+ datasource:
+ driver-class-name: org.gjt.mm.mysql.Driver
+ url: jdbc:mysql:///rabbitmq
+ username: root
+ password: root
\ No newline at end of file