58.springrain云原生微服务架构

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

if ((!clazz.isInterface()) || (!clazz.isAnnotationPresent(RpcServiceAnnotation.class))) {// 只处理有@RpcService注解的接口
    continue;
}


// 获取实现类名
String classSimpleName = clazz.getSimpleName();
String classImplSimpleName = classSimpleName.substring(1, classSimpleName.length()) + "Impl";

// 实现类的全路径
String rpcServiceImplPath = null;


RpcServiceAnnotation rpcServiceAnnotation = clazz.getAnnotation(RpcServiceAnnotation.class);
String implpackage = rpcServiceAnnotation.implpackage();

if (StringUtils.isBlank(implpackage)) {//没有指定包路径
    // 根据包名规则,组装接口默认实现的class路径,如果类存在,就认为是本机加载,找不到就启用RPC
    String rpcServiceImplClassName = rpcServiceClassName.replace(".service.", ".service.impl.");
    rpcServiceImplPath = rpcServiceImplClassName.substring(0, rpcServiceImplClassName.lastIndexOf("."))+ "." + classImplSimpleName;
} else {
    rpcServiceImplPath = basepackagepath + "." + implpackage + "." + classImplSimpleName;
}


try {
    Class rpcServiceImplClass = Class.forName(rpcServiceImplPath);
    if (rpcServiceImplClass != null) {
        continue;
    }

} catch (Exception e) {
    logger.error("未找到接口" + clazz.getName() + "的实现类" + rpcServiceImplPath + ",开始RPC调用远程实现");
}
           // 因为有远程调用的service,设置seata为启用状态.
if (org.springrain.frame.util.GlobalStatic.seataGlobalEnable) {
    if (!org.springrain.frame.util.GlobalStatic.seataEnable) {
        org.springrain.frame.util.GlobalStatic.seataEnable = true;
    }
} else {// 如果全局禁用seata,就设置为false
    org.springrain.frame.util.GlobalStatic.seataEnable = false;
}


String rpcHost = rpcServiceAnnotation.rpcHost();
Integer rpcPort = rpcServiceAnnotation.rpcPort();
String beanName = rpcServiceAnnotation.beanName();

if (rpcHost == null || rpcHost.equals("")) {
    rpcHost = GlobalStatic.rpcHost;
}

if (rpcPort == null || rpcPort <= 0) {
    rpcPort = GlobalStatic.rpcPort;
}

if (beanName == null || beanName.equals("")) {
    beanName = clazz.getName();
}
// 开始gRPC请求调用
GrpcCommonRequest grpcRequest = new GrpcCommonRequest();
grpcRequest.setClazz(clazz.getName());
grpcRequest.setBeanName(beanName);
grpcRequest.setTimeout(rpcServiceAnnotation.timeout());
grpcRequest.setVersionCode(rpcServiceAnnotation.versionCode());
grpcRequest.setAutocommit(rpcServiceAnnotation.autocommit());

// 创建接口实现的gRPC代理类
// Object invoker = new Object();
InvocationHandler invocationHandler = new GrpcServiceProxy<>(rpcHost, rpcPort, grpcRequest);
Object proxy = Proxy.newProxyInstance(RpcServiceAnnotation.class.getClassLoader(), new Class[]{clazz},
        invocationHandler);
// 手动注册 springbean
beanFactory.registerSingleton(beanName, proxy);

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

// 因为有远程调用的service,设置seata为启用状态.
if (GlobalStatic.seataGlobalEnable) {
    if (!GlobalStatic.seataEnable) {
       GlobalStatic.seataEnable = true;
    }
} else {// 如果全局禁用seata,就设置为false
    GlobalStatic.seataEnable = false;
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

/**
 * 自定义 dataSource,用户扩展实现
 */
@Bean("dataSource")
public DataSource dataSource() {
  DruidDataSource dataSource = new DruidDataSource();
  dataSource.setUrl(url);
  dataSource.setUsername(username);// 用户名
  dataSource.setPassword(password);// 密码
  // 设置属性
  setDataSourceProperties(dataSource);

  // 如果使用seata
  if (GlobalStatic.seataEnable) {
      // 设置seata的datasource代理
      DataSourceProxy proxy = new DataSourceProxy(dataSource);
      // 初始化注册seata
      RMClient.init(GlobalStatic.seataApplicationId, GlobalStatic.seataTransactionServiceGroup);
      TMClient.init(GlobalStatic.seataApplicationId, GlobalStatic.seataTransactionServiceGroup);
      return proxy;
  }

  return dataSource;
}

1
2
3
4
5
6
7
8

<!-- 单体项目依赖springrain-system-serviceimpl,如果是微服务依赖 springrain-system-service 接口即可 -->
<dependency>
    <groupId>org.springrain</groupId>
    <artifactId>springrain-system-serviceimpl</artifactId>
    <version>6.0.0-SNAPSHOT</version>
</dependency>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

<!-- 作为独立的RPC服务运行时,需要依赖 springrain-grpc-server  -->
<dependency>
    <groupId>org.springrain</groupId>
    <artifactId>springrain-grpc-server</artifactId>
    <version>6.0.0-SNAPSHOT</version>
</dependency>

....

<!-- springboot compile plugin,RCP独立运行时需要使用springboot插件进行打包 -->
<plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
</plugin>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18

@RestController
@RequestMapping(value = "/api/system/menu", method = RequestMethod.POST)
public class MenuController extends BaseController {

  @Resource  //有可能实现在远程,也可能是本地代码
  private IMenuService menuService;

  @RequestMapping(value = "/list", method = RequestMethod.POST)
  public ReturnDatas<Menu> list( Menu menu, Page page)
      throws Exception {

    // 有可能是gRPC调用返回的结果,也可能是本地代码调用
    List<Menu> datas = menuService.findListDataByFinder(null, page, Menu.class, menu);

    return null;
  }
}