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

 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 LoadOrders(List 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  orderList = Common.BuildOrderList();
 50             startMili = System.currentTimeMillis();
 51             List returnOrderList = null;
 52             for (int i = 0; i