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();
    }
}