- 后端:Order 模块,引用 Dubbo 服务的版本

This commit is contained in:
YunaiV 2019-05-08 23:34:16 +08:00
parent de9f191c30
commit 861dcc14e5
4 changed files with 17 additions and 6 deletions

View File

@ -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")

View File

@ -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

View File

@ -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:

View File

@ -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 对象