Java 11 RMI NoClassDefFoundError

2022-08-23 00:00:00 java rmi

我更新了我的应用程序以使用Java 11,并且在尝试通过RMI重新绑定对象时收到以下错误。该应用程序在Java 8上运行良好。

他们说NoClassDefFoundError可能是由于类路径中缺少类或静态块中的错误而发生的。

$Proxy0类显然是在运行时创建的类,因此它不应该位于类路径中,但我想知道rmiregristy是否知道这一点。

我没有看到任何可能导致问题的静态代码块。

接受任何建议。

2021-09-21 14:27:18,750 (3019) [main] WARN  org.ets.speechrater.pm.RPMServer [] - Unable to create RMI object Retrying
java.rmi.ServerError: Error occurred in server thread; nested exception is:
        java.lang.NoClassDefFoundError: Could not initialize class org.ets.speechrater.pm.$Proxy0
        at java.rmi/sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:388) ~[?:?]
        at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:200) ~[?:?]
        at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:197) ~[?:?]
        at java.base/java.security.AccessController.doPrivileged(Native Method) ~[?:?]
        at java.rmi/sun.rmi.transport.Transport.serviceCall(Transport.java:196) ~[?:?]
        at java.rmi/sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:562) ~[?:?]
        at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:796) ~[?:?]
        at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:677) ~[?:?]
        at java.base/java.security.AccessController.doPrivileged(Native Method) ~[?:?]
        at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:676) ~[?:?]
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
        at java.base/java.lang.Thread.run(Thread.java:829) [?:?]
        at java.rmi/sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteCall.java:303) ~[?:?]
        at java.rmi/sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:279) ~[?:?]
        at java.rmi/sun.rmi.server.UnicastRef.invoke(UnicastRef.java:380) ~[?:?]
        at java.rmi/sun.rmi.registry.RegistryImpl_Stub.rebind(RegistryImpl_Stub.java:158) ~[?:?]
        at java.rmi/java.rmi.Naming.rebind(Naming.java:177) ~[?:?]
        at org.ets.speechrater.pm.RPMServer.main(RPMServer.java:104) ~[SpeechServlet-classes.jar:?]
Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.ets.speechrater.pm.$Proxy0
        at jdk.internal.reflect.GeneratedSerializationConstructorAccessor2.newInstance(Unknown Source) ~[?:?]
        at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490) ~[?:?]
        at java.base/java.io.ObjectStreamClass.lambda$newInstance$0(ObjectStreamClass.java:1097) ~[?:?]
        at java.base/java.security.AccessController.doPrivileged(Native Method) ~[?:?]
        at java.base/java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:85) ~[?:?]
        at java.base/java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1105) ~[?:?]
        at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2180) ~[?:?]
        at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1679) ~[?:?]
        at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:493) ~[?:?]
        at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:451) ~[?:?]
        at java.rmi/sun.rmi.registry.RegistryImpl_Skel.dispatch(RegistryImpl_Skel.java:154) ~[?:?]
        at java.rmi/sun.rmi.server.UnicastServerRef.oldDispatch(UnicastServerRef.java:468) ~[?:?]
        at java.rmi/sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:298) ~[?:?]
        at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:200) ~[?:?]
        at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:197) ~[?:?]
        at java.base/java.security.AccessController.doPrivileged(Native Method) ~[?:?]
        at java.rmi/sun.rmi.transport.Transport.serviceCall(Transport.java:196) ~[?:?]
        at java.rmi/sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:562) ~[?:?]
        at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:796) ~[?:?]
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
        at java.base/java.lang.Thread.run(Thread.java:829) ~[?:?]
package org.ets.speechrater.pm;

import java.io.File;
import java.rmi.Naming;
import java.lang.SecurityManager;
import java.rmi.RemoteException;

import org.ets.research.srater.config.Config;
import org.ets.speechrater.properties.PropertiesAssist;
import org.ets.speechrater.util.ETSLogger;

/**
 * RPMServer
 * 
 * Operational wrapper for RPMImpl, which implements the speech recognition
 * (server) components.
 * 
 * 
 * 
 */
public class RPMServer { // class RPMServer

    static private ETSLogger logger = ETSLogger.getLogger(RPMServer.class
            .getName());

    static RPM rpm;

    // ///////////////////////////////////////////////////////////////////
    //
    // main()
    //
    // ///////////////////////////////////////////////////////////////////

    public static void main(String args[]) throws Throwable { // main()

        try {

            System.setSecurityManager(new SecurityManager());

            String propertyKey = null;
            String bindingName;
            int portNumber;
            String rmiAddr;
            int hostIndex = 0;
            boolean rpmSimMode = false;

            try { // get access to the logger
                PropertiesAssist.initPmProperty(args[0]);
            } // get access to the logger
            catch (Exception e) {
                String msg = "Unable to load properties";
                logger.error(msg);
                throw new RemoteException(msg, e);
            }
            
            try {
                if (args.length > 1)
                    hostIndex = Integer.parseInt(args[1]);
                else
                    hostIndex = 0;

                propertyKey = "rpm" + hostIndex + "BindingName";
                logger.debug("propertyKey " + propertyKey);

                bindingName = PropertiesAssist.getPmPropertyString(propertyKey);
                propertyKey = "rpm" + hostIndex + "Port";
                logger.debug("propertyKey " + propertyKey);
                portNumber = Integer.parseInt(PropertiesAssist
                        .getPmPropertyString(propertyKey));
            } catch (Exception e) {
                String msg = "Unable to get bindingName or port property. "
                        + propertyKey;
                logger.error(msg);

                throw new RemoteException(msg, e);
            }
            try {
                propertyKey = "rpmRMIAddr";
                rmiAddr = PropertiesAssist.getPmPropertyString(propertyKey);
            } catch (Exception e) {
                rmiAddr = null;
            }

            if (args.length > 2) {
                rpmSimMode = Boolean.parseBoolean(args[2]);
                logger.debug("rpmSimMode is " + rpmSimMode);
            }

            rpm = null;
            while (rpm == null) { // Retry until have reference
                try {
                    logger.debug("In server before Object rpm");
                    if (!rpmSimMode)
                        rpm = new RPMImpl(logger, portNumber);
                    else
                        rpm = new RPMImplSim(logger, portNumber);

                    logger.debug("RPM Implementation: " + rpm);
                    logger.debug("In server after Object rpm");
                    if (rmiAddr != null)
                        bindingName = rmiAddr + "/" + bindingName;

                    logger.debug("In server binding to " + bindingName);
                    Naming.rebind(bindingName, rpm);
                    logger.debug("In server after bind rpm to tagRPM");
                } catch (Exception e) { // catch block
                    logger.warn("Unable to create RMI object Retrying",e);
                    String msg = "Is rmiregistry running?";
                    logger.warn(msg);
                    logger.debug(e);
                    try {
                        Thread.sleep(2000);
                    } catch (InterruptedException ex) {
                        ex.printStackTrace();
                    }
                } // catch block
            } // Retry until have reference

            final String killFilename = PropertiesAssist
                    .getPmPropertyString("killFile.server");
            if (killFilename == null || killFilename.length() == 0) {
                logger.warn("Property not found: killFile.server");
            } else {
                final String finalBindingName = bindingName;
                Runnable killFileWatcher = new Runnable() {
                    public void run() {
                        File f = new File(killFilename);
                        while (f == null || !f.exists()) {
                            f = new File(killFilename);
                            try {
                                Thread.sleep(5000);
                            } catch (InterruptedException e) {
                            }
                        }

                        if (f.exists()) {
                            logger.info("Kill file found. Stopping server");
                            try {
                                rpm.shutdown();
                                logger.info("All recognizer instances shut down successfully.");
                                Naming.unbind(finalBindingName);
                                rpm = null;
                                logger.info("(Server) Bye.");
                                System.exit(0);
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    }
                };
                killFileWatcher.run();
            }
            logger.debug("RPMServer: End of main().");

        } catch (Throwable t) {
            logger.fatal("RPMServer: Throwable Exception caught " + t.toString(), t);

            throw t;
        }
    } // main()
} // class RPMServer
package org.ets.speechrater.pm;

import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.util.HashMap;
import java.util.Map;

import org.ets.research.srater.exceptions.RecognizerException;
import org.ets.research.srater.asrfa.FeatureExtractionPipeline;
import org.ets.research.srater.kaldi.KaldiPipeline;
import org.ets.research.srater.htk.HtkPipeline;
import org.ets.research.srater.config.Config;
import org.ets.research.srater.config.ConfigFactory;
import org.ets.research.srater.scoring.CTMData;
import org.ets.research.srater.scoring.SpeechSample;
import org.ets.research.srater.util.Tools;
import org.ets.research.srater.util.os.DirectoryHandler;
import org.ets.speechrater.ScoringRequest;
import org.ets.speechrater.properties.PropertiesAssist;
import org.ets.speechrater.util.ETSLogger;

//######################################################################
//
// class RPMImpl   implements RPM
//
// This object provides a very thin layer between a remote client
//    and a list of local Recognizers.
//
// Errors:
//    A message will be displayed
//       All messages coming from this class will begin with RPM
//    A trace of the trapped exception will be displayed
//    A remote exception will be thrown including the displayed
//       message and the text of the trapped exception.
//
// Errors: all throw RemoteException
//
// Client calls LPMRecognizer.extract()
// LPMRecognizer.extract() calls RPM.extract()
// RPM.extract() calls KaldiPipeline.extract()
//
//######################################################################

public class RPMImpl extends UnicastRemoteObject implements RPM { // class
                                                                    // RPMImpl

    static ETSLogger loggerPm;

    // ///////////////////////////////////////////////////////////////////
    //
    // private vars
    //
    // ///////////////////////////////////////////////////////////////////

    private static final long serialVersionUID = 271828182845904523L;

    private Map<String,FeatureExtractionPipeline[]> _RecognizerList;
    private boolean[] busyFlags;

    private int _numEVRecognizer;
    private String _msg; // last error. Keep

    // ///////////////////////////////////////////////////////////////////
    //
    // RPMImpl() constructor
    //
    // Construct an object as an rmi remote target.
    //
    // ///////////////////////////////////////////////////////////////////
    public RPMImpl(ETSLogger logger, int port) throws RemoteException { // RPMImpl()
                                                                        // constructor
        super(port); // Set the port
        _msg = "";
        loggerPm = logger;
        loggerPm.debug("RPMImpl constructed.");
    } // RPMImpl() constructor

    // ///////////////////////////////////////////////////////////////////
    //
    // init()
    //
    // instantiate a list of MultimodalRecognizer objects.
    // instantiate a list of EV Recognizer objects.
    //
    // ///////////////////////////////////////////////////////////////////
    public void init(int inNumEVRecognizer) throws Exception { // init()
        Config configTPO = ConfigFactory.makeConfig(PropertiesAssist.getPmPropertyString("research.tpo.config.name"));  //note it does not matter what config is used, because just basic things are used (e.g. basedir...)
        configTPO.load(PropertiesAssist.getPmPropertyString("research.master.config"));
        Config configNEWORIENTAL = ConfigFactory.makeConfig(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"));  //note it does not matter what config is used, because just basic things are used (e.g. basedir...)
        configNEWORIENTAL.load(PropertiesAssist.getPmPropertyString("research.master.config"));
        Config configTOEFLIBT = ConfigFactory.makeConfig(PropertiesAssist.getPmPropertyString("research.toeflibt.config"));
        configTOEFLIBT.load(PropertiesAssist.getPmPropertyString("research.master.config"));
        
        _numEVRecognizer = inNumEVRecognizer;

        if (PropertiesAssist.getPmPropertyString("Srater.recognizerType")
                .toUpperCase().equals("KALDI")) {
            _RecognizerList = new HashMap<String,FeatureExtractionPipeline[]>();
            _RecognizerList.put(PropertiesAssist.getPmPropertyString("research.tpo.config.name"),new KaldiPipeline[_numEVRecognizer]);
            _RecognizerList.put(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"),new KaldiPipeline[_numEVRecognizer]);
            _RecognizerList.put(PropertiesAssist.getPmPropertyString("research.toeflibt.config"),new KaldiPipeline[_numEVRecognizer]);
            
            loggerPm.debug("HTK Array initiaized");
        } else if (PropertiesAssist.getPmPropertyString("Srater.recognizerType")
                .toUpperCase().equals("HTK")) {
            _RecognizerList = new HashMap<String,FeatureExtractionPipeline[]>();
            _RecognizerList.put(PropertiesAssist.getPmPropertyString("research.tpo.config.name"),new HtkPipeline[_numEVRecognizer]);
            _RecognizerList.put(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"),new HtkPipeline[_numEVRecognizer]);
            _RecognizerList.put(PropertiesAssist.getPmPropertyString("research.toeflibt.config"),new HtkPipeline[_numEVRecognizer]);
            loggerPm.debug("HTK Array initiaized");
        } else {
            throw new Exception("Srater.recognizerType set to unknown type: "
                    + PropertiesAssist.getPmPropertyString(
                            "Srater.recognizerType").toUpperCase());
        }

        busyFlags = new boolean[_numEVRecognizer];

        loggerPm.debug("Ready to create " + _numEVRecognizer + " EVRecognizer");

        // Chi added
        String outputDirName = null;

        try {
            outputDirName = PropertiesAssist.getPmPropertyString("Srater.outputDirName");
        } catch (Exception e) {
            _msg = "Unable to get property MultimodalRecognizer arg";
            loggerPm.error(_msg, e);
            throw new RemoteException(_msg, e);
        }

        loggerPm.debug("Ready to create " + _numEVRecognizer + " EVRecognizer");
        for (int index = 0; index < _numEVRecognizer; index++) {
            try {
                if (PropertiesAssist
                        .getPmPropertyString("Srater.recognizerType")
                        .toUpperCase().equals("KALDI")) {
                    try {
                        _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.tpo.config.name"))[index] = new KaldiPipeline(configTPO);
                        _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"))[index] = new KaldiPipeline(configNEWORIENTAL);
                        _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.toeflibt.config"))[index] = new KaldiPipeline(configTOEFLIBT);
                    } catch (Throwable e) {
                        loggerPm.error("some type of error with recognizer" + e.getMessage());
                        
                        if (e instanceof RecognizerException) {
                            throw new RecognizerException(new Exception(e.getMessage()));
                        }
                        else{
                            throw new Exception(e.getMessage());
                        }
                        
                    }
                            //outputDirName,
                            //"",                           //note that archiving of dat and ctm are handled outside of extract now
                            //config);
                    loggerPm.debug("HTK Array[" + index + "] initiaized");
                } else if (PropertiesAssist
                        .getPmPropertyString("Srater.recognizerType")
                        .toUpperCase().equals("HTK")) {
                    try {
                        _RecognizerList.get("research.tpo.config.name")[index] = new HtkPipeline(configTPO);
                        _RecognizerList.get("research.neworiental.config.name")[index] = new HtkPipeline(configNEWORIENTAL);
                        _RecognizerList.get("research.toeflibt.config")[index] = new HtkPipeline(configTOEFLIBT);
                    } catch (Throwable e) {
                        loggerPm.error("some type of error with recognizer" + e.getMessage());
                        
                        if (e instanceof RecognizerException) {
                            throw new RecognizerException(new Exception(e.getMessage()));
                        }
                        else{
                            throw new Exception(e.getMessage());
                        }
                    }
                            //outputDirName,
                            //"",                           //note that archiving of dat and ctm are handled outside of extract now
                            //config);
                    loggerPm.debug("HTK Array[" + index + "] initiaized");
                } else {
                    throw new Exception(
                            "Srater.recognizerType set to unknown type: "
                                    + PropertiesAssist.getPmPropertyString(
                                            "Srater.recognizerType")
                                            .toUpperCase());
                }

                busyFlags[index] = false;
                loggerPm.debug("MultimodalRecognizer " + index + " Created");
            } catch (Exception e) {
                _msg = "RPM init failed";
                loggerPm.error(_msg, e);
                throw new RemoteException(_msg, e);
            }
        }
    } // init()



    /***
     * Note this saves TPO *.ctm and *.dat to files.
     *
     * @param ctm
     * @throws Exception
     *
     */
    public void generateDatFromCTMandArchiveDATandCTM(CTMData ctm, String fileName) throws Exception {
        String archiveFilenamePathAndPrefix = new File(PropertiesAssist.getPmPropertyString("Srater.dataWarehouseDir"),fileName).getAbsolutePath();

        //create dat file
        File outFile = new File(archiveFilenamePathAndPrefix + ".dat");
        PrintWriter pw = new PrintWriter(new FileWriter(outFile));
        pw.print(ctm.PfHeader());
        pw.print(ctm.getFeatureStr());
        pw.close();

        //create ctm file
        outFile = new File(archiveFilenamePathAndPrefix + ".ctm");
        pw = new PrintWriter(new FileWriter(outFile));
        pw.print(ctm.getCtm());
//      pw.print(ctm.PfHeader());
//      pw.print(ctm.getFeatureStr());
        pw.close();

    }







    // ///////////////////////////////////////////////////////////////////
    //
    // extract()
    //
    // call the specified MultimodalRecognizer in the object list.
    //
    // Client calls LPMRecognizer.extract()
    // LPMRecognizer.extract() calls RPM.extract()
    // RPM.extract() calls KaldiPipeline.extract()
    //
    // ///////////////////////////////////////////////////////////////////
    // public CTM extract( int index, SpeechSample toServ ) throws
    // RemoteException, RecognizerException
    // { // extract()

    public CTMData extract(
            int index,
            SpeechSample toServ,
            ScoringRequest scoringRequest,
            String modelName,
            String configName,
            String masterConfigFileName
            ) throws RemoteException,
            RecognizerException { // extract()
        String ID = toServ.getID();
        loggerPm.debug("RPM Ready to extract Thread " + index + "  DB " + ID);
        boolean saveTmpOnFailure = true;
        DirectoryHandler workingDirHandler = null;

        try {
            busyFlags[index] = true;

            Config config = ConfigFactory.makeConfig(configName);
            config.load(masterConfigFileName);
            loggerPm.warn("masterConfig>>>>:"+masterConfigFileName);

            try{
                saveTmpOnFailure = PropertiesAssist.getPmPropertyString("Srater.saveTempDirOnExtractFailure").equals("true");
            } catch (Exception any) {};


            //TPOv5 version of extract
            String baseDir = PropertiesAssist.getPmPropertyString("tmpPath");
            String dirPrefix = "recognizer_" + scoringRequest.getRequestID().getRequestID().toString() + "_";
//          String workingDir = new File(baseDir, dirPrefix).getAbsolutePath() + index;
            workingDirHandler = new DirectoryHandler(baseDir, dirPrefix);


            CTMData ctm = null;

            //save sound file to disk before extract
            String filenameWithExtension = new File(workingDirHandler.getWorkingDir(), toServ.getID() + "." + toServ.getSampleCodec()).getAbsolutePath() ;
            toServ.saveFile(filenameWithExtension);
            if (PropertiesAssist.getPmPropertyString("Srater.recognizerType")
                    .toUpperCase().equals("KALDI")) {
                ctm = ((KaldiPipeline)_RecognizerList.get(configName)[index]).extract(toServ, workingDirHandler);
            }
            else if (PropertiesAssist.getPmPropertyString("Srater.recognizerType")
                    .toUpperCase().equals("HTK")) {
                ctm = ((HtkPipeline)_RecognizerList.get(configName)[index]).extract(toServ, workingDirHandler);
            }

            ctm.SetSampleID(toServ.getID());
//          generateCdatFromCTM();

            //create dat and ctm files and archive them
            // !!! adding proper file name as a parameter
            generateDatFromCTMandArchiveDATandCTM(ctm,
                    scoringRequest.getRequestID()+"-"+scoringRequest.getClientRequestID());

            //clean up directory
            if(PropertiesAssist.getPmPropertyString("Srater.deleteTempfiles").equals("true")){
                workingDirHandler.deleteWorkingDir();
                
            }
            else{
                loggerPm.debug("not deleting temporary files for: " + scoringRequest.getRequestID().getRequestID().toString() + " , directory: " + workingDirHandler.getWorkingDir().toPath().toAbsolutePath().toString());
            }



//          CTMData ctm = _RecognizerList[index].extract(
//                  toServ,
//                  PropertiesAssist.getPmPropertyString("Srater.deleteOutputfiles").equals("true"),
//                  PropertiesAssist.getPmPropertyString("Srater.deleteTempfiles").equals("true"),
//                  scoringRequest.getRequestID() + "-"+ scoringRequest.getClientRequestID(),
//                  modelName
//                  ,config
//
//          );

            loggerPm.debug("Extract Features Header:" + ctm.PfHeader());
//          loggerPm.debug("Extract Features Values:"
//                  + ctm.PfOutput(""));
            loggerPm.debug("Extract Features Names and Values:"
                    + ctm.getFeatureStr());



            loggerPm.debug("RPM Done extract Thread " + index + "  DB " + ID);
            return (ctm);

        } catch (RecognizerException e) {
            _msg = "RPM extract caught RecognizerException (" + e.getMessage()
                    + ") Thread " + index + "  DB " + ID;
            loggerPm.warn(_msg, e);

            try{
                if(!saveTmpOnFailure && workingDirHandler != null)
                    workingDirHandler.deleteWorkingDir();
            }catch(Exception any){}

            throw e;
        } catch (Throwable t) {
            _msg = "RPM extract failed Thread " + index + "  DB " + ID;
            loggerPm.warn(_msg + t.toString(), t);
            throw new RemoteException(_msg, t);
        }

    } // extract()

    // ///////////////////////////////////////////////////////////////////
    //
    // refresh()
    //
    // One of the recognizers has failed.
    // This method replaces the broken object with a new one.
    //
    // ///////////////////////////////////////////////////////////////////
    public void refresh(int index) throws RemoteException { // refresh()


        // Chi added
        String outputDirName = null;

        try {

            outputDirName = PropertiesAssist
                    .getPmPropertyString("Srater.outputDirName");

        } catch (Exception e) {
            _msg = "Unable to get property MultimodalRecognizer arg";
            loggerPm.error(_msg, e);
            throw new RemoteException(_msg, e);
        }
        try {
//          Config.readMasterConfig(PropertiesAssist.getPmPropertyString("research.master.config"));
//          Config.setCurrentConfig(PropertiesAssist.getPmPropertyString("research.tpo.config.name"));
            Config configTPO = ConfigFactory.makeConfig(PropertiesAssist.getPmPropertyString("research.tpo.config.name"));  //note it does not matter what config is used, because just basic things are used (e.g. basedir...)
            configTPO.load(PropertiesAssist.getPmPropertyString("research.master.config"));
            Config configNEWORIENTAL = ConfigFactory.makeConfig(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"));  //note it does not matter what config is used, because just basic things are used (e.g. basedir...)
            configNEWORIENTAL.load(PropertiesAssist.getPmPropertyString("research.master.config"));
            Config configTOEFLIBT = ConfigFactory.makeConfig(PropertiesAssist.getPmPropertyString("research.toeflibt.config"));
            configTOEFLIBT.load(PropertiesAssist.getPmPropertyString("research.master.config"));


            if (PropertiesAssist.getPmPropertyString("Srater.recognizerType")
                    .toUpperCase().equals("HTK")) {
                try {
                    _RecognizerList.get(PropertiesAssist.getPmPropertyString(PropertiesAssist.getPmPropertyString("research.tpo.config.name")))[index] = new HtkPipeline(configTPO);
                    _RecognizerList.get(PropertiesAssist.getPmPropertyString(PropertiesAssist.getPmPropertyString("research.neworiental.config.name")))[index] = new HtkPipeline(configNEWORIENTAL);                    
                    _RecognizerList.get(PropertiesAssist.getPmPropertyString(PropertiesAssist.getPmPropertyString("research.toeflibt.config")))[index] = new HtkPipeline(configTOEFLIBT);                   
                } catch (Throwable e) {
                    loggerPm.error("some type of error with recognizer" + e.getMessage());
                    
                    if (e instanceof RecognizerException) {
                        throw new RecognizerException(new Exception(e.getMessage()));
                    }
                    else{
                        throw new Exception(e.getMessage());
                    }
                }
                        //outputDirName,
                        //"",                           //note that archiving of dat and ctm are handled outside of extract now
                        //config);
                loggerPm.debug("HTK Array[" + index + "] refreshed");
            } else if (PropertiesAssist
                    .getPmPropertyString("Srater.recognizerType").toUpperCase()
                    .equals("KALDI")) {
                try {
                    _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.tpo.config.name"))[index] = new KaldiPipeline(configTPO);
                    _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"))[index] = new KaldiPipeline(configNEWORIENTAL);
                    _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.toeflibt.config"))[index] = new KaldiPipeline(configTOEFLIBT);
                } catch (Throwable e) {
                    loggerPm.error("some type of error with recognizer" + e.getMessage());
                    
                    if (e instanceof RecognizerException) {
                        throw new RecognizerException(new Exception(e.getMessage()));
                    }
                    else{
                        throw new Exception(e.getMessage());
                    }
                }
                        //outputDirName,
                        //"",                           //note that archiving of dat and ctm are handled outside of extract now
                        //config);
                loggerPm.debug("KALDI Array[" + index + "] refreshed");

            } else {
                throw new Exception(
                        "Srater.recognizerType set to unknown type: "
                                + PropertiesAssist.getPmPropertyString(
                                        "Srater.recognizerType").toUpperCase());
            }


            loggerPm.debug("MultimodalRecognizer " + index + " Refreshed");
        } catch (Exception e) {
            _msg = "RPM refresh failed";
            loggerPm.error(_msg, e);
            throw new RemoteException(_msg, e);
        }

    } // refresh()

    // ///////////////////////////////////////////////////////////////////
    //
    // pingRemote()
    //
    // Recovery has been attempted.
    // A reference has been acquired.
    // But is it a stale one that is still in the registry.
    // This method is used to validate.
    // If the reference is stale a remote exception is thrown.
    // If not stale "OK"
    //
    // ///////////////////////////////////////////////////////////////////
    public String pingRemote() throws RemoteException { // pingRemote()
        return ("OK");
    } // pingRemote()



    public void shutdown() {

        for (int i = 0; i < _numEVRecognizer; i++) {
            int retryCount = 0;
            while (busyFlags[i] && retryCount < 60) {
                loggerPm.debug("Recognizer " + (i + 1) + " is busy.");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                }
                retryCount++;
            }
            loggerPm.info("Shutting down recognizer instance " + (i + 1) + ".");

            try {
                _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.tpo.config.name"))[i].close();
                _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"))[i].close();
                _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.toeflibt.config"))[i].close();
            } catch (Exception e) {
                loggerPm.warn("Recognizer close (which removes the temporary directory used for that instance) - failed",e);
            }

            try {
                _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.tpo.config.name"))[i] = null;
                _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.neworiental.config.name"))[i] = null;
                _RecognizerList.get(PropertiesAssist.getPmPropertyString("research.toeflibt.config"))[i] = null;                
            } catch (Exception e) {
                loggerPm.warn("ignoring error when setting recognizer to null, because we are shutting down already");
            }
        }
        loggerPm.info("All recognizers have been shut down.");
    }

    public void setBusy(int index, boolean busy) throws RemoteException {
        loggerPm.debug("RPM recognizer(" + index + ") is "
                + (busy ? "" : "no longer ") + "busy.");
        busyFlags[index] = busy;
    }

} // class RPMImpl

jdk

如果我使用推荐答案附带的rmilist可执行文件,则会遇到此问题。但使用代码创建注册表似乎是一个很好的解决办法。

package org.ets.speechrater.util;

import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.util.concurrent.TimeUnit;

public class RMIregistry {
    static ETSLogger logger = ETSLogger.getLogger(RMIregistry.class
            .getName());
    
    public static void main(String args[]) {
        
        try {
            Registry registry = LocateRegistry.createRegistry(Integer.valueOf(args[0]));
            
            logger.info("Server ready");
            
            while(true) {
                TimeUnit.MINUTES.sleep(1000);
            }
            
        } catch (Exception e) {
            logger.error("Server exception: " + e.toString(),e);
        }
    }
}

相关文章