關(guān)于dubbo的RPC和RESTful性能及對(duì)比

更新時(shí)間：2022年12月19日 10:04:44 作者：fomeiherz

這篇文章主要介紹了關(guān)于dubbo的RPC和RESTful性能及對(duì)比，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

先上結(jié)論

RPC請(qǐng)求的效率是HTTP請(qǐng)求的1.6倍左右，性能明顯比HTTP請(qǐng)求要高很多。

原因分析

RESTful是基于HTTP協(xié)議進(jìn)行交互的，HTTP協(xié)議包含大量的請(qǐng)求頭、響應(yīng)頭信息。

而dubbo是基于dubbo自定義的二進(jìn)制協(xié)議進(jìn)行傳輸，消息體比較簡(jiǎn)單，傳輸數(shù)據(jù)要小很多。

性能對(duì)比

HTTP請(qǐng)求代碼

// 服務(wù)端基于spring boot搭建
// 服務(wù)端代碼
@SpringBootApplication
@RestController
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

    @RequestMapping("/helloworld")
    public String helloworld() {
        return "hello world";
    }

}

// 客戶(hù)端代碼
import org.springframework.util.StopWatch;
import org.springframework.web.client.RestTemplate;

public class HelloworldTest {
    public static void main(String[] args) {
        RestTemplate restTemplate = new RestTemplate();
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();
        for (int j = 0; j < 10; j++) {
            System.out.println("------------------");
            for (int i = 1; i <= 10000; i++) {
                restTemplate.getForObject("http://127.0.0.1/helloworld", String.class);
                if (i % 1000 == 0) {
                    stopWatch.stop();
                    System.out.println(stopWatch.getTotalTimeSeconds());
                    stopWatch = new StopWatch();
                    stopWatch.start();
                }
            }
        }
    }
}

RPC代碼

// dubbo-demo工程的代碼，詳情請(qǐng)看：https://github.com/apache/dubbo/tree/master/dubbo-demo
// 服務(wù)端
public class DemoServiceImpl implements DemoService {

    @Override
    public String sayHello(String name) {
        return "Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress();
    }
}

// 客戶(hù)端
public class Consumer {

    public static void main(String[] args) {
        //Prevent to get IPV6 address,this way only work in debug mode
        //But you can pass use -Djava.net.preferIPv4Stack=true,then it work well whether in debug mode or not
        System.setProperty("java.net.preferIPv4Stack", "true");
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"META-INF/spring/dubbo-demo-consumer.xml"});
        context.start();
        DemoService demoService = (DemoService) context.getBean("demoService"); // get remote service proxy

        StopWatch stopWatch = new StopWatch();
        stopWatch.start();

        for (int j = 0; j < 10; j++) {
            System.out.println("-----------");
            for (int i = 1; i <= 10000; i++) {
                demoService.sayHello("world"); // call remote method
                if (i % 1000 == 0) {
                    stopWatch.stop();
                    System.out.println(stopWatch.getTotalTimeSeconds());
                    stopWatch = new StopWatch();
                    stopWatch.start();
                }
            }
        }
    }
}