Quarkus集成Dubbo服务Rpc远程通讯框架整合

Quarkus集成Dubbo服务Rpc远程通讯框架整合

目录前言引入dubbo依赖定义接口和实现定义接收dubbo的配置dubbo组件配置 dubbo提供者配置dubbo消费者配置结语

前言

dubbo是一个流行的使用广泛的服务治理型RPC框架，博主所在公司，大量服务都是使用dubbo来暴露和调用的，如果想要使用quarkus替换spring boot来做业务系统，肯定要在quarkus中解决dubbo集成的问题。好在dubbo的设计比较优良，除了提供在spring环境下的自动装备加载，还可以通过手动编程的方式集成dubbo。不过，如果确定使用quarkus作为主要的开发框架的话，最终的目标应该是将服务直接注册到k8s的service中，就不需要dubbo或者grpc这种远程通讯框架了。

引入dubbo依赖

org.apache.dubbo

dubbo

2.7.7

spring-context-support

com.alibaba.spring

spring-context

org.springframework

spring-aop

org.springframework

spring-expression

org.springframework

com.alibaba.nacos

nacos-client

1.1.3

这里引入了dubbo的依赖和nacos注册中心的依赖，注意可以排除spring的那些依赖，在quarkus环境中，sprwYUhOEDing的包一点用都没有，只会增加应用的体积

定义接口和实现

public interface TestService {

String hello(String name);

}

@Singleton

@Startup

class TestServiceImpl implements TestService {

@Override

public String hello(String name) {

System.err.println(Thread.currentThread().getName());

return "hello " + name;

}

}

熟悉dubbo的用户肯定清楚，一般情况下，我们会新增一个项目模块，专门用来定义api接口，这个模块单独打jar包，方便给其他的项目引入，这里为了演示方便，所以我将api接口和具体实现都写在一个文件里了。

定义接收dubbo的配置

@ConfigProperties(prefix = "quarkus.dubbo")

public class DubboProperties {

private String name;

private String registrAddress;

private Protocol protocol;

public static class Protocol {

private Integer port;

private String name = "dubbo";

}

}

这个类用来映射application.properties中的dubbo配置，这里只定义了基本的配置属性，其他都可以使用默认值，更多的配置属性看需求可以在这里新增，上面的代码为了博文的篇幅考虑简化了get和set代码。定义好后，可以在配置文件中新增如下配置：

quarkus.dubbo.name = kl

quarkus.dubbo.registr-address = nacos://nacos-xxx.com:80

quarkus.dubbo.protocol.name = dubbo

quarkus.dubbo.protocol.port = 20330

应用启动时，创建DubboProperties实例，并将配置文件中的相关配置设置到对应的属性中，在需要的地方可以通过构造函数或者@Inject注解自动注入

dubbo组件配置

@Dependent

@Startup

public class DubboConfig {

private final DubboProperties dubboProperties;

public DubboConfig(DubboProperties dubboProperties) {

this.dubboProperties = dubboProperties;

}

@Produces

private ApplicationConfig applicationConfig(){

ApplicationConfig config = new ApplicationConfig();

config.setName(dubboProperties.getName());

return config;

}

@Produces

private RegistryConfig registryConfig(){

RegistryConfig config = new RegistryConfig();

config.setAddress(dubboProperties.getRegistrAddress());

return config;

}

@Produces

private ProtocolConfig protocolConfig(){

ProtocolConfig protocol = new ProtocolConfig();

protocol.setName(dubboProperties.getProtocol().getName());

protocol.setPort(dubboProperties.getProtocol().getPort());

return protocol;

}

}

这里通过构造函数注入的方式，引用了前面定义的dubbo配置实例，通过配置，可以实例化出ApplicationConfig、RegistryConfig、ProtocolConfig等实例，这里创建实例时，只设置了最基本的dubbo属性，更多的属性配置扩展可以在这个地方修改。这里的三个实例是保留dubbo服务和引入dubbo服务不可或缺的三个重要组件，具体的用法继续往下看

dubbo提供者配置

@Dependent

@Startup

public class DubboProviderConfig {

@Inject

ApplicationConfig applicationConfig;

@Inject

RegistryConfig registryConfig;

@Inject

ProtocolConfig protocolConfig;

@Inject

TestService testService;

@PostConstruct

public void init() {

Map beans = new HashMap<>(6);

beans.put(TestService.class, testService);

beans.forEach(this::registerDubboService);

}

private void registerDubboService(Class clz, Object obj) {

ServiceConfig

service.setApplication(applicationConfig);

service.setRegistry(registryConfig);

service.setProtocol(protocolConfig);

service.setInterface(clz);

service.setRef(obj);

service.setVersion("1.0.0");

service.export();

}

}

可以看到，上面定义的三个dubbo配置组件，都出现在了dubbo提供者配置里，这三个组件是组成dubbo serviceConfig的一部分。因为没有spring自动扫描dubbo注解获取bean实例，所以在quarkus中，需要手动声明和注册dubbo服务，这里通过@PostConstruct应用启动后的构造函数来触发dubbo的服务注册暴露动作，然后把所有的需要暴露成dubbo服务的接口都统一放入map容器里，然后迭代map完成dubbo服务暴露。

dubbo消费者配置

@Dependent

@Startup

public class DubboConsumerConfig {

@Inject

ApplicationConfig applicationConfig;

@Inject

RegistryConfig registryConfig;

@Produces

public DingSMSService testService1() {

return this.referenceService(DingSMSService.class);

}

private T referenceService(Class clazz) {

ReferenceConfig

reference.setApplication(applicationConfig);

reference.setRegistry(registryConfig);

reference.setInterface(clazz);

reference.setVersion("1.0.0");

return (T)reference.get();

}

}

dubbo里的消费者，就是引入远程服务。首先需要在自己的项目中添加服务提供方的api依赖，然后通过ReferenceConfig配置，可以得到接口的代理实现，这里，也需要用到应用配置和注册中心的配置组件。最后通过@Produces注解，将api实例注册到本地quarkus的bean上下文中，完成后就可以通过@Inject注解注入直接使用dubbo服务了，如：

@Path("/dingservice")

@Produces(MediaType.APPLICATION_jsON)

@Consumes(MediaType.APPLICATION_JSON)

public class TestResource {

@Inject

DingSMSService smsService;

@GET

public String send(@QueryParam("msg")String msg){

smsService.sendDing("1330741xxxx",msg,"kl");

return "发送成功";

}

}

结语

完成了quarkus和dubbo的集成后，博主看到了quarkus在这边落地的希望，虽然最终的目标是面向容器编程，但是在全部迁移上容器的过程中，肯定还需要兼容dubbo这种远程通讯方式的，相比于spring中的dubbo使用，quarkus目前只能手动注册服务和引入服务，博主尝试过使用BeanManager来进一步的自动化发布dubbo服务，但是没能找像spring中getBean（Type）这类的方法。相信随着对Quarkus和CDI的深入了解，这块也会有突破，那个时候就可以像spring中那么使用dubbo了

以上就是Quarkus集成Dubbo服务Rpc远程通讯框架整合的详细内容，更多关于Quarkus集成Dubbo服务Rpc远程通讯框架的资料请关注我们其它相关文章！

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。