remoting { connector { default "bisocket" bisocket { socket { serverBindAddress localhost } transportSelector default } } } public class OrderService { public void processOrder(Order order) { } public static void main(String[] args) throws Exception { Server server = new Server(); server.registerInvoker("OrderService", new OrderService()); server.start(); } } public class OrderClient { public void sendOrder(Order order) throws Exception { Client client = new Client(); TransportConfiguration configuration = new TransportConfiguration("bisocket", new HashMap<>()); client.connect(configuration); InvocationRequest request = new InvocationRequest("OrderService", "processOrder", new Object[]{order}); client.invoke(request); client.close(); } }


上一篇:
下一篇:
切换中文