package rpc;

import java.util.concurrent.TimeUnit;

import static rpc.SimpleRpcFramework.export;

import static rpc.SimpleRpcFramework.use;

/**

* Created by 李恒名 on 2017/8/17.

*/

public class RpcTest {

private static final String HOST = "localhost";

private static final int PORT = 8888;

interface ComputeService {

int sum(int a, int b);

}

static class ComputeServiceImpl implements ComputeService {

@Override

public int sum(int a, int b) {

return a + b;

}

}

//服务提供者

static class Provider implements Runnable {

@Override

public void run() {

//暴露服务

export(new ComputeServiceImpl(), PORT);

}

}

//服务消费者

static class Customer implements Runnable {

@Override

public void run() {

//使用服务

ComputeService computeService = use(ComputeService.class, HOST, PORT);

for (int i = 0; i < 10; i++) {

int sum = computeService.sum(1, 1);

System.out.println("SUM:" + sum);

try {

TimeUnit.SECONDS.sleep(1);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}

public static void main(String[] args) {

new Thread(new Provider()).start();

new Thread(new Customer()).start();

new Thread(new Customer()).start();

}

}