sofarpc详解

一、sofarpc延迟

SofaRPC是一个基于Java的高性能RPC框架，它的优势之一就是所谓的”延迟控制”技术。SofaRPC的延迟控制技术可以根据网络环境和传输的内容自动调节报文大小和数据压缩比率，从而达到最优的性能表现。

延迟控制模块可以自动感知网络波动，通过动态调整传输的字节数和数据压缩比率以适应网络环境波动，从而在保证性能的同时，还可以保障数据传输的可靠性。其代码示例如下：

@SofaService
public class ExampleService {

    @SofaMethod(timeout = 500)
    public String hello(String name) {
        return "Hello, " + name;
    }

}

二、sofarpc grpc

SofaRPC还提供了与grpc之间的互操作性，支持使用grpc代码生成功能调用SofaRPC服务。同时，SofaRPC搭配使用grpc-gateway，使得SofaRPC API可以被HTTP协议调用。

与grpc的互操作示例代码如下：

@SofaService
public class ExampleService {

    @SofaMethod(timeout = 500)
    public String hello(String name) {
        return "Hello, " + name;
    }

}

ManagedChannel channel = NettyChannelBuilder.forAddress("localhost", 50051)
                .usePlaintext()
                .build();

ExampleServiceGrpc.ExampleServiceBlockingStub blockingStub = ExampleServiceGrpc.newBlockingStub(channel);

HelloWorldProto.HelloRequest request = HelloWorldProto.HelloRequest.newBuilder().setName("World").build();
HelloWorldProto.HelloReply response = blockingStub.sayHello(request);

channel.shutdownNow();

三、sofarpc泛化调用

在SofaRPC中，泛化调用是一种特殊的调用方式，它可以通过泛型让客户端更加灵活地调用服务。泛化调用只需要传入接口名、方法名以及参数列表等信息，服务端就可以根据这些信息定位并执行正确的服务方法。

泛化调用示例代码如下：

GenericService genericService = (GenericService) proxyFactory.getProxy();

Object result = genericService.$invoke("hello", new String[]{"java.lang.String"}, new Object[]{"world"});

四、sofarpc使用nacos

SofaRPC提供了内置的nacos依赖项，可以简单地对服务进行注册和发现。使用SofaRPC配合nacos，使得服务注册与发现更加方便和快捷。

使用nacos服务注册示例代码如下：

@Configuration
public class SofaRpcConfig {

   @Bean
   public RegistryConfig registryConfig() {
      RegistryConfig registryConfig = new RegistryConfig();
      registryConfig.setProtocol("nacos");
      registryConfig.setAddress("localhost:8848");
      return registryConfig;
   }
}

五、sofarpc与dubbo对比

在RPC框架的选择上，SofaRPC和dubbo都有着各自的优势。SofaRPC注重高性能和高可扩展性，在复杂的场景中表现出色；而dubbo更加侧重服务治理，适合于中小型企业服务的构建。

谈及SofaRPC和dubbo的对比，它们的差异在于不同的应用场景和业务需求。在现有的技术竞争中，SofaRPC凭借其出色的性能和扩展性逐渐成为RPC框架的一大选择。

六、sofarpc远程调试端口配置

在SofaRPC开发中，经常需要远程调试服务，需进行远程端口的配置。SofaRPC提供了远程端口随机化配置和手动配置两种方式，可以根据需要选择。

远程调试端口配置的示例代码如下：

@SofaService(uniqueId = "exampleService")
public class ExampleServiceImpl implements ExampleService {

    @Override
    public String sayHello(String name) {
        int port = RpcRuntimeContext.registryConfig().getPort();
        return "Hello, " + name + " from port: " + port;
    }

}

-Dcom.alipay.sofa.rpc.port=20000
-Dcom.alipay.sofa.rpc.port=0

七、sofarpc服务注册不到nacos

在使用SofaRPC和nacos进行服务注册时，如果服务没有注册成功，可能是因为nacos的启动条件没有满足。可以通过多个方面排查问题，确保服务成功注册到nacos中。

排查服务注册不到nacos的示例代码如下：

@Configuration
public class SofaRpcConfig {

    @Bean
    public ProviderConfig providerConfig() {
        ProviderConfig providerConfig = new ProviderConfig();
        providerConfig.setRegister(true);
        providerConfig.setRegister(false);
        //其他配置
        return providerConfig;
    }
}

八、查看sofarpc注册状态

查看SofaRPC服务的注册状态，可以通过调用SPI的方式，获取当前已注册的服务。

查看注册状态的示例代码如下：

List exporters = RpcBootstrap.getRpcContext().getRuntimeContext().getExporters();
for (Exporter exporter : exporters) {
    System.out.println(exporter.getServiceType() + " " + exporter.getUniqueId() + " " + exporter.getPort());
}

九、springboot调用sofarpc

在使用SpringBoot调用SofaRPC服务时，需要将SofaRPC和Spring集成，并进行相关配置。SpringBoot提供了自动配置的方式，使得调用SofaRPC服务可以更加简单快捷。

SpringBoot调用SofaRPC的示例代码如下：

@SofaReference(uniqueId = "exampleService")
private ExampleService exampleService;

@GetMapping("/hello")
public String hello(String name) {
    return exampleService.sayHello(name);
}

@Configuration
public class SofaRpcConfig {

    @Bean
    public RegistryConfig registryConfig() {
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setAddress("localhost:8848");
        registryConfig.setProtocol("nacos");
        return registryConfig;
    }

    @Bean
    public ConsumerConfig consumerConfig() {
        return new ConsumerConfig();
    }
}