public class RpcHessianClient { public static void main(String[] args) { String url = "http://localhost:8081/apis/hello"; HessianProxyFactory factory = new HessianProxyFactory(); ExecutorService es = Executors.newFixedThreadPool(10); int size = 1000000; final CountDownLatch cdl = new CountDownLatch(size); try { long start = System.currentTimeMillis(); factory.setUser("client1"); factory.setPassword("client1"); factory.setOverloadEnabled(true); final Hello basic = (Hello) factory.create(Hello.class, url); for (int i = 0; i < size; i++) { es.submit(new Runnable() { @Override public void run() { String u=basic.hello("guolei"); //System.out.println(u); cdl.countDown(); } }); } cdl.await(); long time = System.currentTimeMillis() - start; System.out.println("SayHello:"); System.out.println("耗時：" + (double) time / 1000 + " s"); System.out.println("平均:" + ((double) time) / size +" ms"); System.out.println("TPS:" + (double) size / ((double) time / 1000)); // System.out.println("Hello, " + s.getMail()); } catch (MalformedURLException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); }finally{ es.shutdown(); } } |