servicecomb 、servicecomb rpc_生活资讯_资讯

servicecomb 、servicecomb rpc

2023-04-14 01:02 浏览:48

ServiceComb常见配置项解析

1、同步开发模式下，根据业务接口调整默认工作线程，默认为CPU个数

thread-per-group: 200

2、同步开发模式下，根据业务需要，动态调整thread-count，默认为1，一般建议配置成cpu*2

thread-count: 8

3、根据接口时延，调整Http连接池大小，但是不建议连接数配置过大。按经验不要超过50，***是进行压力测试得出一个比较合理的值。

maxPoolSize: 10

4、同步开发转成全异步开发模式，参考CSE开发文档Reactive

5、调整虚拟机启动参数

6、如果使用Https连接，建议使用openssl作为SSLEngine

ssl:

engine: openssl

分布式事务解决方案ServiceComb - Omega源码阅读与分享

ServiceComb已经是Apache的顶级项目，包含两个组件，即 alpha 和 omega。

源码地址：

alpha 是事务协调中心，保存事务日志，通过日志协调各个分支

demo 里面项目的各框架的例子：spring和du***o saga tcc

docs 设计文档，***应该熟悉的。

omega 负责与alpha通讯，子事务逻辑

pack-contracts gRPC通讯接口定义文件,通过中间文件生成客户端与服务端面代码，让开发者不必关心通讯过程

web 用angular写的web界面，可以查看事务的状态。

我们主要关注的alpha和omega的代码，gRPC知识是通讯基础非常重要，***先了解gRPC和probuf、Kyro序列化对阅读源码

还是很有帮助的。但通讯部分只是简单带过。

GlobalTxId全局事务ID标记子事务是否同属性一个事务中

ParentTxId 父类的事务ID

localTxId子事务Id

Omega会面向切面编程的方式，向程序中注入相应的逻辑，初始化事务上下文OmegaContext,在事务处理的过程中向alpha报告事务状态，

实现saga协调协议和TCC协调协议,下面就是omega客户端要配置了三个信息

omega.enable=true或@EnableOmega的作用只标记开启Omega，Omega在SpringBoot上初始化过程：

OmegaSpringAutoConfiguration 通过@Configuration，在Spring框架启动时加载并配置

OmegaSpringConfig

作用：初始化各Bean,IdGenerator用来生成子事务Id Saga的事件Sender Tcc事件Sender回调CallbackContext

TransactionAspectConfig

对@SagaStart @Compensable注解AOP的切面编程对象初始

Omega内部机制：SagaStartAspect @SagaStart的AOP切面编程

TransactionAspect对@Compensable注解AOP切面编程

成功场景下，每个事务都会有开始和对应的结束事件。

TransactionAspect=Def***ltRecovery=CompensableInterceptor

封装了通讯组件：du***o fegin resttemplate servicecomb实现的通讯

这些组件各自通讯的基础上，在服务之间相互调用时，把globalTxId和localTxId传递过去，并注入Context中

如：omega-transport-omega-transport-resttemplate

RestTemplateConfig 配置拦截器TransactionClientHttpRequestInterceptor

TransactionClientHttpRequestInterceptor：把当前的上下文的globalTxId和localTxId放到请求里

TransactionHandlerInterceptor 服务提供者，把resttemplate传递过来的globalTxId和localTxId放到当前上下文里，

pack-contracts-pack-contract-grpc

gRPC的接口服务定义文件：GrpcCommon.proto GrpcTccEvent.protogrpcTxEvent.proto：这些文件在protobuf命令直接编译成java代码。

如何使用请看：proto文件gRpc基础

谢谢能看到最后的人：我分享我是怎么阅读源码的。源码阅读不能一上来就找到main入口一行一行的看。***应该了解基本的组成架构、和用到了哪些技术栈，如果还用了你从来没见的技术，建议先去学习这门新的技术，再回头来看代码，熟悉了各模块相对应的功能后。我会找到一个切入口，猜一下它的实现方式，再根据猜测，带着疑问，去找答案。如果对整个项目的模块不是很清楚，***先把源码里的Demo正常的运行。通过这样的简单学习，一步步的深入。有的代码的抽象是比较复杂的。可先跳过，当你对整个结构都非常了解了，这时再回头去读剩下的难点。最后有个总结有个对比就是***结果。

华为ServiceComb

解决方案：：

检查实现类下是否有方法

添加

问题

2018-05-09 12:33:48.209 [http-nio-8888-exec-10] ERROR org.apache.catalina.core.Containerbase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.Error: Can not find value, name=Schema meta id mgr for microservice livehouse, key=helloCombService] with root c***se

java.lang.Error: Can not find value, name=Schema meta id mgr for microservice livehouse, key=helloCombService

at org.apache.servicecomb.foundation.common.RegisterManager.ensureFindValue(RegisterManager.java:76)

at org.apache.servicecomb.core.definition.Microservicemeta.ensureFindSchemameta(Microservicemeta.java:81)

at org.apache.servicecomb.provider.pojo.Invoker.prepare(Invoker.java:79)

at org.apache.servicecomb.provider.pojo.Invoker.invoke(Invoker.java:91)

at com.sun.proxy.$Proxy107.s***Hello(Unknown Source)

at com.huawei.bosom.friend.web.controller.mi.MIController.hello(MIController.java:49)

at com.huawei.bosom.friend.web.controller.mi.MIController$$FastClassBySpringCGLIB$$589aafe.invoke(generated)

at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)

at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)

at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)

at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)

at com.huawei.bosom.friend.aop.RequestAopLog.getResponseLog(RequestAopLog.java:133)

at com.huawei.bosom.friend.aop.RequestAopLog.doAround(RequestAopLog.java:41)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:629)

at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:618)

at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70)

at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)

at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)

at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)

at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)

at com.huawei.bosom.friend.web.controller.mi.MIController$$EnhancerBySpringCGLIB$$ebf69285.hello(generated)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:220)

at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:134)

at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:116)

at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)

at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)

at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)

at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:963)

at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:897)

at org.springframework.web.servlet.frameworkServlet.processRequest(frameworkServlet.java:970)

at org.springframework.web.servlet.frameworkServlet.doGet(frameworkServlet.java:861)

at javax.servlet.http.HttpServlet.service(HttpServlet.java:622)

at org.springframework.web.servlet.frameworkServlet.service(frameworkServlet.java:846)

at javax.servlet.http.HttpServlet.service(HttpServlet.java:729)

at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:230)