Как установить тайм-аут поиска JNDI на Glassfish

Question

Из приведенного ниже кода я пытаюсь получить доступ к EJB на удаленной машине.

Код работает на Glassfish 4.1. в веб-приложении.

Properties props = new Properties();
props.put(Context.INITIAL_CONTEXT_FACTORY, 
    "com.sun.enterprise.naming.SerialInitContextFactory");

props.setProperty("org.omg.CORBA.ORBInitialHost","X.X.X.X");
props.setProperty("org.omg.CORBA.ORBInitialPort","3700"); 
//timeouts
props.setProperty("sun.rmi.transport.connectionTimeout","5000");
props.setProperty("sun.rmi.transport.tcp.handshakeTimeout","5000");
props.setProperty("sun.rmi.transport.tcp.responseTimeout","5000");
props.setProperty("sun.rmi.transport.tcp.readTimeout","5000");


props.setProperty("com.sun.corba.ee.transport.ORBWaitForResponseTimeout","5000");
props.setProperty("com.sun.corba.ee.transport.ORBTCPConnectTimeouts", "100:500:100:500");
props.setProperty("com.sun.corba.ee.transport.ORBTCPTimeouts", "500:2000:50:1000");

System.setProperty("com.sun.corba.ee.transport.ORBWaitForResponseTimeout","5000");
System.setProperty("com.sun.corba.ee.transport.ORBTCPConnectTimeouts","100:500:100:500"); 
System.setProperty("com.sun.corba.ee.transport.ORBTCPTimeouts","500:2000:50:1000"); 

System.setProperty("sun.rmi.transport.connectionTimeout","5000");
System.setProperty("sun.rmi.transport.tcp.handshakeTimeout","5000");
System.setProperty("sun.rmi.transport.tcp.responseTimeout","5000");
System.setProperty("sun.rmi.transport.tcp.readTimeout","5000");
//timeout
InitialContext ctx = new InitialContext(props);
MyRemoteInterface bean = (MyRemoteInterface) 
ctx.lookup("ejbname#EjbName");

Если поиск успешен - все работает отлично.

Однако проблема в том, что если удаленный компьютер недоступен, то код зависает ctx.lookup("ejbname#EjbName");, Время отличается от причины, для более 1 min 20 seconds если ip не существует и закончился 10 minutes если удаленная машина находится за брандмауэром, пока не выдаст исключение сбоя:

Severe:   org.omg.CORBA.COMM_FAILURE: FINE: 00410001: Connection failure: 
   ... 
   ...
Caused by: java.nio.channels.UnresolvedAddressException
    at sun.nio.ch.Net.checkAddress(Net.java:101)
    at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622)
    at com.sun.corba.ee.impl.misc.ORBUtility.openSocketChannel(ORBUtility.java:110)
    at org.glassfish.enterprise.iiop.impl.IIOPSSLSocketFactory.createSocket(IIOPSSLSocketFactory.java:329)

И вот еще одна причина:

Caused by: java.net.ConnectException: Connection timed out: connect
    at sun.nio.ch.Net.connect0(Native Method)
    at sun.nio.ch.Net.connect(Net.java:454)
    at sun.nio.ch.Net.connect(Net.java:446)
    at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:648)
    at com.sun.corba.ee.impl.misc.ORBUtility.openSocketChannel(ORBUtility.java:110)
    at org.glassfish.enterprise.iiop.impl.IIOPSSLSocketFactory.createSocket(IIOPSSLSocketFactory.java:329)

Я не хочу ждать так долго, чтобы выяснить, что поиск не удался. Все тайм-ауты, которые я установил выше, не помогли. Как я могу установить тайм-аут поиска или есть другие обходные пути?

Благодарю.

Answer 1

Я нашел обходной путь, используя Java concurrent.Future,

            MyRemoteInterface bean;
            java.util.concurrent.Future <Object> future; 
            java.util.concurrent.ExecutorService executorService = java.util.concurrent.Executors.newFixedThreadPool(1);
            future = executorService.submit(new java.util.concurrent.Callable<Object>() { 
               public Object call() throws Exception {
                   return ctx.lookup("ejbname#EjbName");
               }
             });

            try {
                  bean = (MyRemoteInterface) future.get(2L, java.util.concurrent.TimeUnit.SECONDS); 
                } catch (java.util.concurrent.ExecutionException ex) { 
                    ex.printStackTrace();
                    throw ex;
                }
                  catch (InterruptedException ee){
                      ee.printStackTrace();
                      throw ee;

                }
                   catch (TimeoutException te){
                       throw new Exception("Time Out!");
                }
                 finally {
                      future.cancel(true);
                      executorService.shutdown();
                }