diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java
index c29b724b7..641b582b2 100644
--- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java
+++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java
@@ -167,7 +167,10 @@ public class ProductRpcServiceImpl implements ProductRpcService {
                 consStockFlowMapper.insert(consStockFlow);
             }
         }
-        rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
+        ThreadUtil.execAsync(() -> {
+            rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
+        });
+        log.info("ProductService.--------------------------------------------库存更新成功");
     }
 
     @Override
@@ -221,6 +224,9 @@ public class ProductRpcServiceImpl implements ProductRpcService {
                 consStockFlowMapper.insert(consStockFlow);
             }
         }
-        rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
+        ThreadUtil.execAsync(() -> {
+            rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
+        });
+        log.info("ProductService.--------------------------------------------库存更新成功");
     }
 }