soul源码阅读（二） 启动http服务
2021-03-03 05:28
标签：build ica cal ping start save param false localhost 官方文档地址: https://dromara.org/zh-cn/docs/soul/user-http.html http服务就是我们自己的项目。 1.引入 soul-examples/soul-examples-http 到soul.pom中 application.yml中添加自己的soul-adminuri 2.启动服务 SoulTestHttpApplication 3.http服务上带有注解 @SoulSpringMvcClient 的uri将会被注册到 soul-admin中 SpringMvcClientBeanPostProcessor 继承 beanPostProcessor接口,利用bean的后置处理器完成实现对uri的注册和更新。 后台的divide插件可以进行选择器，和规则的添加，进行流量的匹配筛选。 在divide插件中可以看到http服务已经被注册到网关中。 4.启动两个服务进行均衡负载 勾选 Allow parrallel run 修改 applicaion.yml 启动服务 SoulTestHttpApplication 可以看到 8189端口被注册到网关之中。 网关通过appName作为服务的唯一标识 当我们打开编辑选择器的按钮,就能看到我们启动的两个http服务。 我们就可以通过机器的内存/CPU等硬件考量,设置两个服务器的权重。 服务注册这块的核心代码 org.dromara.soul.client.springmvc.init.SpringMvcClientBeanPostProcessor#postProcessAfterInitialization soul源码阅读（二） 启动http服务 标签：build ica cal ping start save param false localhost 原文地址：https://www.cnblogs.com/linkuan/p/14283465.html
server:
port: 8188
address: 0.0.0.0
soul:
http:
adminUrl: http://localhost:9095
port: 8188
contextPath: /http
appName: http
full: false
2021-01-15 17:00:44.180 INFO 2688 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/test/**","pathDesc":"","rpcType":"http","host":"192.168.100.52","port":8188,"ruleName":"/http/test/**","enabled":true,"registerMetaData":false}
2021-01-15 17:00:47.011 INFO 2688 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/save","pathDesc":"Save order","rpcType":"http","host":"192.168.100.52","port":8188,"ruleName":"/http/order/save","enabled":true,"registerMetaData":false}
2021-01-15 17:00:48.455 INFO 2688 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/path/**","pathDesc":"","rpcType":"http","host":"192.168.100.52","port":8188,"ruleName":"/http/order/path/**","enabled":true,"registerMetaData":false}
2021-01-15 17:00:48.930 INFO 2688 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/path/**/name","pathDesc":"","rpcType":"http","host":"192.168.100.52","port":8188,"ruleName":"/http/order/path/**/name","enabled":true,"registerMetaData":false}
2021-01-15 17:00:49.294 INFO 2688 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/findById","pathDesc":"Find by id","rpcType":"http","host":"192.168.100.52","port":8188,"ruleName":"/http/order/findById","enabled":true,"registerMetaData":false}
server:
port: 8189
address: 0.0.0.0
soul:
http:
adminUrl: http://localhost:9095
port: 8189
contextPath: /http
appName: http
full: false
2021-01-15 18:56:12.795 INFO 14432 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/test/**","pathDesc":"","rpcType":"http","host":"192.168.100.52","port":8189,"ruleName":"/http/test/**","enabled":true,"registerMetaData":false}
2021-01-15 18:56:12.889 INFO 14432 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/save","pathDesc":"Save order","rpcType":"http","host":"192.168.100.52","port":8189,"ruleName":"/http/order/save","enabled":true,"registerMetaData":false}
2021-01-15 18:56:13.041 INFO 14432 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/path/**","pathDesc":"","rpcType":"http","host":"192.168.100.52","port":8189,"ruleName":"/http/order/path/**","enabled":true,"registerMetaData":false}
2021-01-15 18:56:13.193 INFO 14432 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/path/**/name","pathDesc":"","rpcType":"http","host":"192.168.100.52","port":8189,"ruleName":"/http/order/path/**/name","enabled":true,"registerMetaData":false}
2021-01-15 18:56:13.605 INFO 14432 --- [pool-1-thread-1] o.d.s.client.common.utils.RegisterUtils : http client register success: {"appName":"http","context":"/http","path":"/http/order/findById","pathDesc":"Find by id","rpcType":"http","host":"192.168.100.52","port":8189,"ruleName":"/http/order/findById","enabled":true,"registerMetaData":false}
2021-01-15 18:56:13.634 INFO 14432 --- [ main] o.s.b.web.embedded.netty.NettyWebServer : Netty started on port(s): 8189
public Object postProcessAfterInitialization(@NonNull final Object bean, @NonNull final String beanName) throws BeansException {
if (soulSpringMvcConfig.isFull()) {
return bean;
}
Controller controller = AnnotationUtils.findAnnotation(bean.getClass(), Controller.class);
RestController restController = AnnotationUtils.findAnnotation(bean.getClass(), RestController.class);
RequestMapping requestMapping = AnnotationUtils.findAnnotation(bean.getClass(), RequestMapping.class);
if (controller != null || restController != null || requestMapping != null) {
SoulSpringMvcClient clazzAnnotation = AnnotationUtils.findAnnotation(bean.getClass(), SoulSpringMvcClient.class);
String prePath = "";
if (Objects.nonNull(clazzAnnotation)) {
if (clazzAnnotation.path().indexOf("*") > 1) {
String finalPrePath = prePath;
executorService.execute(() -> RegisterUtils.doRegister(buildJsonParams(clazzAnnotation, finalPrePath), url,
RpcTypeEnum.HTTP));
return bean;
}
prePath = clazzAnnotation.path();
}
final Method[] methods = ReflectionUtils.getUniqueDeclaredMethods(bean.getClass());
for (Method method : methods) {
SoulSpringMvcClient soulSpringMvcClient = AnnotationUtils.findAnnotation(method, SoulSpringMvcClient.class);
if (Objects.nonNull(soulSpringMvcClient)) {
String finalPrePath = prePath;
executorService.execute(() -> RegisterUtils.doRegister(buildJsonParams(soulSpringMvcClient, finalPrePath), url,
RpcTypeEnum.HTTP));
}
}
}
return bean;
}