skyformat99/springcloudserviceproxy

SpringCloudServiceProxy-SpringCloud代理服务调用框架，基于spring cloud，对比使用Feign 做到服务层无侵入，高性能（依赖FST序列化+OkHttp3处理服务调用请求），服务调用无侵入-高性能。目前已部署在生产环境中至少10余个平台

#SpringCloudServiceProxy SpringCloudServiceProxy-一个实现动态代理服务调用层工具，基于spring cloud，

市面各框架对比：

-SpringCloud，SpringCloud全家桶提供了诸多功能，Feign侵入严重，@ResponseBody注解无法解决多个复杂JSON对象的传递。
-Dubbo框架，采用dubbo协议，dubbo协议采用单一长连接和NIO异步通讯，适合于小数据量大并发的服务调用，不适合传送大数据量的服务，比如传文件，传视频等，除非请求量很低。
-底层使用Json序列化,可兼容跨语言环境调用Java,Go,Kotlin....(只需定义其他语言的ServiceDTO对象) ===此框架优势===

基于更成熟更全面的Spring Cloud全家桶 微服务解决方案

忠于原厂的改装，提升便捷和性能的同时 享受Spring Cloud全家桶带来的各种便利 config zuul Sleuth Bus等等...

单体迁移到分布式系统 免重构 代码0无侵入

使用动态代理提供每个Service对象的伪实例，内方法实现则使用Ribbon负载均衡的 Spring WebFlux WebClient 反应式请求网络

相比Dubbo完美支持服务-服务-消费者-之间的 大文件传输

而且服务的参数和返回值 支持 几乎所有复杂对象包括文件byte[]（依赖 Google Gson 快速高效序列化传输），调用远程服务像调用本地服务一样方便

##实际性能测试： Apache ab压力测试工具实测：10000并发，10000个请求数，调用复杂JavaBean完美（不代表最终性能，此处只是案例，具体看客户电脑配置性能） 提供相比Feign性能更好的服务调用

ab.exe -n 10000 -c 10000 http://localhost:18080/

框架实现原理

（依赖 Google Gson 快速高效序列化传输，调用远程服务像调用本地服务一样方便，减少网络带宽消耗
每个微服务入口接口使用SpringBoot2.0 WebFlux异步处理 基于事件和异步 调用,提高性能,减少资源占用

如何引入项目？

Maven项目依赖，首先加入pom

<repositories>
   <repository>
	 <id>jitpack.io</id>
	 <url>https://jitpack.io</url>
   </repository>
</repositories>

<dependencies>
<dependency>
   <groupId>com.github.zhuxiujia</groupId>
   <artifactId>SpringCloudServiceProxy</artifactId>
   <version>*</version><!-- *替换为版本号 -->
</dependency>
</dependencies>

消费者端（或者说Controller端）加入配置文件

@Configuration
public class ProviderConfig {

        @Autowired
        private LoadBalancerClient loadBalancerClient; //注入发现客户端
    
    
        @Bean
        public DemoService demoService() {
            DemoService demoService = RemoteServiceProxyFactory.newInstance(loadBalancerClient, RemoteMicroServiceName.SERVICE_EVEYY_THING, DemoService.class);
            return demoService;
        }
}

微服务端（或者说Service端）加入Controller控制器(单个微服务项目中，只需存在一个控制器即可访问单个微服务项目中的所有Service)

@RestController
public class ServiceInvokeCoreController {

 private static Logger logger = LoggerFactory.getLogger(ServiceInvokeCoreController.class);

    private static LocalServiceAccessUtil.Logger controllerLogger = new LocalServiceAccessUtil.Logger() {
        @Override
        public void info(String info) {
            logger.info(info);
        }

        @Override
        public void error(String error) {
            logger.error(error);
        }

        @Override
        public void error(String info, Exception e) {
            logger.error(info, e);
        }
    };

    @Resource
    private ApplicationContext applicationContext;

        /**
         * 使用Mono的类似观察者模式的机制处理异步任务
         * @param inputStream
         * @return
         * @throws Throwable
         */
        @ResponseBody
        @RequestMapping("/" + RemoteMicroServiceName.SERVICE_EVEYY_THING)
        Mono invoke(InputStream inputStream) throws Throwable {
            return LocalServiceAccessUtil.asyncMonoAccess(applicationContext,inputStream,controllerLogger);
        }
    
}

demo 运行步骤

step1: 运行 DemoDiscoveryApplication，DemoConsumersApplication，DemoServiceApplication
step2: 浏览器访问 http://localhost:18080/page 即可 展示 传递复杂对象 的案例。