servicecomb-pack

前言：

servicecomb-pack 包括2大部分即 alpha、omega ，其中alpha相当于管理端服务端，而omega是需要嵌入到业务代码中，是一个client端，接收、上报给alpha事务ID以及执行状态。而事务协议又包括2种即saga与tcc，我们在omega-transport这个项目模块，包括支持的项目框架：dubbo、feign、hystrix、resttemplate、servicecomb，在官方文档里或者代码demo里没有关于springcoud feign的相关实例，可能感觉和debbo类似，官方就省略了，这篇文章我们来给一个例子。

需要引入的jar包

compile group: 'org.apache.servicecomb.pack', name: 'omega-spring-starter', version: '0.7.0-SNAPSHOT'
        compile group: 'org.apache.servicecomb.pack', name: 'omega-transport-feign', version: '0.7.0-SNAPSHOT'
        compile group: 'org.apache.servicecomb.pack', name: 'omega-transport-resttemplate', version: '0.7.0-SNAPSHOT'
    //选择你公司监控平台jar包，支持consul、eureka、nacos、zookeeper
        compile group: 'org.apache.servicecomb.pack', name: 'omega-spring-cloud-nacos-starter', version: '0.7.0-SNAPSHOT'

假如有3个不同的feign ，使用官方的例子，预定-》预定车票-》预定宾馆，在预定服务中开启整体的事务，预定车票及预定宾馆有各自的事务，如果3个服务，其中有一个不成功，则整体事务回滚，执行其取消方法。

BookingFeign.java

@FeignClient(value = "booking-feign", contextId = "booking-feign", configuration = {FeignConfiguration.class})
    public interface BookingFeign {
        /**
         * @description: 预定服务
         * @param name 入参
         * @param rooms 几间房
         * @param cars 几辆车
         */
     @PostMapping(value = "/booking/order")
     String order(@RequestParam("name")String name, @RequestParam("rooms")Integer rooms, @RequestParam("cars")Integer cars);
    }

对应BookingController.java 开启全局分布式事务

@RestController
    @Api(tags = "BookingController")
    public class BookingController implements BookingFeign {
        @Autowired
        private BookingCarFeign bookingCarFeign;
        @Autowired
        private BookingHotelFeign bookingHotelFeign;

        /**
         * @description: 预定服务
         * @param name 名字
         * @param rooms 几间房
         * @param cars 几辆车
         */
        @SagaStart(timeout = 10)
        @Transaction(rollBack = Exception.class)
        @Override
        public String order(String name, Integer rooms, Integer cars) throws Throwable
     {

          //省略处理自己预定服务业务逻辑
          //预定车票
          bookingCarFeign(name,cars);
          //预定宾馆
          bookingHotelFeign(name,rooms)
    }

BookingCarFeign.java、BookingCarController.java 订车服务

@FeignClient(value = "booking-car-feign", contextId = "booking-car-feign", configuration = {FeignConfiguration.class})
    public interface BookingCarFeign {
        /**
         * @description: 预定车服务
         * @param name 名字
         * @param cars 几辆车
         */
     @PostMapping(value = "/booking/car/order")
     String order(@RequestParam("name")String name, @RequestParam("cars")Integer cars);
    }

@RestController
    @Api(tags = "BookingCarController")
    public class BookingCarController implements BookingCarFeign {

        /**
         * @description: 预定车服务
         * @param name 名字
         * @param cars 几辆车
         */
        @Compensable(compensationMethod = "cancelOrder")
        @Transaction(rollBack = Exception.class)
        @Override
        public String order(String name,Integer cars) throws Throwable {
          //省略处理自己预定服务业务逻辑
     }

         /**
          * 事务失败后回滚方法
          */
        private String cancelOrder(String name,Integer cars) throws Throwable{
          //回滚业务逻辑
      }
    }

HotelBookingFeign.java、HotelBookingController.java 订宾馆服务

@FeignClient(value = "booking-hotel-feign", contextId = "booking-hotel-feign", configuration = {FeignConfiguration.class})
    public interface BookingHotelFeign {
        /**
         * @description: 预定宾馆服务
         * @param name 名字
         * @param cars 几间房
         */
     @PostMapping(value = "/booking/hotel/order")
     String order(@RequestParam("name")String name, @RequestParam("cars")Integer rooms);
    }

@RestController
    @Api(tags = "BookingHotelController")
    public class BookingHotelController implements BookingHotelFeign {

        /**
         * @description: 预定宾馆服务
         * @param name 名字
         * @param cars 几间房
         */
        @Compensable(compensationMethod = "cancelOrder")
        @Transaction(rollBack = Exception.class)
        @Override
        public String order(String name,Integer rooms) throws Throwable {
          //省略处理自己预定服务业务逻辑
     }

         /**
          * 事务失败后回滚方法
          */
        private String cancelOrder(String name,Integer rooms) throws Throwable{
          //回滚业务逻辑
      }
    }

注意：

1、cancelOrder方法的入参必须与order相同

2、而且与order在同一个类中

3、order开启自己的本地事务

4、方法内发生异常即使吃掉，也要抛出

5、子事务中无需开启事务分布式事务，他会根据框架不同，将父事务传递下来

5、再执行过程中，分布式事务执行失败，提示在omerga中找不到取消方法，那么你要核对下constance ID 中的IP是不是你服务器IP，很有可能会不是，重启alpha服务一般可以解决

6、还有一些其他bug，大家可以查看官方AFQ

大家可以发现，其他写法与dubbo给的示例查询不多，引用包有点区别，有问题欢迎大家在下面留言。

servicecomb-pack相关推荐

Apache ServiceComb Pack 微服务分布式数据最终一致性解决方案
Apache ServiceComb Pack 微服务分布式数据最终一致性解决方案参考文章: (1)Apache ServiceComb Pack 微服务分布式数据最终一致性解决方案 (2)http ...
Apache ServiceComb 社区12月动态精选
点击蓝字关注这个神奇的公众号- Apache ServiceComb | 精选 Apache ServiceComb 致力于帮助企业.用户和开发者将企业应用轻松微服务化上云,并实现对微服务应用的高效运 ...
Apache ServiceComb 社区4月动态精选
你好,四月我说你是人间的四月天: 笑响点亮了四面风: 轻灵在春的光艳中交舞着变你是四月早天里的云烟: 黄昏吹着风的软,星子在无意中闪: 细雨点洒在花前 ...... 你是一树一树的花开, 是燕在 ...
微服务架构深度解析与最佳实践 - 第五部分：七个应对策略之性能、一致性与高可用
七个关键问题的应对策略-续 3.关于微服务对性能的影响大家可以先思考 2 个问题:延迟(latency)和吞吐量(throughout)有什么关系? 延迟是响应时间么? 先说一下延迟和响应时间,延迟 ...
微服务架构深度解析与最佳实践
微服务架构深度解析与最佳实践微服务架构的概念,现在对于大家应该都不陌生,无论使用 Apache Dubbo.还是 Spring Cloud,都可以去尝试微服务,把复杂而庞大的业务系统拆分成一些更小粒 ...
dbaplus-爱可生社区-北京站沙龙归来
这是学习笔记的第 2143 篇文章今天全程参与组织了dbaplus社群+爱可生开源社区的北京站沙龙活动. 总体感觉很顺利,从听众的部分反馈来说,还是有不少收获的. 整个下午场的议题如下: 在前一天下 ...
【daisy-framework】分布式事务技术选型
前言 Github:https://github.com/yihonglei/daisy-framework 一概述随着系统交易量增加,业务规模的发展,团队规模扩大,为了提高系统高可用,高并发,高 ...
AI TALK | 云原生时代的微服务架构与关键技术
随着云原生与微服务技术的逐步发展,业界也逐步构建出一整套比较完整的微服务技术体系. 面向云原生时代,微服务架构是从业人员绕不开的一个话题,腾讯云AI&腾讯优图的内容风控安全审核能力也与微服务技 ...
Apache ServiceComb 开源两周年，聊聊其与微服务的前世今生
欢迎添加华为云小助手微信(微信号:HWCloud002 或 HWCloud003),输入关键字"加群",加入华为云线上技术讨论群:输入关键字"最新活动",获取华 ...

servicecomb-pack

servicecomb-pack相关推荐

最新文章

热门文章