Java rmi: can't return object

In general, here is a special helloWorld for you to rivet

First of all, we run registryService itself with this file:

RegistryService.java

 package server; import client.TestObject; import java.rmi.Naming; import java.rmi.NotBoundException; import java.rmi.RemoteException; import java.io.Serializable; import java.util.*; public class TestService implements TestServiceInterface, Serializable { Map testServiceListenerQueueMap = new HashMap(); public TestService() throws Exception { init(); unBindFromRegistry(); bindToRegistry(); } private void init() throws Exception { } public String test() throws RemoteException { System.out.println( "test" ); return "Hello"; } public TestObject test2() throws RemoteException { return new TestObject(); } public static void main(String[] args) throws Exception { final TestService t = new TestService(); t.startLiveLoop(); t.unBindFromRegistry(); } public void startLiveLoop() { Thread cMainThread = new Thread(new Runnable() { public void run() { while (Thread.currentThread() != null) { try { //Thread.sleep(10000); Iterator itr = testServiceListenerQueueMap.keySet().iterator(); while (itr.hasNext()) { try { String name = (String) itr.next(); // Ваши какие то действия для очереди сообщений } catch (Exception e) { e.printStackTrace(); } } } catch (Exception e) { e.printStackTrace(); } } }}); cMainThread.setName("Live Loop"); //Start the thread cMainThread.start(); try { cMainThread.join(); } catch (InterruptedException e) { e.printStackTrace(); } } protected void bindToRegistry() { boolean bound = false; while (!bound) { try { System.out.println("Trying to bind " + BIND_NAME); java.rmi.server.UnicastRemoteObject.exportObject(this); java.rmi.registry.LocateRegistry.getRegistry().bind(BIND_NAME, this); bound = true; System.out.println("Successfully called bind() for " + BIND_NAME); }catch (Exception ex) { System.out.println("Could not bind " + BIND_NAME + ", trying to rebind"); try { java.rmi.registry.LocateRegistry.getRegistry().rebind(BIND_NAME, this); bound = true; System.out.println("Successfully called rebind() for " + BIND_NAME); }catch (Exception ex2) { System.out.println("Could not rebind " + BIND_NAME); ex2.printStackTrace(); } } //Sleep a little before attemping to bind again. try { Thread.sleep(5000); }catch (Exception ex1) { ex1.printStackTrace(); } } } protected void unBindFromRegistry() { try { System.out.println("Trying unbind() for " + BIND_NAME); java.rmi.registry.LocateRegistry.getRegistry().unbind(BIND_NAME); System.out.println("Successfully called unbind() for " + BIND_NAME); }catch (Exception ex) { System.out.println("Could not unbind() for " + BIND_NAME); } } public void ping() { //System.out.println("ping() :" + getClass().getName()); } } 

Then run this:

 package server; import client.TestObject; import java.rmi.Naming; import java.rmi.NotBoundException; import java.rmi.RemoteException; import java.io.Serializable; import java.util.*; public class TestService implements TestServiceInterface, Serializable { Map testServiceListenerQueueMap = new HashMap(); public TestService() throws Exception { init(); unBindFromRegistry(); bindToRegistry(); } private void init() throws Exception { } public String test() throws RemoteException { System.out.println( "test" ); return "Hello"; } public TestObject test2() throws RemoteException { return new TestObject(); } public static void main(String[] args) throws Exception { final TestService t = new TestService(); t.startLiveLoop(); t.unBindFromRegistry(); } public void startLiveLoop() { Thread cMainThread = new Thread(new Runnable() { public void run() { while (Thread.currentThread() != null) { try { //Thread.sleep(10000); Iterator itr = testServiceListenerQueueMap.keySet().iterator(); while (itr.hasNext()) { try { String name = (String) itr.next(); // Ваши какие то действия для очереди сообщений } catch (Exception e) { e.printStackTrace(); } } } catch (Exception e) { e.printStackTrace(); } } }}); cMainThread.setName("Live Loop"); //Start the thread cMainThread.start(); try { cMainThread.join(); } catch (InterruptedException e) { e.printStackTrace(); } } protected void bindToRegistry() { boolean bound = false; while (!bound) { try { System.out.println("Trying to bind " + BIND_NAME); java.rmi.server.UnicastRemoteObject.exportObject(this); java.rmi.registry.LocateRegistry.getRegistry().bind(BIND_NAME, this); bound = true; System.out.println("Successfully called bind() for " + BIND_NAME); }catch (Exception ex) { System.out.println("Could not bind " + BIND_NAME + ", trying to rebind"); try { java.rmi.registry.LocateRegistry.getRegistry().rebind(BIND_NAME, this); bound = true; System.out.println("Successfully called rebind() for " + BIND_NAME); }catch (Exception ex2) { System.out.println("Could not rebind " + BIND_NAME); ex2.printStackTrace(); } } //Sleep a little before attemping to bind again. try { Thread.sleep(5000); }catch (Exception ex1) { ex1.printStackTrace(); } } } protected void unBindFromRegistry() { try { System.out.println("Trying unbind() for " + BIND_NAME); java.rmi.registry.LocateRegistry.getRegistry().unbind(BIND_NAME); System.out.println("Successfully called unbind() for " + BIND_NAME); }catch (Exception ex) { System.out.println("Could not unbind() for " + BIND_NAME); } } public void ping() { //System.out.println("ping() :" + getClass().getName()); } } 

Well, the interface file itself: TestServiceInterface.java

 package server; import client.TestObject; import java.rmi.Remote; import java.rmi.RemoteException; public interface TestServiceInterface extends Remote{ public static final String BIND_NAME = "testRMI"; public String test() throws RemoteException; public TestObject test2() throws RemoteException; public void ping() throws RemoteException; } 

Now the server is running.

We start client Client.java

 package client; import java.rmi.Naming; import server.TestServiceInterface; public class Client { TestServiceInterface test; String RMIURL = "rmi://localhost/" + TestServiceInterface.BIND_NAME; public TestServiceInterface getTest() throws Exception { int attempts = 0; while (attempts < 5) { try { test.ping(); attempts++; Thread.sleep(100); break; }catch (Exception ex) { System.out.println("===> TestClient Connection failed! Reconnecting..."); test = (TestServiceInterface) Naming.lookup( RMIURL ); } } return test; } public void test(){ try{ getTest(); System.out.println( test.test() ); }catch(Exception e){ e.printStackTrace(); } } public void test2(){ try{ getTest(); TestObject to = test.test2(); System.out.println( to.t ); }catch(Exception e){ e.printStackTrace(); } } public static void main(String[] args){ Client c = new Client(); c.test(); c.test2(); } } 

TestObject.java

 package client; import java.io.Serializable; public class TestObject implements Serializable { public String t = "Hello World"; }