From 861dcc14e5c467630fbe493335d0b25674bd7897 Mon Sep 17 00:00:00 2001 From: YunaiV Date: Wed, 8 May 2019 23:34:16 +0800 Subject: [PATCH] =?UTF-8?q?-=20=E5=90=8E=E7=AB=AF=EF=BC=9AOrder=20?= =?UTF-8?q?=E6=A8=A1=E5=9D=97=EF=BC=8C=E5=BC=95=E7=94=A8=20Dubbo=20?= =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E7=9A=84=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/users/UsersCartController.java | 4 ++-- .../mall/order/biz/service/CartServiceImpl.java | 8 ++++---- .../src/main/resources/config/application.yaml | 10 ++++++++++ .../mall/pay/biz/component/DubboReferencePool.java | 1 + 4 files changed, 17 insertions(+), 6 deletions(-) diff --git a/order/order-application/src/main/java/cn/iocoder/mall/order/application/controller/users/UsersCartController.java b/order/order-application/src/main/java/cn/iocoder/mall/order/application/controller/users/UsersCartController.java index 059923790..08e92fd18 100644 --- a/order/order-application/src/main/java/cn/iocoder/mall/order/application/controller/users/UsersCartController.java +++ b/order/order-application/src/main/java/cn/iocoder/mall/order/application/controller/users/UsersCartController.java @@ -29,11 +29,11 @@ import static cn.iocoder.common.framework.vo.CommonResult.success; @RequestMapping("users/cart") public class UsersCartController { - @Reference(validation = "true") + @Reference(validation = "true", version = "${dubbo.provider.CartService.version}") private CartService cartService; @Reference(validation = "true") private OrderService orderService; - @Reference(validation = "true") + @Reference(validation = "true", version = "${dubbo.consumer.CouponService.version}") private CouponService couponService; @PostMapping("add") diff --git a/order/order-service-impl/src/main/java/cn/iocoder/mall/order/biz/service/CartServiceImpl.java b/order/order-service-impl/src/main/java/cn/iocoder/mall/order/biz/service/CartServiceImpl.java index 7f354f7bf..bc4056b8d 100644 --- a/order/order-service-impl/src/main/java/cn/iocoder/mall/order/biz/service/CartServiceImpl.java +++ b/order/order-service-impl/src/main/java/cn/iocoder/mall/order/biz/service/CartServiceImpl.java @@ -32,14 +32,14 @@ import java.util.stream.Collectors; * 购物车服务 Service 实现类 */ @Service -@org.apache.dubbo.config.annotation.Service(validation = "true") +@org.apache.dubbo.config.annotation.Service(validation = "true", version = "${dubbo.provider.CartService.version}") public class CartServiceImpl implements CartService { - @Reference(validation = "true") + @Reference(validation = "true", version = "${dubbo.consumer.PromotionActivityService.version}") private ProductSpuService productSpuService; - @Reference(validation = "true") + @Reference(validation = "true", version = "${dubbo.consumer.PromotionActivityService.version}") private PromotionActivityService promotionActivityService; - @Reference(validation = "true") + @Reference(validation = "true", version = "${dubbo.consumer.CouponService.version}") private CouponService couponService; @Autowired diff --git a/order/order-service-impl/src/main/resources/config/application.yaml b/order/order-service-impl/src/main/resources/config/application.yaml index b0648b4e2..31ccaee44 100644 --- a/order/order-service-impl/src/main/resources/config/application.yaml +++ b/order/order-service-impl/src/main/resources/config/application.yaml @@ -23,6 +23,16 @@ dubbo: name: dubbo scan: base-packages: cn.iocoder.mall.order.biz.service + provider: + CartService: + version: 1.0.0 + consumer: + ProductSpuService: + version: 1.0.0 + PromotionActivityService: + version: 1.0.0 + CouponService: + version: 1.0.0 # logging logging: diff --git a/pay/pay-service-impl/src/main/java/cn/iocoder/mall/pay/biz/component/DubboReferencePool.java b/pay/pay-service-impl/src/main/java/cn/iocoder/mall/pay/biz/component/DubboReferencePool.java index 11f3785d7..17cde45f8 100644 --- a/pay/pay-service-impl/src/main/java/cn/iocoder/mall/pay/biz/component/DubboReferencePool.java +++ b/pay/pay-service-impl/src/main/java/cn/iocoder/mall/pay/biz/component/DubboReferencePool.java @@ -58,6 +58,7 @@ public class DubboReferencePool { reference.setInterface(notifyUrlParts[0]); // 弱类型接口名 reference.setGeneric(true); // 声明为泛化接口 reference.setApplication(application); + reference.setVersion("1.0.0"); // TODO 芋艿,后面要优化下。 // 获得 GenericService 对象 GenericService genericService = reference.get(); // 构建最终的 ReferenceMeta 对象