基于dubbo框架下的RPC通讯协议性能测试 - lengfo

1 package business;
2
3 import ibusiness.IBusinessOrder;
4
5 import java.util.List;
6
7 import model.*;
8
9 public class BusinessOrder implements IBusinessOrder {
10 public String SendStr(String str) {
11 return str;
12 }
13
14 public List<OrderInfo> LoadOrders(List<OrderInfo> orders) {
15 return orders;
16 }
17
18 public OrderInfo LoadOrder(OrderInfo order) {
19 return order;
20 }
21 }

1 import java.util.List;
2
3 import org.springframework.context.ApplicationContext;
4 import org.springframework.context.support.FileSystemXmlApplicationContext;
5
6 import com.alibaba.dubbo.rpc.service.EchoService;
7 import common.Common;
8
9 import ibusiness.*;
10 import model.*;
11
12 public class Program {
13 public static void main(String[] args) throws Exception {
14
15 ApplicationContext ctx = new FileSystemXmlApplicationContext("src//applicationContext.xml");
16 IBusinessOrder orderBusiness = (IBusinessOrder) ctx.getBean("orderBusiness");
17
18 // EchoService echoService = (EchoService) orderBusiness;
19 // String status = echoService.$echo("OK").toString();
20 // if (!status.equals("OK")) {
21 // System.out.println("orderBusiness out of service!");
22 // return;
23 // } else {
24 // System.out.println("orderBusiness in service !");
25 // }
26
27 long startMili, endMili;
28 int loop = 100;
29
30 // 单个pojo
31 try {
32 OrderInfo order = Common.BuildOrder();
33 orderBusiness.LoadOrder(order); // 防止首次连接的开销
34
35 startMili = System.currentTimeMillis();
36 OrderInfo returnOrder = null;
37 for (int i = 0; i < loop; i++) {
38 returnOrder = orderBusiness.LoadOrder(order);
39 }
40 endMili = System.currentTimeMillis();
41 System.out.println("单个pojo 平均传输耗时为：" + ((endMili - startMili) / (float) loop) + "毫秒 ,返回对象BillNumber:" + returnOrder.getBillNumber());
42 } catch (Exception ex) {
43 System.out.println("单个pojo 测试失败!");
44 //ex.printStackTrace();
45 }
46
47 // pojo集合 (100)
48 try {
49 List<OrderInfo> orderList = Common.BuildOrderList();
50 startMili = System.currentTimeMillis();
51 List<OrderInfo> returnOrderList = null;
52 for (int i = 0; i < loop; i++) {
53 returnOrderList = orderBusiness.LoadOrders(orderList);
54 }
55 endMili = System.currentTimeMillis();
56 System.out.println("pojo集合 (100) 平均传输耗时为：" + ((endMili - startMili) / (float) loop) + "毫秒 ,返回记录数：" + returnOrderList.size());
57 } catch (Exception ex) {
58 System.out.println("pojo集合 (100) 测试失败!");
59 }
60
61 // 1K String
62 try {
63 String str1k = Common.Build1KString();
64 startMili = System.currentTimeMillis();
65 String returnStr1k = null;
66 for (int i = 0; i < loop; i++) {
67 returnStr1k = orderBusiness.SendStr(str1k);
68 }
69 endMili = System.currentTimeMillis();
70 System.out.println("1K String 平均传输耗时为：" + ((endMili - startMili) / (float) loop) + "毫秒,返回字符长度：" + returnStr1k.length());
71 } catch (Exception ex) {
72 System.out.println("1K String 测试失败!");
73 }
74
75 // 100K String
76 try {
77 String str100K = Common.Build100KString();
78 startMili = System.currentTimeMillis();
79 String returnStr100k = null;
80 for (int i = 0; i < loop; i++) {
81 returnStr100k = orderBusiness.SendStr(str100K);
82 }
83 endMili = System.currentTimeMillis();
84 System.out.println("100K String 平均传输耗时为：" + ((endMili - startMili) / (float) loop) + "毫秒,返回字符长度：" + returnStr100k.length());
85 } catch (Exception ex) {
86 System.out.println("100K String 测试失败!");
87 }
88
89 // 1M String
90 try {
91 String str1M = Common.Build1MString();
92 startMili = System.currentTimeMillis();
93 String returnStr1M = null;
94 for (int i = 0; i < loop; i++) {
95 returnStr1M = orderBusiness.SendStr(str1M);
96 }
97 endMili = System.currentTimeMillis();
98 System.out.println("1M String 平均传输耗时为：" + ((endMili - startMili) / (float) loop) + "毫秒,返回字符长度：" + returnStr1M.length());
99 } catch (Exception ex) {
100 System.out.println("1M String 测试失败!");
101 }
102
103 System.out.println("all test done!");
104 }
105 }

 

<dubbo:protocol name="dubbo" server="netty" port="30001" serialization="dubbo" /> 

单个POJO	1.45毫秒
POJO集合 (100)	3.42毫秒
1K String	0.94毫秒
100K String	4.35毫秒
1M String	27.92毫秒

C、dubbo 协议、netty 传输、java 序列化

<dubbo:protocol name="dubbo" server="netty" port="30001" serialization="java" /> 

<dubbo:protocol name="rmi" server="netty" port="1099" serialization="java" />   

单个POJO	1165毫秒
POJO集合 (100)	1311毫秒
1K String	1149毫秒
100K String	1273毫秒
1M String	2141毫秒

 

C、dubbo 协议、netty 传输、java 序列化

<dubbo:protocol name="dubbo" server="netty" port="30001" serialization="java" /> 

<dubbo:protocol name="rmi" server="netty" port="1099" serialization="java" />