<dependencies>
<dependency>
<groupId>org.jboss.remoting</groupId>
<artifactId>jboss-remoting</artifactId>
<version>3.5.1.Final</version>
</dependency>
</dependencies>
import org.jboss.remoting.*;
public class RemotingClient {
public static void main(String[] args) throws Exception {
Connector connector = new Connector();
connector.setConnectorURI("socket://localhost:1234");
connector.start();
ObjectLocator objectLocator = new ObjectLocator(connector);
MyService remoteService = (MyService) objectLocator.getRemoteObject("my-service");
String result = remoteService.doSomething();
System.out.println(result);
connector.stop();
}
}
import org.jboss.remoting.*;
public class RemotingServer {
public static void main(String[] args) throws Exception {
Server server = new Server();
server.setServerConfig("server.conf");
server.start();
MyService myService = new MyServiceImpl();
server.addInvocationHandler("my-service", myService);
Object waitObject = new Object();
synchronized (waitObject) {
waitObject.wait();
}
server.stop();
}
}